server

Documentation

Index

• type ConnectService
  • func NewConnectService(transaqHandler *transaq.TransaqHandler, ...) *ConnectService
  • func (s *ConnectService) FetchResponseData(_ *server2.DataRequest, srv server2.ConnectService_FetchResponseDataServer) error
  • func (s *ConnectService) SendCommand(_ context.Context, request *server2.SendCommandRequest) (*server2.SendCommandResponse, error)

Types

type ConnectService

type ConnectService struct {
	server2.UnimplementedConnectServiceServer
	// contains filtered or unexported fields
}

func NewConnectService

func NewConnectService(
	transaqHandler *transaq.TransaqHandler,
	messagesQueue *queue.FixedQueue[string],
	clientExists *client.ClientExists,
	logger *zerolog.Logger,
) *ConnectService

func (*ConnectService) FetchResponseData

func (s *ConnectService) FetchResponseData(_ *server2.DataRequest, srv server2.ConnectService_FetchResponseDataServer) error

func (*ConnectService) SendCommand

func (s *ConnectService) SendCommand(_ context.Context, request *server2.SendCommandRequest) (*server2.SendCommandResponse, error)