grpclib

Documentation

Index

• func CreateClient[T any](new func(grpc.ClientConnInterface) T, opts ClientOptions) (res T, err error)
• func InternalError(msg string, err error, args ...interface{}) error
• func InvalidArgument(msg string, args ...interface{}) error
• func NotFound(msg string, args ...interface{}) error
• type ClientOptions
• type EnvServerConfig
• type GrpcServer
  • func NewGrpcServer(opts ServerOptions) (*GrpcServer, error)
  • func (gs *GrpcServer) Start() error
  • func (gs *GrpcServer) Stop()
• type ServerOptions
  • func ServerOptionsFromEnvConfig(cfg EnvServerConfig) ServerOptions

Functions

func CreateClient

func CreateClient[T any](new func(grpc.ClientConnInterface) T, opts ClientOptions) (res T, err error)

func InternalError

func InternalError(msg string, err error, args ...interface{}) error

func InvalidArgument

func InvalidArgument(msg string, args ...interface{}) error

func NotFound

func NotFound(msg string, args ...interface{}) error

Types

type ClientOptions

type ClientOptions struct {
	Url         string `validate:"required,url"`
	Logger      *slog.Logger
	Credentials *certlib.ClientTLSConfigFiles
	ServerName  string // Added for TLS verification
}

type EnvServerConfig

type EnvServerConfig struct {
	Port     int    `env:"GRPC_PORT" validate:"required,numeric"`
	CertFile string `env:"GRPC_CERT" validate:"omitempty,filepath"`
	KeyFile  string `env:"GRPC_KEY" validate:"omitempty,filepath"`
	CAFile   string `env:"GRPC_CA" validate:"omitempty,filepath"`
}

type GrpcServer

type GrpcServer struct {
	// contains filtered or unexported fields
}

func NewGrpcServer

func NewGrpcServer(opts ServerOptions) (*GrpcServer, error)

func (*GrpcServer) Start

func (gs *GrpcServer) Start() error

func (*GrpcServer) Stop

func (gs *GrpcServer) Stop()

type ServerOptions

type ServerOptions struct {
	Port        int               `validate:"required,number"`
	ServiceDesc *grpc.ServiceDesc `validate:"required"`
	Handler     interface{}       `validate:"required"`
	Logger      *slog.Logger
	TLSConfig   *certlib.ServerTLSConfigFiles `validate:"omitempty"`
}

func ServerOptionsFromEnvConfig

func ServerOptionsFromEnvConfig(cfg EnvServerConfig) ServerOptions