corpus

Documentation

Index

• type API
  • func New(config APIConfig, logger *otelzap.Logger, opts ...Option) API
  • func (a API) Start()
  • func (a API) Stop()
• type APIConfig
• type GRPC
  • func NewGRPC[T any](cfg GRPCConfig, log *otelzap.Logger, checkHealth func() error, ...) GRPC[T]
  • func (g *GRPC[T]) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)
  • func (g *GRPC[T]) GracefulStop()
  • func (g *GRPC[T]) Start()
  • func (g *GRPC[T]) Watch(_ *grpc_health_v1.HealthCheckRequest, server grpc_health_v1.Health_WatchServer) error
• type GRPCConfig
• type Option
  • func WithAdditionalHandler(pattern string, mux http.Handler) Option

Types

type API

type API struct {
	Mux        *chi.Mux
	Config     APIConfig
	Server     *http.Server
	Logger     *otelzap.Logger
	AddHandler http.Handler
}

func New

func New(config APIConfig, logger *otelzap.Logger, opts ...Option) API

func (API) Start

func (a API) Start()

func (API) Stop

func (a API) Stop()

type APIConfig

type APIConfig struct {
	Host string
	Port int
}

type GRPC

type GRPC[T any] struct {
	Logger *otelzap.Logger
	Server *grpc.Server
	// contains filtered or unexported fields
}

func NewGRPC

func NewGRPC[T any](cfg GRPCConfig, log *otelzap.Logger, checkHealth func() error, userMapper userMapperFunc[T], registrar func(g *grpc.Server)) GRPC[T]

func (*GRPC[T]) Check

func (g *GRPC[T]) Check(_ context.Context, _ *grpc_health_v1.HealthCheckRequest) (*grpc_health_v1.HealthCheckResponse, error)

func (*GRPC[T]) GracefulStop

func (g *GRPC[T]) GracefulStop()

func (*GRPC[T]) Start

func (g *GRPC[T]) Start()

func (*GRPC[T]) Watch

func (g *GRPC[T]) Watch(_ *grpc_health_v1.HealthCheckRequest, server grpc_health_v1.Health_WatchServer) error

type GRPCConfig

type GRPCConfig struct {
	Port          uint16
	Host          string
	Issuer        string
	Env           string
	Audiences     []string
	OTLPCollector string
}

type Option

type Option func(*API)

func WithAdditionalHandler

func WithAdditionalHandler(pattern string, mux http.Handler) Option