service

Documentation

Index

• func BuildErrorResponse(err error) (*api.CallResponse, error)
• func BuildSuccessfullResponse(payload interface{}) (*api.CallResponse, error)
• func UnmarshalRequestArgumentsInto(req *api.CallRequest, into interface{}) error
• type Service
  • func New(port string) Service
  • func (s *Service) Call(ctx context.Context, req *api.CallRequest) (*api.CallResponse, error)
  • func (s *Service) Init(ctx context.Context, req *api.InitRequest) (*api.InitResponse, error)
  • func (s *Service) RegisterEndpoint(name string, handler endpointHandler) error
  • func (s *Service) Run(ctx context.Context) error

Functions

func BuildErrorResponse

func BuildErrorResponse(err error) (*api.CallResponse, error)

func BuildSuccessfullResponse

func BuildSuccessfullResponse(payload interface{}) (*api.CallResponse, error)

func UnmarshalRequestArgumentsInto

func UnmarshalRequestArgumentsInto(req *api.CallRequest, into interface{}) error

Types

type Service

type Service struct {
	api.UnimplementedServiceServer
	Logger logger.Logger
	Port   string
	// contains filtered or unexported fields
}

Service implements the gRPC service to be used by the different catalog services

func New

func New(port string) Service

func (*Service) Call

func (s *Service) Call(ctx context.Context, req *api.CallRequest) (*api.CallResponse, error)

func (*Service) Init

func (s *Service) Init(ctx context.Context, req *api.InitRequest) (*api.InitResponse, error)

func (*Service) RegisterEndpoint

func (s *Service) RegisterEndpoint(name string, handler endpointHandler) error

func (*Service) Run

func (s *Service) Run(ctx context.Context) error