endpointv3

package
v0.0.2 Latest Latest
Warning

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

 Go to latest Published: Aug 8, 2024 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	EndpointDiscoveryService_StreamEndpoints_FullMethodName = "/envoy.service.endpoint.v3.EndpointDiscoveryService/StreamEndpoints"
	EndpointDiscoveryService_DeltaEndpoints_FullMethodName  = "/envoy.service.endpoint.v3.EndpointDiscoveryService/DeltaEndpoints"
	EndpointDiscoveryService_FetchEndpoints_FullMethodName  = "/envoy.service.endpoint.v3.EndpointDiscoveryService/FetchEndpoints"
)
View Source 
const (
	LocalityEndpointDiscoveryService_DeltaLocalityEndpoints_FullMethodName = "/envoy.service.endpoint.v3.LocalityEndpointDiscoveryService/DeltaLocalityEndpoints"
)

Variables

View Source 
var EndpointDiscoveryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "envoy.service.endpoint.v3.EndpointDiscoveryService",
	HandlerType: (*EndpointDiscoveryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "FetchEndpoints",
			Handler:    _EndpointDiscoveryService_FetchEndpoints_Handler,
		},
	},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "StreamEndpoints",
			Handler:       _EndpointDiscoveryService_StreamEndpoints_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "DeltaEndpoints",
			Handler:       _EndpointDiscoveryService_DeltaEndpoints_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "envoy/service/endpoint/v3/eds.proto",
}

EndpointDiscoveryService_ServiceDesc is the grpc.ServiceDesc for EndpointDiscoveryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_envoy_service_endpoint_v3_eds_proto protoreflect.FileDescriptor
View Source 
var File_envoy_service_endpoint_v3_leds_proto protoreflect.FileDescriptor
View Source 
var LocalityEndpointDiscoveryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "envoy.service.endpoint.v3.LocalityEndpointDiscoveryService",
	HandlerType: (*LocalityEndpointDiscoveryServiceServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "DeltaLocalityEndpoints",
			Handler:       _LocalityEndpointDiscoveryService_DeltaLocalityEndpoints_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "envoy/service/endpoint/v3/leds.proto",
}

LocalityEndpointDiscoveryService_ServiceDesc is the grpc.ServiceDesc for LocalityEndpointDiscoveryService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterEndpointDiscoveryServiceServer 

func RegisterEndpointDiscoveryServiceServer(s grpc.ServiceRegistrar, srv EndpointDiscoveryServiceServer)

func RegisterLocalityEndpointDiscoveryServiceServer 

func RegisterLocalityEndpointDiscoveryServiceServer(s grpc.ServiceRegistrar, srv LocalityEndpointDiscoveryServiceServer)

Types

type EdsDummy 

type EdsDummy struct {
	// contains filtered or unexported fields
}

[#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing services: https://github.com/google/protobuf/issues/4221 and protoxform to upgrade the file.

func (*EdsDummy) Descriptor deprecated 

func (*EdsDummy) Descriptor() ([]byte, []int)

Deprecated: Use EdsDummy.ProtoReflect.Descriptor instead.

func (*EdsDummy) ProtoMessage 

func (*EdsDummy) ProtoMessage()

func (*EdsDummy) ProtoReflect 

func (x *EdsDummy) ProtoReflect() protoreflect.Message

func (*EdsDummy) Reset 

func (x *EdsDummy) Reset()

func (*EdsDummy) String 

func (x *EdsDummy) String() string

type EndpointDiscoveryServiceClient 

type EndpointDiscoveryServiceClient interface {
	// The resource_names field in DiscoveryRequest specifies a list of clusters
	// to subscribe to updates for.
	StreamEndpoints(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[v3.DiscoveryRequest, v3.DiscoveryResponse], error)
	DeltaEndpoints(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse], error)
	FetchEndpoints(ctx context.Context, in *v3.DiscoveryRequest, opts ...grpc.CallOption) (*v3.DiscoveryResponse, error)
}

EndpointDiscoveryServiceClient is the client API for EndpointDiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewEndpointDiscoveryServiceClient 

func NewEndpointDiscoveryServiceClient(cc grpc.ClientConnInterface) EndpointDiscoveryServiceClient

type EndpointDiscoveryServiceServer 

type EndpointDiscoveryServiceServer interface {
	// The resource_names field in DiscoveryRequest specifies a list of clusters
	// to subscribe to updates for.
	StreamEndpoints(grpc.BidiStreamingServer[v3.DiscoveryRequest, v3.DiscoveryResponse]) error
	DeltaEndpoints(grpc.BidiStreamingServer[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse]) error
	FetchEndpoints(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)
	// contains filtered or unexported methods
}

EndpointDiscoveryServiceServer is the server API for EndpointDiscoveryService service. All implementations must embed UnimplementedEndpointDiscoveryServiceServer for forward compatibility.

type EndpointDiscoveryService_DeltaEndpointsClient 

type EndpointDiscoveryService_DeltaEndpointsClient = grpc.BidiStreamingClient[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EndpointDiscoveryService_DeltaEndpointsServer 

type EndpointDiscoveryService_DeltaEndpointsServer = grpc.BidiStreamingServer[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EndpointDiscoveryService_StreamEndpointsClient 

type EndpointDiscoveryService_StreamEndpointsClient = grpc.BidiStreamingClient[v3.DiscoveryRequest, v3.DiscoveryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type EndpointDiscoveryService_StreamEndpointsServer 

type EndpointDiscoveryService_StreamEndpointsServer = grpc.BidiStreamingServer[v3.DiscoveryRequest, v3.DiscoveryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type LedsDummy 

type LedsDummy struct {
	// contains filtered or unexported fields
}

[#not-implemented-hide:] Not configuration. Workaround c++ protobuf issue with importing services: https://github.com/google/protobuf/issues/4221 and protoxform to upgrade the file.

func (*LedsDummy) Descriptor deprecated 

func (*LedsDummy) Descriptor() ([]byte, []int)

Deprecated: Use LedsDummy.ProtoReflect.Descriptor instead.

func (*LedsDummy) ProtoMessage 

func (*LedsDummy) ProtoMessage()

func (*LedsDummy) ProtoReflect 

func (x *LedsDummy) ProtoReflect() protoreflect.Message

func (*LedsDummy) Reset 

func (x *LedsDummy) Reset()

func (*LedsDummy) String 

func (x *LedsDummy) String() string

type LocalityEndpointDiscoveryServiceClient 

type LocalityEndpointDiscoveryServiceClient interface {
	// The resource_names_subscribe resource_names_unsubscribe fields in DeltaDiscoveryRequest
	// specify a list of glob collections to subscribe to updates for.
	DeltaLocalityEndpoints(ctx context.Context, opts ...grpc.CallOption) (grpc.BidiStreamingClient[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse], error)
}

LocalityEndpointDiscoveryServiceClient is the client API for LocalityEndpointDiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewLocalityEndpointDiscoveryServiceClient 

func NewLocalityEndpointDiscoveryServiceClient(cc grpc.ClientConnInterface) LocalityEndpointDiscoveryServiceClient

type LocalityEndpointDiscoveryServiceServer 

type LocalityEndpointDiscoveryServiceServer interface {
	// The resource_names_subscribe resource_names_unsubscribe fields in DeltaDiscoveryRequest
	// specify a list of glob collections to subscribe to updates for.
	DeltaLocalityEndpoints(grpc.BidiStreamingServer[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse]) error
	// contains filtered or unexported methods
}

LocalityEndpointDiscoveryServiceServer is the server API for LocalityEndpointDiscoveryService service. All implementations must embed UnimplementedLocalityEndpointDiscoveryServiceServer for forward compatibility.

type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsClient 

type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsClient = grpc.BidiStreamingClient[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsServer 

type LocalityEndpointDiscoveryService_DeltaLocalityEndpointsServer = grpc.BidiStreamingServer[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse]

This type alias is provided for backwards compatibility with existing code that references the prior non-generic stream type by name.

type UnimplementedEndpointDiscoveryServiceServer 

type UnimplementedEndpointDiscoveryServiceServer struct{}

UnimplementedEndpointDiscoveryServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedEndpointDiscoveryServiceServer) DeltaEndpoints 

func (UnimplementedEndpointDiscoveryServiceServer) DeltaEndpoints(grpc.BidiStreamingServer[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse]) error

func (UnimplementedEndpointDiscoveryServiceServer) FetchEndpoints 

func (UnimplementedEndpointDiscoveryServiceServer) FetchEndpoints(context.Context, *v3.DiscoveryRequest) (*v3.DiscoveryResponse, error)

func (UnimplementedEndpointDiscoveryServiceServer) StreamEndpoints 

func (UnimplementedEndpointDiscoveryServiceServer) StreamEndpoints(grpc.BidiStreamingServer[v3.DiscoveryRequest, v3.DiscoveryResponse]) error

type UnimplementedLocalityEndpointDiscoveryServiceServer 

type UnimplementedLocalityEndpointDiscoveryServiceServer struct{}

UnimplementedLocalityEndpointDiscoveryServiceServer must be embedded to have forward compatible implementations.

NOTE: this should be embedded by value instead of pointer to avoid a nil pointer dereference when methods are called.

func (UnimplementedLocalityEndpointDiscoveryServiceServer) DeltaLocalityEndpoints 

func (UnimplementedLocalityEndpointDiscoveryServiceServer) DeltaLocalityEndpoints(grpc.BidiStreamingServer[v3.DeltaDiscoveryRequest, v3.DeltaDiscoveryResponse]) error

type UnsafeEndpointDiscoveryServiceServer 

type UnsafeEndpointDiscoveryServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeEndpointDiscoveryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to EndpointDiscoveryServiceServer will result in compilation errors.

type UnsafeLocalityEndpointDiscoveryServiceServer 

type UnsafeLocalityEndpointDiscoveryServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeLocalityEndpointDiscoveryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to LocalityEndpointDiscoveryServiceServer will result in compilation errors.

Source Files

View all Source files

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.