og

Documentation

Index

• type OgProcessor
  • func NewOgProcessor(config OgProcessorConfig, originalDataProcessor ogws.OriginalDataProcessor) *OgProcessor
  • func (o *OgProcessor) ConsumeQueue()
  • func (o *OgProcessor) EnqueueSendToLedger(data interface{}) error
  • func (m *OgProcessor) Name() string
  • func (m *OgProcessor) Start()
  • func (m *OgProcessor) Stop()
• type OgProcessorConfig
• type Response
• type TxReq

Types

type OgProcessor

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

func NewOgProcessor

func NewOgProcessor(config OgProcessorConfig, originalDataProcessor ogws.OriginalDataProcessor) *OgProcessor

func (*OgProcessor) ConsumeQueue

func (o *OgProcessor) ConsumeQueue()

func (*OgProcessor) EnqueueSendToLedger

func (o *OgProcessor) EnqueueSendToLedger(data interface{}) error

func (*OgProcessor) Name

func (m *OgProcessor) Name() string

func (*OgProcessor) Start

func (m *OgProcessor) Start()

func (*OgProcessor) Stop

func (m *OgProcessor) Stop()

type OgProcessorConfig

type OgProcessorConfig struct {
	IdleConnectionTimeout time.Duration
	LedgerUrl             string
	BufferSize            int
	RetryTimes            int
}

type Response

type Response struct {
	//"data": "0x2f0d3ee49d9eb21a75249b348541574d11f6f70f36c50892b89db3e1dc4a591a",
	//"message": ""
	Data    interface{} `json:"data"`
	Message string      `json:"message"`
}

type TxReq

type TxReq struct {
	Data []byte `json:"data"`
}