api

Documentation

Index

• Variables
• func LogProtoMessage(msg interface{}) (attrs logger.Attrs)
• func NewService(backend service.Backend) (service.Service, error)
• func UnaryServerLogger() grpc.UnaryServerInterceptor
• type API
• type Constructor
• type Service
  • func (service *Service) Attach(name string, api API)
  • func (service *Service) Start() error
  • func (service *Service) Stop()

Variables

var (
	// JsonPbMarshaller is the marshaller used for serializing protobuf messages.
	JsonPbMarshaller = &jsonpb.Marshaler{}
)

Functions

func LogProtoMessage

func LogProtoMessage(msg interface{}) (attrs logger.Attrs)

LogProtoMessage serializes proto.Message into loggable attributes.

func NewService

func NewService(backend service.Backend) (service.Service, error)

func UnaryServerLogger

func UnaryServerLogger() grpc.UnaryServerInterceptor

Types

type API

type API interface {
	AttachToAPI(api *Service)
}

type Constructor

type Constructor func(backend service.Backend) (API, error)

type Service

type Service struct {
	GrpcServer *grpc.Server
	HttpServer *gin.Engine
	// contains filtered or unexported fields
}

func (*Service) Attach

func (service *Service) Attach(name string, api API)

func (*Service) Start

func (service *Service) Start() error

Start serves gRPC server and HTTP REST API Server on given TCP port.

func (*Service) Stop

func (service *Service) Stop()

Stop stops gRPC server.