sender

Documentation

Index

• Constants
• type Chain
• type KafkaSender
  • func NewKafkaSender(chain Chain, dirName string) (*KafkaSender, error)
  • func (sender *KafkaSender) Start(brokerList []string, topic string) error
  • func (sender *KafkaSender) Stop(brokerList []string, topic string)
  • func (sender *KafkaSender) StopAll()
• type MqAccountBlock
• type Producer
  • func NewProducer(producerId uint8, brokerList []string, topic string, chain Chain, ...) (*Producer, error)
  • func NewProducerFromDb(producerId uint8, buf []byte, chain Chain, db *leveldb.DB) (*Producer, error)
  • func (producer *Producer) BrokerList() []string
  • func (producer *Producer) Deserialize(buffer []byte) error
  • func (producer *Producer) IsSame(brokerList []string, topic string) bool
  • func (producer *Producer) Serialize() ([]byte, error)
  • func (producer *Producer) Start() error
  • func (producer *Producer) Stop()
  • func (producer *Producer) Topic() string

Constants

const (
	DBKP_PRODUCER          = byte(1)
	DBKP_PRODUCER_HAS_SEND = byte(2)
)

const (
	STOPPED = iota
	RUNNING
)

Types

type Chain

type Chain interface {
	GetLatestBlockEventId() (uint64, error)
	GetEvent(eventId uint64) (byte, []types.Hash, error)
	vm_context.Chain
}

type KafkaSender

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

func NewKafkaSender

func NewKafkaSender(chain Chain, dirName string) (*KafkaSender, error)

func (*KafkaSender) Start

func (sender *KafkaSender) Start(brokerList []string, topic string) error

func (*KafkaSender) Stop

func (sender *KafkaSender) Stop(brokerList []string, topic string)

func (*KafkaSender) StopAll

func (sender *KafkaSender) StopAll()

type MqAccountBlock

type MqAccountBlock struct {
	ledger.AccountBlock
	Balance *big.Int
}

type Producer

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

func NewProducer

func NewProducer(producerId uint8, brokerList []string, topic string, chain Chain, db *leveldb.DB) (*Producer, error)

func NewProducerFromDb

func NewProducerFromDb(producerId uint8, buf []byte, chain Chain, db *leveldb.DB) (*Producer, error)

func (*Producer) BrokerList

func (producer *Producer) BrokerList() []string

func (*Producer) Deserialize

func (producer *Producer) Deserialize(buffer []byte) error

func (*Producer) IsSame

func (producer *Producer) IsSame(brokerList []string, topic string) bool

func (*Producer) Serialize

func (producer *Producer) Serialize() ([]byte, error)

func (*Producer) Start

func (producer *Producer) Start() error

func (*Producer) Stop

func (producer *Producer) Stop()

func (*Producer) Topic

func (producer *Producer) Topic() string