Versions in this module Expand all Collapse all v0 v0.1.1 Aug 16, 2018 v0.1.0 May 1, 2018 Changes in this version + const DEFAULT_MAX_WORK_QUEUE_SIZE + type Attribute struct + Key string + Value string + type AuthorizationException struct + ExtendedData []byte + Msg string + func (err *AuthorizationException) Error() string + type Context struct + func NewContext(connection messaging.Connection, contextId string) *Context + func (self *Context) AddEvent(event_type string, attributes []Attribute, event_data []byte) error + func (self *Context) AddReceiptData(data []byte) error + func (self *Context) DeleteState(addresses []string) ([]string, error) + func (self *Context) GetState(addresses []string) (map[string][]byte, error) + func (self *Context) SetState(pairs map[string][]byte) ([]string, error) + type InternalError struct + ExtendedData []byte + Msg string + func (err *InternalError) Error() string + type InvalidTransactionError struct + ExtendedData []byte + Msg string + func (err *InvalidTransactionError) Error() string + type TransactionHandler interface + Apply func(*processor_pb2.TpProcessRequest, *Context) error + FamilyName func() string + FamilyVersions func() []string + Namespaces func() []string + type TransactionProcessor struct + func NewTransactionProcessor(uri string) *TransactionProcessor + func (self *TransactionProcessor) AddHandler(handler TransactionHandler) + func (self *TransactionProcessor) SetMaxQueueSize(n uint) + func (self *TransactionProcessor) SetThreadCount(n uint) + func (self *TransactionProcessor) Shutdown() + func (self *TransactionProcessor) ShutdownOnSignal(siglist ...os.Signal) + func (self *TransactionProcessor) Start() error