grpcserver

type ApplyResourceHandler func(context.Context, *servicepb.FunctionServiceRequest) (*servicepb.FunctionServiceResponse, error)

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 DeleteResourceHandler func(context.Context, *servicepb.FunctionServiceRequest) (*emptypb.Empty, error)

type GrpcServer struct {
	servicepb.UnimplementedFunctionServiceServer
	// contains filtered or unexported fields
}

type Option func(*GrpcServer)

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