Documentation ¶
Index ¶
- Constants
- Variables
- func CChainNotReady(err error) bool
- func ChainNotReady(err error) bool
- func GetTopicName(networkID uint32, chainID string, eventType EventType) string
- func IndexNotReady(err error) bool
- func NewMessage(id string, chainID string, body []byte, timestamp int64, nanosecond int64) services.Consumable
- func NewProducerCChain(sc *servicesctrl.Control, conf cfg.Config) utils.ListenCloser
- func TrimNL(msg string) string
- func UpdateTxPool(ctxTimeout time.Duration, conns *utils.Connections, persist db.Persist, ...) error
- type EventType
- type IndexType
- type IndexedChain
- type Message
- type ProcessorDB
- type ProcessorFactoryChainDB
- type ProcessorFactoryInstDB
- type ProducerCChain
- type ProducerChain
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 ChainNotReady ¶ added in v1.4.5
func IndexNotReady ¶ added in v1.4.5
func NewMessage ¶ added in v1.1.2
func NewProducerCChain ¶ added in v1.1.3
func NewProducerCChain(sc *servicesctrl.Control, conf cfg.Config) utils.ListenCloser
func UpdateTxPool ¶ added in v1.4.5
Types ¶
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) Nanosecond ¶ added in v1.2.0
type ProcessorDB ¶ added in v1.2.3
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 ¶
Click to show internal directories.
Click to hide internal directories.