services

Documentation

Index

• type Consumable
• type Consumer
• type ConsumerCChain
• type ConsumerCtx
  • func NewConsumerContext(ctx context.Context, job *health.Job, db dbr.SessionRunner, ts int64, ...) ConsumerCtx
  • func (ic *ConsumerCtx) Ctx() context.Context
  • func (ic *ConsumerCtx) DB() dbr.SessionRunner
  • func (ic *ConsumerCtx) Job() *health.Job
  • func (ic *ConsumerCtx) Persist() idb.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, *servicesconn.Connections, idb.Persist) error
	Consume(context.Context, *servicesconn.Connections, Consumable, idb.Persist) error
	ConsumeConsensus(context.Context, *servicesconn.Connections, Consumable, idb.Persist) error
	ParseJSON([]byte) ([]byte, error)
}

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

type ConsumerCChain

type ConsumerCChain interface {
	Name() string
	Consume(context.Context, *servicesconn.Connections, Consumable, *cblock.Block, idb.Persist) error
	ParseJSON([]byte) ([]byte, error)
}

type ConsumerCtx

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

ConsumerCtx

func NewConsumerContext

func NewConsumerContext(
	ctx context.Context,
	job *health.Job,
	db dbr.SessionRunner,
	ts int64,
	nanosecond int64,
	persist idb.Persist,
) ConsumerCtx

func (*ConsumerCtx) Ctx

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

func (*ConsumerCtx) DB

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

func (*ConsumerCtx) Job

func (ic *ConsumerCtx) Job() *health.Job

func (*ConsumerCtx) Persist

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

func (*ConsumerCtx) Time

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