model

Documentation

Index

• type Account
• type AttributedOnchainSignature
• type Cursor
• type HexBytes
  • func (h HexBytes) MarshalBSONValue() (bsontype.Type, []byte, error)
  • func (h HexBytes) MarshalJSON() ([]byte, error)
  • func (h HexBytes) String() string
  • func (h *HexBytes) UnmarshalBSONValue(t bsontype.Type, src []byte) error
• type ID
• type Job
• type JobContractConfig
• type JobPeerAnnouncement
• type JobPendingTransmission
• type JobPersistentState
• type JobSpec
• type PendingTransmission
• type ReportTimestamp

Types

type Account

type Account string

type AttributedOnchainSignature

type AttributedOnchainSignature struct {
	Signature HexBytes `json:"signature" bson:"signature"`
	Signer    int      `json:"signer" bson:"signer"`
}

type Cursor

type Cursor struct {
	From  primitive.ObjectID  `json:"from,omitempty"`
	To    *primitive.ObjectID `json:"to,omitempty"`
	Limit int                 `json:"limit,omitempty"`
}

type HexBytes

type HexBytes []byte

func (HexBytes) MarshalBSONValue

func (h HexBytes) MarshalBSONValue() (bsontype.Type, []byte, error)

func (HexBytes) MarshalJSON

func (h HexBytes) MarshalJSON() ([]byte, error)

func (HexBytes) String

func (h HexBytes) String() string

func (*HexBytes) UnmarshalBSONValue

func (h *HexBytes) UnmarshalBSONValue(t bsontype.Type, src []byte) error

type ID

type ID string

type Job

type Job struct {
	ObjectID primitive.ObjectID `json:"-" bson:"_id,omitempty"`

	JobID     ID        `json:"jobId" bson:"jobId"`
	Spec      *JobSpec  `json:"spec" bson:"spec"`
	IsActive  bool      `json:"isActive" bson:"isActive"`
	CreatedAt time.Time `json:"createdAt" bson:"createdAt"`
}

type JobContractConfig

type JobContractConfig struct {
	ObjectID primitive.ObjectID `json:"-" bson:"_id,omitempty"`

	JobID        ID `json:"jobId" bson:"jobId"`
	ConfigDigest ID `json:"configDigest" bson:"configDigest"`

	ConfigCount           uint64     `json:"configCount" bson:"configCount"`
	Signers               []HexBytes `json:"signers" bson:"signers"`
	Transmitters          []Account  `json:"transmitters" bson:"transmitters"`
	F                     uint8      `json:"f" bson:"f"`
	OnchainConfig         HexBytes   `json:"onchainConfig" bson:"onchainConfig"`
	OffchainConfigVersion uint64     `json:"offchainConfigVersion" bson:"offchainConfigVersion"`
	OffchainConfig        []byte     `json:"offchainConfig" bson:"offchainConfig"`
}

type JobPeerAnnouncement

type JobPeerAnnouncement struct {
	ObjectID primitive.ObjectID `json:"-" bson:"_id,omitempty"`

	JobID     ID        `json:"jobId" bson:"jobId"`
	PeerID    ID        `json:"peerId" bson:"peerId"`
	Announce  []byte    `json:"announce" bson:"announce"`
	CreatedAt time.Time `json:"createdAt" bson:"createdAt"`
}

type JobPendingTransmission

type JobPendingTransmission struct {
	ObjectID primitive.ObjectID `json:"-" bson:"_id,omitempty"`

	JobID        ID `json:"jobId" bson:"jobId"`
	ConfigDigest ID `json:"configDigest" bson:"configDigest"`

	ReportTimestamp ReportTimestamp     `json:"reportTimestamp" bson:"reportTimestamp"`
	Transmission    PendingTransmission `json:"tx" bson:"tx"`

	CreatedAt time.Time `json:"createdAt" bson:"createdAt"`
}

type JobPersistentState

type JobPersistentState struct {
	ObjectID primitive.ObjectID `json:"-" bson:"_id,omitempty"`

	JobID        ID `json:"jobId" bson:"jobId"`
	ConfigDigest ID `json:"configDigest" bson:"configDigest"`

	Epoch                uint32   `json:"epoch" bson:"epoch"`
	HighestSentEpoch     uint32   `json:"highestSentEpoch" bson:"highestSentEpoch"`
	HighestReceivedEpoch []uint32 `json:"highestReceivedEpoch" bson:"highestReceivedEpoch"`
}

type JobSpec

type JobSpec struct {
	IsBootstrapPeer                        bool     `json:"isBootstrapPeer" bson:"isBootstrapPeer"`
	FeedID                                 ID       `json:"feedId" bson:"feedId"`
	KeyID                                  ID       `json:"keyId" bson:"keyId"`
	P2PBootstrapPeers                      []string `json:"p2pBootstrapPeers" bson:"p2pBootstrapPeers"`
	ContractConfigConfirmations            int      `json:"contractConfigConfirmations" bson:"contractConfigConfirmations"`
	ContractConfigTrackerSubscribeInterval string   `json:"contractConfigTrackerSubscribeInterval" bson:"contractConfigTrackerSubscribeInterval"`
	ObservationTimeout                     string   `json:"observationTimeout" bson:"observationTimeout"`
	BlockchainTimeout                      string   `json:"blockchainTimeout" bson:"blockchainTimeout"`
}

type PendingTransmission

type PendingTransmission struct {
	Time                 time.Time                    `json:"time" bson:"time"`
	ExtraHash            HexBytes                     `json:"extraHash" bson:"extraHash"`
	Report               HexBytes                     `json:"report" bson:"report"`
	AttributedSignatures []AttributedOnchainSignature `json:"signatures" bson:"signatures"`
}

type ReportTimestamp

type ReportTimestamp struct {
	Epoch uint32 `json:"epoch" bson:"epoch"`
	Round uint8  `json:"round" bson:"round"`
}