presentation

Documentation

Index

• type Grpc
  • func NewGrpc(qh pp.QueryPort, ch pp.CommandPort) *Grpc
  • func (a *Grpc) GetErrors(ctx context.Context, req *pb_error.ErrorRequest) (*pb_error.Errors, error)
  • func (a *Grpc) GetLogsByFilter(ctx context.Context, filter *pb_logging.LogDataFilter) (*pb_logging.LogDatas, error)
  • func (a *Grpc) Log(ctx context.Context, logData *pb_logging.LogData) (*pb_logging.LoggingResult, error)
  • func (a *Grpc) Serve(port string)

Types

type Grpc

type Grpc struct {
	pb_error.UnimplementedErorrSvcServer
	pb_logging.UnimplementedLoggingSvcServer
	// contains filtered or unexported fields
}

Grpc is the gRPC API for the application

func NewGrpc

func NewGrpc(qh pp.QueryPort, ch pp.CommandPort) *Grpc

NewGrpc creates a new instance of Grpc

func (*Grpc) GetErrors

func (a *Grpc) GetErrors(ctx context.Context, req *pb_error.ErrorRequest) (*pb_error.Errors, error)

GetErrors returns the embedded errors.

func (*Grpc) GetLogsByFilter

func (a *Grpc) GetLogsByFilter(ctx context.Context, filter *pb_logging.LogDataFilter) (*pb_logging.LogDatas, error)

GetLogsByFilter returns the logs that match the given filter.

func (*Grpc) Log

func (a *Grpc) Log(ctx context.Context, logData *pb_logging.LogData) (*pb_logging.LoggingResult, error)

Log sends the given log to the application layer.

func (*Grpc) Serve

func (a *Grpc) Serve(port string)

Serve starts the API server