stream

package
v1.9.3 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 22, 2022 License: BSD-3-Clause Imports: 23 Imported by: 1

Documentation

Index

Constants

View Source 
const (
	IndexerTimeout = 3 * time.Minute
	MaxTxRead      = 500
)

Variables

View Source 
var (
	ErrUnknownVM = errors.New("unknown VM")

	ErrInvalidTopicName    = errors.New("invalid topic name")
	ErrWrongTopicEventType = errors.New("wrong topic event type")
	ErrWrongTopicNetworkID = errors.New("wrong topic networkID")
)
View Source 
var (

	// ErrNoMessage is no message
	ErrNoMessage = errors.New("no message")
)

Functions

func CChainNotReady added in v1.3.2 

func CChainNotReady(err error) bool

func ChainNotReady added in v1.4.5 

func ChainNotReady(err error) bool

func GetTopicName 

func GetTopicName(networkID uint32, chainID string, eventType EventType) string

func IndexNotReady added in v1.4.5 

func IndexNotReady(err error) bool

func NewMessage added in v1.1.2 

func NewMessage(id string,
	chainID string,
	body []byte,
	timestamp int64,
	nanosecond int64,
) services.Consumable

func NewProducerCChain added in v1.1.3 

func NewProducerCChain(sc *servicesctrl.Control, conf cfg.Config) utils.ListenCloser

func UpdateTxPool added in v1.4.5 

func UpdateTxPool(
	ctxTimeout time.Duration,
	conns *utils.Connections,
	persist db.Persist,
	txPool *db.TxPool,
	sc *servicesctrl.Control,
) error

Types

type EventType 

type EventType string
const (
	EventTypeConsensus EventType = "consensus"
	EventTypeDecisions EventType = "decisions"
)

type IndexType added in v1.4.5 

type IndexType byte
const (
	IndexTypeTransactions IndexType = iota
	IndexTypeVertices
	IndexTypeBlocks
)

func (IndexType) String added in v1.4.5 

func (t IndexType) String() string

type IndexedChain added in v1.4.5 

type IndexedChain byte
const (
	IndexXChain IndexedChain = iota
	IndexPChain
	IndexCChain
)

func (IndexedChain) String added in v1.4.5 

func (t IndexedChain) String() string

type Message 

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

Message is a message on the event stream

func (*Message) Body 

func (m *Message) Body() []byte

func (*Message) ChainID 

func (m *Message) ChainID() string

func (*Message) ID 

func (m *Message) ID() string

func (*Message) Nanosecond added in v1.2.0 

func (m *Message) Nanosecond() int64

func (*Message) Timestamp 

func (m *Message) Timestamp() int64

type ProcessorDB added in v1.2.3 

type ProcessorDB interface {
	Process(*utils.Connections, *db.TxPool) error
	Close() error
	ID() string
	Topic() []string
}

type ProcessorFactoryChainDB added in v1.2.3 

type ProcessorFactoryChainDB func(*servicesctrl.Control, cfg.Config, string, string) (ProcessorDB, error)

func NewConsumerDBFactory added in v1.2.3 

func NewConsumerDBFactory(factory serviceConsumerFactory, eventType EventType) ProcessorFactoryChainDB

NewConsumerFactory returns a processorFactory for the given service consumer

type ProcessorFactoryInstDB added in v1.2.3 

type ProcessorFactoryInstDB func(*servicesctrl.Control, cfg.Config) (ProcessorDB, error)

func NewConsumerCChainDB added in v1.2.3 

func NewConsumerCChainDB() ProcessorFactoryInstDB

type ProducerCChain added in v1.1.3 

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

func (*ProducerCChain) Close added in v1.1.3 

func (p *ProducerCChain) Close() error

func (*ProducerCChain) Failure added in v1.1.3 

func (p *ProducerCChain) Failure()

func (*ProducerCChain) ID added in v1.1.3 

func (p *ProducerCChain) ID() string

func (*ProducerCChain) Listen added in v1.1.3 

func (p *ProducerCChain) Listen() error

func (*ProducerCChain) Success added in v1.1.3 

func (p *ProducerCChain) Success()

type ProducerChain added in v1.4.5 

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

func NewProducerChain added in v1.4.5 

func NewProducerChain(sc *servicesctrl.Control, conf cfg.Config, chainID string, eventType EventType, indexerType IndexType, indexerChain IndexedChain) (*ProducerChain, error)

func (*ProducerChain) Close added in v1.4.5 

func (p *ProducerChain) Close() error

func (*ProducerChain) Failure added in v1.4.5 

func (p *ProducerChain) Failure()

func (*ProducerChain) ID added in v1.4.5 

func (p *ProducerChain) ID() string

func (*ProducerChain) Listen added in v1.4.5 

func (p *ProducerChain) Listen() error

func (*ProducerChain) Success added in v1.4.5 

func (p *ProducerChain) Success()

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.