service

Documentation

Index

• func Dial(addr string) (*grpc.ClientConn, error)
• func EmptyhealthCheckHandler(context.Context) error
• type Closeable
• type GrpcHelthCheckClient
  • func NewGrpcServerHelthCheckClient(host string) (*GrpcHelthCheckClient, error)
  • func (c *GrpcHelthCheckClient) Check(ctx context.Context, name string) (healthpb.HealthCheckResponse_ServingStatus, error)
  • func (c *GrpcHelthCheckClient) Close()
• type GrpcServerInfo
  • func NewGrpcServerInfo(svc *GrpcService) *GrpcServerInfo
  • func (g *GrpcServerInfo) Metadata(ctx context.Context, req *svcmeta.GrpcMetadataRequest) (*svcmeta.GrpcMetadataReply, error)
• type GrpcServerInfoClient
  • func NewGrpcServerInfoClient(host string) (*GrpcServerInfoClient, error)
  • func (c *GrpcServerInfoClient) Close()
  • func (c *GrpcServerInfoClient) Info(ctx context.Context, in *svcmeta.GrpcMetadataRequest) ([]*svcmeta.GrpcServerMetadata, error)
• type GrpcService
  • func NewGrpcService(ctx context.Context, name string, desc *grpc.ServiceDesc, ...) (*GrpcService, error)
  • func (sh *GrpcService) Dispose()
  • func (sh *GrpcService) Info() map[string]string
  • func (sh *GrpcService) Serve() error
• type HeadlessService
  • func NewHeadlessService(ctx context.Context, name string, serve func(ctx context.Context) error) *HeadlessService
  • func (s HeadlessService) Serve() error
• type HttpService
  • func NewHttpService(ctx context.Context, name, resource string, ...) *HttpService
  • func (sh *HttpService) Serve() error
• type Service
  • func NewService(ctx context.Context, name string) *Service

Functions

func Dial

func Dial(addr string) (*grpc.ClientConn, error)

func EmptyhealthCheckHandler

func EmptyhealthCheckHandler(context.Context) error

Types

type Closeable

type Closeable interface {
	Close() error
}

type GrpcHelthCheckClient

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

func NewGrpcServerHelthCheckClient

func NewGrpcServerHelthCheckClient(host string) (*GrpcHelthCheckClient, error)

func (*GrpcHelthCheckClient) Check

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

func (*GrpcHelthCheckClient) Close

func (c *GrpcHelthCheckClient) Close()

type GrpcServerInfo

type GrpcServerInfo struct {
	svcmeta.UnimplementedGrpcMetadataServer
	// contains filtered or unexported fields
}

func NewGrpcServerInfo

func NewGrpcServerInfo(svc *GrpcService) *GrpcServerInfo

func (*GrpcServerInfo) Metadata

func (g *GrpcServerInfo) Metadata(ctx context.Context, req *svcmeta.GrpcMetadataRequest) (*svcmeta.GrpcMetadataReply, error)

type GrpcServerInfoClient

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

func NewGrpcServerInfoClient

func NewGrpcServerInfoClient(host string) (*GrpcServerInfoClient, error)

func (*GrpcServerInfoClient) Close

func (c *GrpcServerInfoClient) Close()

func (*GrpcServerInfoClient) Info

func (c *GrpcServerInfoClient) Info(ctx context.Context, in *svcmeta.GrpcMetadataRequest) ([]*svcmeta.GrpcServerMetadata, error)

type GrpcService

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

func NewGrpcService

func NewGrpcService(ctx context.Context, name string, desc *grpc.ServiceDesc,
	initHandler func(context.Context) (any, error),
	healthCheckHandler func(context.Context) error) (*GrpcService, error)

func (*GrpcService) Dispose

func (sh *GrpcService) Dispose()

func (*GrpcService) Info

func (sh *GrpcService) Info() map[string]string

func (*GrpcService) Serve

func (sh *GrpcService) Serve() error

type HeadlessService

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

func NewHeadlessService

func NewHeadlessService(ctx context.Context, name string, serve func(ctx context.Context) error) *HeadlessService

func (HeadlessService) Serve

func (s HeadlessService) Serve() error

type HttpService

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

func NewHttpService

func NewHttpService(ctx context.Context, name, resource string, initHandler func(context.Context) chi.Router) *HttpService

func (*HttpService) Serve

func (sh *HttpService) Serve() error

type Service

type Service struct {
	Name      string
	Addr      string
	StartTime time.Time
	Ctx       context.Context
}

func NewService

func NewService(ctx context.Context, name string) *Service