feeds

Documentation

Index

• Constants
• func NewORM(db *gorm.DB) *orm
• type FeedsManager
  • func (FeedsManager) TableName() string
• type ORM
• type PublicKey
  • func PublicKeyFromHex(hexStr string) (*PublicKey, error)
  • func (k PublicKey) MarshalJSON() ([]byte, error)
  • func (k *PublicKey) Scan(value interface{}) error
  • func (k PublicKey) String() string
  • func (k *PublicKey) UnmarshalJSON(in []byte) error
  • func (k PublicKey) Value() (driver.Value, error)
• type Service
  • func NewService(orm ORM) Service

Constants

const (
	JobTypeFluxMonitor       = "fluxmonitor"
	JobTypeOffchainReporting = "offchainreporting"
)

We only support OCR and FM for the feeds manager

Functions

func NewORM

func NewORM(db *gorm.DB) *orm

Types

type FeedsManager

type FeedsManager struct {
	ID        int32
	Name      string
	URI       string
	PublicKey PublicKey
	JobTypes  pq.StringArray `gorm:"type:text[]"`
	Network   string
	CreatedAt time.Time
	UpdatedAt time.Time
}

func (FeedsManager) TableName

func (FeedsManager) TableName() string

type ORM

type ORM interface {
	CountManagers() (int64, error)
	CreateManager(ctx context.Context, ms *FeedsManager) (int32, error)
	GetManager(ctx context.Context, id int32) (*FeedsManager, error)
	ListManagers(ctx context.Context) ([]FeedsManager, error)
}

type PublicKey

type PublicKey []byte

PublicKey defines a type which can be used for JSON and SQL.

func PublicKeyFromHex

func PublicKeyFromHex(hexStr string) (*PublicKey, error)

PublicKeyFromHex generates a public key from a hex string

func (PublicKey) MarshalJSON

func (k PublicKey) MarshalJSON() ([]byte, error)

func (*PublicKey) Scan

func (k *PublicKey) Scan(value interface{}) error

func (PublicKey) String

func (k PublicKey) String() string

func (*PublicKey) UnmarshalJSON

func (k *PublicKey) UnmarshalJSON(in []byte) error

func (PublicKey) Value

func (k PublicKey) Value() (driver.Value, error)

type Service

type Service interface {
	CountManagers() (int64, error)
	GetManager(id int32) (*FeedsManager, error)
	ListManagers() ([]FeedsManager, error)
	RegisterManager(ms *FeedsManager) (int32, error)
}

func NewService

func NewService(orm ORM) Service

NewService constructs a new feeds service