grpc

Documentation

Index

• func Err(err error, comments ...string) error
• func NewGrpcClientFx[T ClientOptions, M GrpcClient2]() fx.Option
• func NewGrpcServerFx[T ServerOptions]() fx.Option
• func NewInsecureClient(grpcUrl string) (*grpc.ClientConn, error)
• func NewRequestLogger(logr *slog.Logger, comment string) *logger
• func ParseErr(err error) *errors.Error
• type Client
  • func NewGrpcClient(serverAddr string) (Client, error)
  • func NewGrpcClientV2(serverAddr string, opts GrpcConnectOpts) (Client, error)
• type ClientOptions
• type GrpcClient2
• type GrpcConnectOpts
• type Server
  • func NewGrpcServer(opts ServerOpts) (Server, error)
• type ServerOptions
• type ServerOpts

Functions

func Err

func Err(err error, comments ...string) error

func NewGrpcClientFx

func NewGrpcClientFx[T ClientOptions, M GrpcClient2]() fx.Option

func NewGrpcServerFx

func NewGrpcServerFx[T ServerOptions]() fx.Option

func NewInsecureClient

func NewInsecureClient(grpcUrl string) (*grpc.ClientConn, error)

func NewRequestLogger

func NewRequestLogger(logr *slog.Logger, comment string) *logger

func ParseErr

func ParseErr(err error) *errors.Error

Types

type Client

type Client interface {
	grpc.ClientConnInterface
	Close() error
}

func NewGrpcClient

func NewGrpcClient(serverAddr string) (Client, error)

func NewGrpcClientV2

func NewGrpcClientV2(serverAddr string, opts GrpcConnectOpts) (Client, error)

type ClientOptions

type ClientOptions interface {
	GetGRPCServerURL() string
}

type GrpcClient2

type GrpcClient2 interface {
	~*grpc.ClientConn
}

type GrpcConnectOpts

type GrpcConnectOpts struct {
	TLSConnect bool
	Logger     *slog.Logger

	ReconnectCheckInterval *time.Duration
}

type Server

type Server interface {
	grpc.ServiceRegistrar
	Listen(addr string) error
	Stop()
}

func NewGrpcServer

func NewGrpcServer(opts ServerOpts) (Server, error)

type ServerOptions

type ServerOptions interface {
	GetGRPCPort() uint16
}

type ServerOpts

type ServerOpts struct {
	ShowLogs bool
	Logger   *slog.Logger
}