grpc

Documentation

Index

• type Closeable
• type HealthCheckFn
• type HelthCheckClient
  • func NewHelthCheckClient(ctx context.Context, addr string, d service.GrpcDialer) (*HelthCheckClient, error)
  • func NewHelthCheckClientWithConn(conn *grpc.ClientConn) (*HelthCheckClient, error)
  • func (c *HelthCheckClient) Check(ctx context.Context, name string) (healthpb.HealthCheckResponse_ServingStatus, error)
  • func (c *HelthCheckClient) Close()
• type NewServiceFn
• type Option
  • func WithAddr(a *string) Option
  • func WithContext(ctx context.Context) Option
  • func WithHealthCheckFn(healthCheck HealthCheckFn) Option
  • func WithListener(l service.GrpcListener) Option
  • func WithName(n string) Option
  • func WithNewServiceFn(newService NewServiceFn) Option
  • func WithServiceDesc(serviceDesc *grpc.ServiceDesc) Option
• type Options
• type Service
  • func New(opts ...Option) (*Service, error)
  • func (g *Service) Addr() *string
  • func (g *Service) Dispose()
  • func (g *Service) DoServe(listener net.Listener) error
  • func (g *Service) Metadata() map[string]string
  • func (g *Service) Name() string
  • func (g *Service) Serve() error

Types

type Closeable

type Closeable interface {
	Close() error
}

type HealthCheckFn

type HealthCheckFn func(context.Context) error

type HelthCheckClient

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

func NewHelthCheckClient

func NewHelthCheckClient(ctx context.Context, addr string, d service.GrpcDialer) (*HelthCheckClient, error)

func NewHelthCheckClientWithConn

func NewHelthCheckClientWithConn(conn *grpc.ClientConn) (*HelthCheckClient, error)

func (*HelthCheckClient) Check

func (c *HelthCheckClient) Check(ctx context.Context, name string) (healthpb.HealthCheckResponse_ServingStatus, error)

func (*HelthCheckClient) Close

func (c *HelthCheckClient) Close()

type NewServiceFn

type NewServiceFn func(context.Context) (any, error)

type Option

type Option interface {
	Apply(*Options)
}

func WithAddr

func WithAddr(a *string) Option

Setters

func WithContext

func WithContext(ctx context.Context) Option

func WithHealthCheckFn

func WithHealthCheckFn(healthCheck HealthCheckFn) Option

func WithListener

func WithListener(l service.GrpcListener) Option

func WithName

func WithName(n string) Option

func WithNewServiceFn

func WithNewServiceFn(newService NewServiceFn) Option

func WithServiceDesc

func WithServiceDesc(serviceDesc *grpc.ServiceDesc) Option

type Options

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

type Service

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

func New

func New(opts ...Option) (*Service, error)

func (*Service) Addr

func (g *Service) Addr() *string

func (*Service) Dispose

func (g *Service) Dispose()

func (*Service) DoServe

func (g *Service) DoServe(listener net.Listener) error

func (*Service) Metadata

func (g *Service) Metadata() map[string]string

func (*Service) Name

func (g *Service) Name() string

func (*Service) Serve

func (g *Service) Serve() error