Versions in this module Expand all Collapse all v0 v0.0.5 Dec 31, 2021 v0.0.4 Nov 21, 2021 v0.0.3 Oct 26, 2021 Changes in this version + type PublicKey []byte + func PublicKeyFromHex(hexStr string) (*PublicKey, error) + func (k *PublicKey) Scan(value interface{}) error + func (k *PublicKey) UnmarshalJSON(in []byte) error + func (k PublicKey) MarshalJSON() ([]byte, error) + func (k PublicKey) String() string + func (k PublicKey) Value() (driver.Value, error) v0.0.2 Oct 11, 2021 Changes in this version + const JobTypeFluxMonitor + const JobTypeOffchainReporting + func NewORM(db *gorm.DB) *orm + type FeedsManager struct + CreatedAt time.Time + ID int64 + JobTypes pq.StringArray + Name string + Network string + PublicKey crypto.PublicKey + URI string + UpdatedAt time.Time + func (FeedsManager) TableName() string + type JobProposal struct + CreatedAt time.Time + FeedsManagerID int64 + ID int64 + JobID uuid.NullUUID + Spec string + Status JobProposalStatus + UpdatedAt time.Time + type JobProposalStatus string + const JobProposalStatusApproved + const JobProposalStatusPending + const JobProposalStatusRejected + type ORM interface + CountJobProposals func() (int64, error) + CountManagers func() (int64, error) + CreateJobProposal func(ctx context.Context, jp *JobProposal) (int64, error) + CreateManager func(ctx context.Context, ms *FeedsManager) (int64, error) + GetJobProposal func(ctx context.Context, id int64) (*JobProposal, error) + GetManager func(ctx context.Context, id int64) (*FeedsManager, error) + ListJobProposals func(ctx context.Context) ([]JobProposal, error) + ListManagers func(ctx context.Context) ([]FeedsManager, error) + type RPCHandlers struct + func NewRPCHandlers(svc Service, feedsManagerID int64) *RPCHandlers + func (h *RPCHandlers) ProposeJob(ctx context.Context, req *pb.ProposeJobRequest) (*pb.ProposeJobResponse, error) + type Service interface + Close func() error + CountManagers func() (int64, error) + CreateJobProposal func(jp *JobProposal) (int64, error) + GetManager func(id int64) (*FeedsManager, error) + ListManagers func() ([]FeedsManager, error) + RegisterManager func(ms *FeedsManager) (int64, error) + Start func() error + func NewService(orm ORM, ks keystore.CSAKeystoreInterface) Service
Go to main page