consumers

Documentation

Index

• type BlockConsumer
  • func NewBlockConsumer(client *ethclient.Client, channel chan *types.Header) BlockConsumer
  • func (bc *BlockConsumer) StartConsuming() error
  • func (bc *BlockConsumer) StopConsuming()
• type CancelledConsumer
  • func NewCancelledConsumer(ex *contracts.Exchange, out chan<- *CancelledMessage) CancelledConsumer
  • func (cc *CancelledConsumer) StartConsuming() error
  • func (cc *CancelledConsumer) StopConsuming()
• type CancelledMessage
  • func NewCancelledMessage(hash types.Hash, ack, reject chan<- types.Hash) *CancelledMessage
  • func (cm CancelledMessage) Ack()
  • func (cm CancelledMessage) Reject()
• type Consumer
• type Message
• type TradedConsumer
  • func NewTradedConsumer(ex *contracts.Exchange, conn *ethclient.Client, out chan<- *TradedMessage) TradedConsumer
  • func (tc *TradedConsumer) StartConsuming() error
  • func (tc *TradedConsumer) StopConsuming()
• type TradedMessage
  • func NewTradedMessage(tx types.Transaction, ack, reject chan<- types.Hash) *TradedMessage
  • func (tm TradedMessage) Ack()
  • func (tm TradedMessage) Reject()

Types

type BlockConsumer

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

func NewBlockConsumer

func NewBlockConsumer(client *ethclient.Client, channel chan *types.Header) BlockConsumer

func (*BlockConsumer) StartConsuming

func (bc *BlockConsumer) StartConsuming() error

func (*BlockConsumer) StopConsuming

func (bc *BlockConsumer) StopConsuming()

type CancelledConsumer

type CancelledConsumer struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewCancelledConsumer

func NewCancelledConsumer(ex *contracts.Exchange, out chan<- *CancelledMessage) CancelledConsumer

func (*CancelledConsumer) StartConsuming

func (cc *CancelledConsumer) StartConsuming() error

func (*CancelledConsumer) StopConsuming

func (cc *CancelledConsumer) StopConsuming()

type CancelledMessage

type CancelledMessage struct {
	Hash types.Hash
	// contains filtered or unexported fields
}

func NewCancelledMessage

func NewCancelledMessage(hash types.Hash, ack, reject chan<- types.Hash) *CancelledMessage

func (CancelledMessage) Ack

func (cm CancelledMessage) Ack()

func (CancelledMessage) Reject

func (cm CancelledMessage) Reject()

type Consumer

type Consumer interface {
	StartConsuming() error
	StopConsuming()
}

type Message

type Message interface {
	Ack()
	Reject()
}

type TradedConsumer

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

func NewTradedConsumer

func NewTradedConsumer(ex *contracts.Exchange, conn *ethclient.Client, out chan<- *TradedMessage) TradedConsumer

func (*TradedConsumer) StartConsuming

func (tc *TradedConsumer) StartConsuming() error

func (*TradedConsumer) StopConsuming

func (tc *TradedConsumer) StopConsuming()

type TradedMessage

type TradedMessage struct {
	Transaction types.Transaction
	// contains filtered or unexported fields
}

func NewTradedMessage

func NewTradedMessage(tx types.Transaction, ack, reject chan<- types.Hash) *TradedMessage

func (TradedMessage) Ack

func (tm TradedMessage) Ack()

func (TradedMessage) Reject

func (tm TradedMessage) Reject()