xds

Documentation

Index

• Variables
• func RegisterSoloDiscoveryServiceServer(s *grpc.Server, srv SoloDiscoveryServiceServer)
• type SoloDiscoveryServiceClient
  • func NewSoloDiscoveryServiceClient(cc grpc.ClientConnInterface) SoloDiscoveryServiceClient
• type SoloDiscoveryServiceServer
• type SoloDiscoveryService_DeltaAggregatedResourcesClient
• type SoloDiscoveryService_DeltaAggregatedResourcesServer
• type SoloDiscoveryService_StreamAggregatedResourcesClient
• type SoloDiscoveryService_StreamAggregatedResourcesServer
• type UnimplementedSoloDiscoveryServiceServer
  • func (*UnimplementedSoloDiscoveryServiceServer) DeltaAggregatedResources(SoloDiscoveryService_DeltaAggregatedResourcesServer) error
  • func (*UnimplementedSoloDiscoveryServiceServer) StreamAggregatedResources(SoloDiscoveryService_StreamAggregatedResourcesServer) error

Variables

var File_github_com_solo_io_solo_kit_api_xds_solo_discovery_service_proto protoreflect.FileDescriptor

Functions

func RegisterSoloDiscoveryServiceServer

func RegisterSoloDiscoveryServiceServer(s *grpc.Server, srv SoloDiscoveryServiceServer)

Types

type SoloDiscoveryServiceClient

type SoloDiscoveryServiceClient interface {
	// This is a gRPC-only API.
	StreamAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (SoloDiscoveryService_StreamAggregatedResourcesClient, error)
	DeltaAggregatedResources(ctx context.Context, opts ...grpc.CallOption) (SoloDiscoveryService_DeltaAggregatedResourcesClient, error)
}

SoloDiscoveryServiceClient is the client API for SoloDiscoveryService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewSoloDiscoveryServiceClient

func NewSoloDiscoveryServiceClient(cc grpc.ClientConnInterface) SoloDiscoveryServiceClient

type SoloDiscoveryServiceServer

type SoloDiscoveryServiceServer interface {
	// This is a gRPC-only API.
	StreamAggregatedResources(SoloDiscoveryService_StreamAggregatedResourcesServer) error
	DeltaAggregatedResources(SoloDiscoveryService_DeltaAggregatedResourcesServer) error
}

SoloDiscoveryServiceServer is the server API for SoloDiscoveryService service.

type SoloDiscoveryService_DeltaAggregatedResourcesClient

type SoloDiscoveryService_DeltaAggregatedResourcesClient interface {
	Send(*v2.DeltaDiscoveryRequest) error
	Recv() (*v2.DeltaDiscoveryResponse, error)
	grpc.ClientStream
}

type SoloDiscoveryService_DeltaAggregatedResourcesServer

type SoloDiscoveryService_DeltaAggregatedResourcesServer interface {
	Send(*v2.DeltaDiscoveryResponse) error
	Recv() (*v2.DeltaDiscoveryRequest, error)
	grpc.ServerStream
}

type SoloDiscoveryService_StreamAggregatedResourcesClient

type SoloDiscoveryService_StreamAggregatedResourcesClient interface {
	Send(*v2.DiscoveryRequest) error
	Recv() (*v2.DiscoveryResponse, error)
	grpc.ClientStream
}

type SoloDiscoveryService_StreamAggregatedResourcesServer

type SoloDiscoveryService_StreamAggregatedResourcesServer interface {
	Send(*v2.DiscoveryResponse) error
	Recv() (*v2.DiscoveryRequest, error)
	grpc.ServerStream
}

type UnimplementedSoloDiscoveryServiceServer

type UnimplementedSoloDiscoveryServiceServer struct {
}

UnimplementedSoloDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSoloDiscoveryServiceServer) DeltaAggregatedResources

func (*UnimplementedSoloDiscoveryServiceServer) DeltaAggregatedResources(SoloDiscoveryService_DeltaAggregatedResourcesServer) error

func (*UnimplementedSoloDiscoveryServiceServer) StreamAggregatedResources

func (*UnimplementedSoloDiscoveryServiceServer) StreamAggregatedResources(SoloDiscoveryService_StreamAggregatedResourcesServer) error