impl

Documentation

Index

• type ConfigServer
  • func NewConfigServer(config *proto.GrpcServerConfig, healthRegistry *HealthRegistry) *ConfigServer
  • func (s *ConfigServer) GetConfig(ctx context.Context, req *proto.ConfigRequest) (*proto.ConfigResponse, error)
• type HealthRegistry
  • func NewHealthRegistry() *HealthRegistry
  • func (r *HealthRegistry) Check(ctx context.Context, req *healthproto.HealthCheckRequest) (*healthproto.HealthCheckResponse, error)
  • func (r *HealthRegistry) MarkAsNotServing(service interface{})
  • func (r *HealthRegistry) MarkAsServing(service interface{})
  • func (r *HealthRegistry) Resume()
  • func (r *HealthRegistry) Shutdown()
  • func (r *HealthRegistry) Watch(req *healthproto.HealthCheckRequest, stream healthproto.Health_WatchServer) error

Types

type ConfigServer

type ConfigServer struct {
	proto.UnimplementedConfigServer
	// contains filtered or unexported fields
}

ConfigServer ... Implementation of auto-generated ConfigServer Grpc framework

func NewConfigServer

func NewConfigServer(
	config *proto.GrpcServerConfig,
	healthRegistry *HealthRegistry,
) *ConfigServer

NewConfigServer ...

func (*ConfigServer) GetConfig

func (s *ConfigServer) GetConfig(ctx context.Context, req *proto.ConfigRequest) (*proto.ConfigResponse, error)

GetConfig ...

type HealthRegistry

type HealthRegistry struct {
	healthproto.UnimplementedHealthServer
	// contains filtered or unexported fields
}

HealthRegistry ... Implementation of auto-generated ConfigServer Grpc framework See https://github.com/grpc/grpc/blob/master/doc/health-checking.md

func NewHealthRegistry

func NewHealthRegistry() *HealthRegistry

NewHealthRegistry ...

func (*HealthRegistry) Check

func (r *HealthRegistry) Check(ctx context.Context, req *healthproto.HealthCheckRequest) (*healthproto.HealthCheckResponse, error)

Check ...

func (*HealthRegistry) MarkAsNotServing

func (r *HealthRegistry) MarkAsNotServing(service interface{})

MarkAsNotServing ...

func (*HealthRegistry) MarkAsServing

func (r *HealthRegistry) MarkAsServing(service interface{})

MarkAsServing ...

func (*HealthRegistry) Resume

func (r *HealthRegistry) Resume()

Resume ... See health.Server.Resume

func (*HealthRegistry) Shutdown

func (r *HealthRegistry) Shutdown()

Shutdown ... See health.Server.Shutdown

func (*HealthRegistry) Watch

func (r *HealthRegistry) Watch(req *healthproto.HealthCheckRequest, stream healthproto.Health_WatchServer) error

Watch ...