socket

Documentation

Index

• type SocketConnectionProcessor
  • func NewSocketProcessor(config SocketConnectionProcessorConfig, dataProcessor processors.DataProcessor, ...) *SocketConnectionProcessor
  • func (s *SocketConnectionProcessor) ProcessConnection(conn net.Conn) error
  • func (SocketConnectionProcessor) Start()
  • func (SocketConnectionProcessor) Stop()
• type SocketConnectionProcessorConfig

Types

type SocketConnectionProcessor

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

func NewSocketProcessor

func NewSocketProcessor(config SocketConnectionProcessorConfig, dataProcessor processors.DataProcessor, ledgerWriter backends.LedgerWriter) *SocketConnectionProcessor

func (*SocketConnectionProcessor) ProcessConnection

func (s *SocketConnectionProcessor) ProcessConnection(conn net.Conn) error

func (SocketConnectionProcessor) Start

func (SocketConnectionProcessor) Start()

func (SocketConnectionProcessor) Stop

func (SocketConnectionProcessor) Stop()

type SocketConnectionProcessorConfig

type SocketConnectionProcessorConfig struct {
	IdleConnectionTimeout time.Duration
}