services

Documentation

Index

• type Consumable
• type Consumer
• type ConsumerCtx
  • func NewConsumerContext(ctx context.Context, db dbr.SessionRunner, ts int64, nanosecond int64, ...) ConsumerCtx
  • func (ic *ConsumerCtx) ChainID() string
  • func (ic *ConsumerCtx) Ctx() context.Context
  • func (ic *ConsumerCtx) DB() dbr.SessionRunner
  • func (ic *ConsumerCtx) Persist() db.Persist
  • func (ic *ConsumerCtx) Time() time.Time

Types

type Consumable

type Consumable interface {
	ID() string
	ChainID() string
	Body() []byte
	Timestamp() int64
	Nanosecond() int64
}

type Consumer

type Consumer interface {
	Name() string
	Bootstrap(context.Context, *utils.Connections, db.Persist) error
	Consume(context.Context, *utils.Connections, Consumable, db.Persist) error
	ConsumeConsensus(context.Context, *utils.Connections, Consumable, db.Persist) error
	ParseJSON([]byte, *models.BlockProposal) ([]byte, error)
}

Consumer takes in Consumables and adds them to the service's backend

type ConsumerCtx

type ConsumerCtx struct {
	// contains filtered or unexported fields
}

func NewConsumerContext

func NewConsumerContext(ctx context.Context, db dbr.SessionRunner, ts int64, nanosecond int64, persist db.Persist, chainID string) ConsumerCtx

func (*ConsumerCtx) ChainID

func (ic *ConsumerCtx) ChainID() string

func (*ConsumerCtx) Ctx

func (ic *ConsumerCtx) Ctx() context.Context

func (*ConsumerCtx) DB

func (ic *ConsumerCtx) DB() dbr.SessionRunner

func (*ConsumerCtx) Persist

func (ic *ConsumerCtx) Persist() db.Persist

func (*ConsumerCtx) Time

func (ic *ConsumerCtx) Time() time.Time