grpcserver

type CheckHandler func(context.Context, *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)

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 EndpointCreateHandler func(context.Context, *endpointpb.EndpointRequest) (*endpointpb.EmptyResponse, error)

type EndpointDeleteHandler func(context.Context, *endpointpb.EndpointRequest) (*endpointpb.EmptyResponse, error)

type EndpointGetHandler func(context.Context, *endpointpb.EndpointRequest) (*endpointpb.EndpointResponse, error)

type EndpointWatchHandler func(*endpointpb.WatchRequest, endpointpb.NodeEndpoint_EndpointWatchServer) error

type GrpcServer struct {
	wirepb.UnimplementedWireServer
	endpointpb.UnimplementedNodeEndpointServer
	// contains filtered or unexported fields
}

type Option func(*GrpcServer)

type WatchHandler func(*healthpb.HealthCheckRequest, healthpb.Health_WatchServer) error

type WireCreateHandler func(context.Context, *wirepb.WireRequest) (*wirepb.EmptyResponse, error)

type WireDeleteHandler func(context.Context, *wirepb.WireRequest) (*wirepb.EmptyResponse, error)

type WireGetHandler func(context.Context, *wirepb.WireRequest) (*wirepb.WireResponse, error)

type WireWatchHandler func(*wirepb.WatchRequest, wirepb.Wire_WireWatchServer) error