server

Documentation

Index

• Constants
• type ProcessingFunc
• type ReaderServer
  • func NewReaderServer(translatorData *common.TranslatorData, grpcServer *grpc.Server, ...) (server *ReaderServer, err error)
  • func (server *ReaderServer) GetConnectionManager() *network.ConnectionManager
  • func (server *ReaderServer) GetGRPCListener() net.Listener
  • func (server *ReaderServer) GetHTTPListener() net.Listener
  • func (server *ReaderServer) Start(parentContext context.Context)
  • func (server *ReaderServer) StartFromFileDescriptor(parentContext context.Context, fdHTTP, fdGRPC uintptr)
  • func (server *ReaderServer) Stop()
  • func (server *ReaderServer) StopListeners()

Constants

const (
	ConnectionTypeKey  = "connection_type"
	HTTPConnectionType = "http"
	GRPCConnectionType = "grpc"
)

Constants show possible connection types.

Types

type ProcessingFunc

type ProcessingFunc func(context.Context, []byte, net.Conn)

ProcessingFunc redirects processing of connection to HTTP handler or gRPC handler.

type ReaderServer

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

ReaderServer represents AcraTranslator server, connects with KeyStorage, configuration file, gRPC and HTTP request parsers.

func NewReaderServer

func NewReaderServer(translatorData *common.TranslatorData, grpcServer *grpc.Server, waitTimeout time.Duration) (server *ReaderServer, err error)

NewReaderServer creates Reader server with provided params.

func (*ReaderServer) GetConnectionManager

func (server *ReaderServer) GetConnectionManager() *network.ConnectionManager

GetConnectionManager returns ConnectionManager object

func (*ReaderServer) GetGRPCListener

func (server *ReaderServer) GetGRPCListener() net.Listener

GetGRPCListener returns GRPC listener object

func (*ReaderServer) GetHTTPListener

func (server *ReaderServer) GetHTTPListener() net.Listener

GetHTTPListener returns HTTP listener object

func (*ReaderServer) Start

func (server *ReaderServer) Start(parentContext context.Context)

Start setups gRPC handler or HTTP handler, poison records callbacks and starts listening to connections.

func (*ReaderServer) StartFromFileDescriptor

func (server *ReaderServer) StartFromFileDescriptor(parentContext context.Context, fdHTTP, fdGRPC uintptr)

StartFromFileDescriptor starts listening commands connections from file descriptor.

func (*ReaderServer) Stop

func (server *ReaderServer) Stop()

Stop stops AcraTranslator from accepting new connections, and gracefully close existing ones.

func (*ReaderServer) StopListeners

func (server *ReaderServer) StopListeners()

StopListeners stops our HTTP/GRPC listeners from accepting new connections