grpc

Documentation

Index

• func NewGRPCServer(params grpcServerParams) *fxgrpc.GRPCServer
• func NewHTTPGatewayHandler() *fxgrpc.HTTPGatewayHandler
• func NewLivenessGateway() *fxgrpc.LivenessGatewayHandler
• func RunHTTPGateway(lc fx.Lifecycle, s fx.Shutdowner, logger *zap.Logger, cfg *fxgrpc.Config, ...) error
• type Handler
  • func NewHandler(params handlerParams) *Handler
  • func (h *Handler) CreateTransaction(ctx context.Context, _ *pbv1.BlockchainPeerServiceCreateTransactionRequest) (*pbv1.BlockchainPeerServiceCreateTransactionResponse, error)
  • func (h *Handler) GetBlocks(ctx context.Context, _ *pbv1.BlockchainPeerServiceGetBlocksRequest) (*pbv1.BlockchainPeerServiceGetBlocksResponse, error)
  • func (h *Handler) GetEntities(ctx context.Context, _ *pbv1.BlockchainPeerServiceGetEntitiesRequest) (*pbv1.BlockchainPeerServiceGetEntitiesResponse, error)
  • func (h *Handler) Validate(ctx context.Context, _ *pbv1.BlockchainPeerServiceValidateRequest) (*pbv1.BlockchainPeerServiceValidateResponse, error)

Functions

func NewGRPCServer

func NewGRPCServer(params grpcServerParams) *fxgrpc.GRPCServer

func NewHTTPGatewayHandler

func NewHTTPGatewayHandler() *fxgrpc.HTTPGatewayHandler

func NewLivenessGateway

func NewLivenessGateway() *fxgrpc.LivenessGatewayHandler

func RunHTTPGateway

func RunHTTPGateway(
	lc fx.Lifecycle,
	s fx.Shutdowner,
	logger *zap.Logger,
	cfg *fxgrpc.Config,
	g *fxgrpc.HTTPGatewayHandler,
) error

Types

type Handler

type Handler struct {
	pbv1.BlockchainPeerServiceServer
	// contains filtered or unexported fields
}

func NewHandler

func NewHandler(params handlerParams) *Handler

func (*Handler) CreateTransaction

func (h *Handler) CreateTransaction(ctx context.Context, _ *pbv1.BlockchainPeerServiceCreateTransactionRequest) (*pbv1.BlockchainPeerServiceCreateTransactionResponse, error)

func (*Handler) GetBlocks

func (h *Handler) GetBlocks(ctx context.Context, _ *pbv1.BlockchainPeerServiceGetBlocksRequest) (*pbv1.BlockchainPeerServiceGetBlocksResponse, error)

func (*Handler) GetEntities

func (h *Handler) GetEntities(ctx context.Context, _ *pbv1.BlockchainPeerServiceGetEntitiesRequest) (*pbv1.BlockchainPeerServiceGetEntitiesResponse, error)

func (*Handler) Validate

func (h *Handler) Validate(ctx context.Context, _ *pbv1.BlockchainPeerServiceValidateRequest) (*pbv1.BlockchainPeerServiceValidateResponse, error)