og

package
Version: v0.0.0-...-c772d2a Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Aug 26, 2020 License: Apache-2.0 Imports: 10 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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"`
}

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL