grpcserver

package
v0.0.0-...-984f6f0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Sep 18, 2023 License: Apache-2.0 Imports: 23 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func WithCheckHandler 

func WithCheckHandler(h CheckHandler) func(*GrpcServer)

func WithEndpointCreateHandler 

func WithEndpointCreateHandler(h EndpointCreateHandler) func(*GrpcServer)

func WithEndpointDeleteHandler 

func WithEndpointDeleteHandler(h EndpointDeleteHandler) func(*GrpcServer)

func WithEndpointGetHandler 

func WithEndpointGetHandler(h EndpointGetHandler) func(*GrpcServer)

func WithEndpointWatchHandler 

func WithEndpointWatchHandler(h EndpointWatchHandler) func(*GrpcServer)

func WithWatchHandler 

func WithWatchHandler(h WatchHandler) func(*GrpcServer)

func WithWireCreateHandler 

func WithWireCreateHandler(h WireCreateHandler) func(*GrpcServer)

func WithWireDeleteHandler 

func WithWireDeleteHandler(h WireDeleteHandler) func(*GrpcServer)

func WithWireGetHandler 

func WithWireGetHandler(h WireGetHandler) func(*GrpcServer)

func WithWireWatchHandler 

func WithWireWatchHandler(h WireWatchHandler) func(*GrpcServer)

Types

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 EndpointCreateHandler 

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

type EndpointDeleteHandler 

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

type EndpointGetHandler 

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

Endpoint Handlers

type EndpointWatchHandler 

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

type GrpcServer 

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

func New 

func New(ctx context.Context, c Config, opts ...Option) *GrpcServer

func (*GrpcServer) Check 

func (s *GrpcServer) Check(ctx context.Context, in *healthpb.HealthCheckRequest) (*healthpb.HealthCheckResponse, error)

Check implements `service Health`.

func (*GrpcServer) EndpointCreate 

func (s *GrpcServer) EndpointCreate(ctx context.Context, req *endpointpb.EndpointRequest) (*endpointpb.EmptyResponse, error)

func (*GrpcServer) EndpointDelete 

func (s *GrpcServer) EndpointDelete(ctx context.Context, req *endpointpb.EndpointRequest) (*endpointpb.EmptyResponse, error)

func (*GrpcServer) EndpointGet 

func (s *GrpcServer) EndpointGet(ctx context.Context, req *endpointpb.EndpointRequest) (*endpointpb.EndpointResponse, error)

func (*GrpcServer) EndpointWatch 

func (s *GrpcServer) EndpointWatch(req *endpointpb.WatchRequest, stream endpointpb.NodeEndpoint_EndpointWatchServer) error

func (*GrpcServer) Start 

func (s *GrpcServer) Start(ctx context.Context) error

func (*GrpcServer) Watch 

func (s *GrpcServer) Watch(in *healthpb.HealthCheckRequest, stream healthpb.Health_WatchServer) error

Watch implements `service Health`.

func (*GrpcServer) WireCreate 

func (s *GrpcServer) WireCreate(ctx context.Context, req *wirepb.WireRequest) (*wirepb.EmptyResponse, error)

func (*GrpcServer) WireDelete 

func (s *GrpcServer) WireDelete(ctx context.Context, req *wirepb.WireRequest) (*wirepb.EmptyResponse, error)

func (*GrpcServer) WireGet 

func (s *GrpcServer) WireGet(ctx context.Context, req *wirepb.WireRequest) (*wirepb.WireResponse, error)

func (*GrpcServer) WireWatch 

func (s *GrpcServer) WireWatch(req *wirepb.WatchRequest, stream wirepb.Wire_WireWatchServer) error

type Option 

type Option func(*GrpcServer)

type WatchHandler 

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

type WireCreateHandler 

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

type WireDeleteHandler 

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

type WireGetHandler 

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

Wire Handlers

type WireWatchHandler 

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

Source Files

View all Source files

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.