grpc

Documentation

Index

• type ServerImpl
  • func NewServer(log *logan.Entry, listener net.Listener, pg *pg.Storage, ...) *ServerImpl
  • func (s *ServerImpl) AddOperation(_ context.Context, request *types.MsgAddOperationRequest) (*types.MsgAddOperationResponse, error)
  • func (s *ServerImpl) Info(_ context.Context, _ *types.MsgInfoRequest) (*types.MsgInfoResponse, error)
  • func (s *ServerImpl) RunGRPC(_ context.Context) error
  • func (s *ServerImpl) RunGateway(ctx context.Context) error
  • func (s *ServerImpl) Session(_ context.Context, request *types.MsgSessionRequest) (*types.MsgSessionResponse, error)
  • func (s *ServerImpl) Submit(ctx context.Context, request *types.MsgSubmitRequest) (*types.MsgSubmitResponse, error)

Types

type ServerImpl

type ServerImpl struct {
	types.UnimplementedServiceServer
	// contains filtered or unexported fields
}

func NewServer

func NewServer(
	log *logan.Entry,
	listener net.Listener,
	pg *pg.Storage,
	storage secret.Storage,
	pool *pool.Pool,
	swagger *config.SwaggerInfo,
	manager *core.SessionManager,
) *ServerImpl

func (*ServerImpl) AddOperation

func (s *ServerImpl) AddOperation(_ context.Context, request *types.MsgAddOperationRequest) (*types.MsgAddOperationResponse, error)

func (*ServerImpl) Info

func (s *ServerImpl) Info(_ context.Context, _ *types.MsgInfoRequest) (*types.MsgInfoResponse, error)

func (*ServerImpl) RunGRPC

func (s *ServerImpl) RunGRPC(_ context.Context) error

func (*ServerImpl) RunGateway

func (s *ServerImpl) RunGateway(ctx context.Context) error

func (*ServerImpl) Session

func (s *ServerImpl) Session(_ context.Context, request *types.MsgSessionRequest) (*types.MsgSessionResponse, error)

func (*ServerImpl) Submit

func (s *ServerImpl) Submit(ctx context.Context, request *types.MsgSubmitRequest) (*types.MsgSubmitResponse, error)