Documentation ¶
Index ¶
- func WithAllocHandler(h AllocHandler) func(*GrpcServer)
- func WithCheckHandler(h CheckHandler) func(*GrpcServer)
- func WithDeAllocHandler(h DeAllocHandler) func(*GrpcServer)
- func WithWatchHandler(h WatchHandler) func(*GrpcServer)
- type AllocHandler
- type CheckHandler
- type Config
- type DeAllocHandler
- type GrpcServer
- func (s *GrpcServer) AllocationRequest(ctx context.Context, req *allocpb.Request) (*allocpb.Response, error)
- func (s *GrpcServer) Check(ctx context.Context, in *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
- func (s *GrpcServer) DeAllocationRequest(ctx context.Context, req *allocpb.Request) (*allocpb.Response, error)
- func (s *GrpcServer) Start(ctx context.Context) error
- func (s *GrpcServer) Watch(in *healthpb.HealthCheckRequest, stream healthpb.Health_WatchServer) error
- type Option
- type WatchHandler
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func WithAllocHandler ¶
func WithAllocHandler(h AllocHandler) func(*GrpcServer)
func WithCheckHandler ¶
func WithCheckHandler(h CheckHandler) func(*GrpcServer)
func WithDeAllocHandler ¶
func WithDeAllocHandler(h DeAllocHandler) func(*GrpcServer)
func WithWatchHandler ¶
func WithWatchHandler(h WatchHandler) func(*GrpcServer)
Types ¶
type AllocHandler ¶
Alloc Handlers
type CheckHandler ¶
type CheckHandler func(context.Context, *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
Health Handlers
type Config ¶
type Config struct { // gRPC server address Address string // insecure server Insecure bool // MaxRPC MaxRPC int64 // request timeout Timeout time.Duration // CertDir is the directory that contains the server key and certificate. The // server key and certificate. CertDir string // CertName is the server certificate name. Defaults to tls.crt. CertName string // KeyName is the server key name. Defaults to tls.key. KeyName string // CaName is the ca certificate name. Defaults to ca.crt. CaName string }
type DeAllocHandler ¶
type GrpcServer ¶
type GrpcServer struct { allocpb.UnimplementedAllocationServer // contains filtered or unexported fields }
func New ¶
func New(c Config, opts ...Option) *GrpcServer
func (*GrpcServer) AllocationRequest ¶
func (*GrpcServer) Check ¶
func (s *GrpcServer) Check(ctx context.Context, in *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)
Check implements `service Health`.
func (*GrpcServer) DeAllocationRequest ¶
func (*GrpcServer) Watch ¶
func (s *GrpcServer) Watch(in *healthpb.HealthCheckRequest, stream healthpb.Health_WatchServer) error
Watch implements `service Health`.
type Option ¶
type Option func(*GrpcServer)
type WatchHandler ¶
type WatchHandler func(*healthpb.HealthCheckRequest, healthpb.Health_WatchServer) error
Click to show internal directories.
Click to hide internal directories.