server

Documentation

Index

• type MessageQueue
  • func NewMessageQueue(writer driver.Writer, encoder message.Encoder) MessageQueue
  • func (mq MessageQueue) Close() error
  • func (mq MessageQueue) Flush() error
  • func (mq MessageQueue) PostAction(act message.ActionTrace) error
  • func (mq MessageQueue) PostHeartbeat(hb message.HeartBeat) error
  • func (mq MessageQueue) PostRollback(rb message.RollbackMessage) error
  • func (mq MessageQueue) PostTableDelta(delta message.TableDelta) error
  • func (mq MessageQueue) PostTransactionTrace(trace message.TransactionTrace) error
• type ShipProcessor
  • func SpawnProccessor(shipStream *shipclient.Stream, loader StateLoader, saver StateSaver, ...) *ShipProcessor
  • func (processor *ShipProcessor) Close() error
  • func (processor *ShipProcessor) FetchDeltas(value bool)
  • func (processor *ShipProcessor) GetCurrentBlock() uint32
  • func (processor *ShipProcessor) SetBlacklist(list types.Blacklist)
• type State
• type StateLoader
• type StateSaver

Types

type MessageQueue

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

MessageQueue takes care of message routing and encoding

func NewMessageQueue

func NewMessageQueue(writer driver.Writer, encoder message.Encoder) MessageQueue

func (MessageQueue) Close

func (mq MessageQueue) Close() error

func (MessageQueue) Flush

func (mq MessageQueue) Flush() error

func (MessageQueue) PostAction

func (mq MessageQueue) PostAction(act message.ActionTrace) error

Post a ActionTrace message to the queue

func (MessageQueue) PostHeartbeat

func (mq MessageQueue) PostHeartbeat(hb message.HeartBeat) error

func (MessageQueue) PostRollback

func (mq MessageQueue) PostRollback(rb message.RollbackMessage) error

func (MessageQueue) PostTableDelta

func (mq MessageQueue) PostTableDelta(delta message.TableDelta) error

func (MessageQueue) PostTransactionTrace

func (mq MessageQueue) PostTransactionTrace(trace message.TransactionTrace) error

type ShipProcessor

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

A ShipProcessor will consume messages from a ship stream, convert the messages into thalos specific ones, encode them and finally post them to an api.Writer

func SpawnProccessor

func SpawnProccessor(shipStream *shipclient.Stream, loader StateLoader, saver StateSaver, writer driver.Writer, abi *abi.AbiManager, codec message.Codec) *ShipProcessor

SpawnProcessor creates a new ShipProccessor that consumes the shipclient.Stream passed to it.

func (*ShipProcessor) Close

func (processor *ShipProcessor) Close() error

Close closes the writer associated with the processor.

func (*ShipProcessor) FetchDeltas

func (processor *ShipProcessor) FetchDeltas(value bool)

func (*ShipProcessor) GetCurrentBlock

func (processor *ShipProcessor) GetCurrentBlock() uint32

Get the current block.

func (*ShipProcessor) SetBlacklist

func (processor *ShipProcessor) SetBlacklist(list types.Blacklist)

type State

type State struct {
	// Last processed block
	CurrentBlock uint32
}

State represents thalos runtime state

type StateLoader

type StateLoader func(*State)

StateLoader is a function that loads a state.

type StateSaver

type StateSaver func(State) error

StateSaver is a function that saves a state.