subscription

type ApiListDiscoveryServiceClient ¶

type ApiListDiscoveryServiceClient interface {
	StreamApiList(ctx context.Context, opts ...grpc.CallOption) (ApiListDiscoveryService_StreamApiListClient, error)
}

ApiListDiscoveryServiceClient is the client API for ApiListDiscoveryService service.

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

func NewApiListDiscoveryServiceClient(cc grpc.ClientConnInterface) ApiListDiscoveryServiceClient

type ApiListDiscoveryServiceServer ¶

type ApiListDiscoveryServiceServer interface {
	StreamApiList(ApiListDiscoveryService_StreamApiListServer) error
}

ApiListDiscoveryServiceServer is the server API for ApiListDiscoveryService service.

type ApiListDiscoveryService_StreamApiListClient ¶

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

type ApiListDiscoveryService_StreamApiListServer ¶

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

type ApplicationDiscoveryServiceClient ¶

type ApplicationDiscoveryServiceClient interface {
	StreamApplications(ctx context.Context, opts ...grpc.CallOption) (ApplicationDiscoveryService_StreamApplicationsClient, error)
}

ApplicationDiscoveryServiceClient is the client API for ApplicationDiscoveryService service.

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

func NewApplicationDiscoveryServiceClient(cc grpc.ClientConnInterface) ApplicationDiscoveryServiceClient

type ApplicationDiscoveryServiceServer ¶

type ApplicationDiscoveryServiceServer interface {
	StreamApplications(ApplicationDiscoveryService_StreamApplicationsServer) error
}

ApplicationDiscoveryServiceServer is the server API for ApplicationDiscoveryService service.

type ApplicationDiscoveryService_StreamApplicationsClient ¶

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

type ApplicationDiscoveryService_StreamApplicationsServer ¶

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

type ApplicationKeyMappingDiscoveryServiceClient ¶

type ApplicationKeyMappingDiscoveryServiceClient interface {
	StreamApplicationKeyMappings(ctx context.Context, opts ...grpc.CallOption) (ApplicationKeyMappingDiscoveryService_StreamApplicationKeyMappingsClient, error)
}

ApplicationKeyMappingDiscoveryServiceClient is the client API for ApplicationKeyMappingDiscoveryService service.

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

func NewApplicationKeyMappingDiscoveryServiceClient(cc grpc.ClientConnInterface) ApplicationKeyMappingDiscoveryServiceClient

type ApplicationKeyMappingDiscoveryServiceServer ¶

type ApplicationKeyMappingDiscoveryServiceServer interface {
	StreamApplicationKeyMappings(ApplicationKeyMappingDiscoveryService_StreamApplicationKeyMappingsServer) error
}

ApplicationKeyMappingDiscoveryServiceServer is the server API for ApplicationKeyMappingDiscoveryService service.

type ApplicationKeyMappingDiscoveryService_StreamApplicationKeyMappingsClient ¶

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

type ApplicationKeyMappingDiscoveryService_StreamApplicationKeyMappingsServer ¶

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

type ApplicationPolicyDiscoveryServiceClient ¶

type ApplicationPolicyDiscoveryServiceClient interface {
	StreamApplicationPolicies(ctx context.Context, opts ...grpc.CallOption) (ApplicationPolicyDiscoveryService_StreamApplicationPoliciesClient, error)
}

ApplicationPolicyDiscoveryServiceClient is the client API for ApplicationPolicyDiscoveryService service.

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

func NewApplicationPolicyDiscoveryServiceClient(cc grpc.ClientConnInterface) ApplicationPolicyDiscoveryServiceClient

type ApplicationPolicyDiscoveryServiceServer ¶

type ApplicationPolicyDiscoveryServiceServer interface {
	StreamApplicationPolicies(ApplicationPolicyDiscoveryService_StreamApplicationPoliciesServer) error
}

ApplicationPolicyDiscoveryServiceServer is the server API for ApplicationPolicyDiscoveryService service.

type ApplicationPolicyDiscoveryService_StreamApplicationPoliciesClient ¶

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

type ApplicationPolicyDiscoveryService_StreamApplicationPoliciesServer ¶

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

type SubscriptionDiscoveryServiceClient ¶

type SubscriptionDiscoveryServiceClient interface {
	StreamSubscriptions(ctx context.Context, opts ...grpc.CallOption) (SubscriptionDiscoveryService_StreamSubscriptionsClient, error)
}

SubscriptionDiscoveryServiceClient is the client API for SubscriptionDiscoveryService service.

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

func NewSubscriptionDiscoveryServiceClient(cc grpc.ClientConnInterface) SubscriptionDiscoveryServiceClient

type SubscriptionDiscoveryServiceServer ¶

type SubscriptionDiscoveryServiceServer interface {
	StreamSubscriptions(SubscriptionDiscoveryService_StreamSubscriptionsServer) error
}

SubscriptionDiscoveryServiceServer is the server API for SubscriptionDiscoveryService service.

type SubscriptionDiscoveryService_StreamSubscriptionsClient ¶

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

type SubscriptionDiscoveryService_StreamSubscriptionsServer ¶

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

type SubscriptionPolicyDiscoveryServiceClient ¶

type SubscriptionPolicyDiscoveryServiceClient interface {
	StreamSubscriptionPolicies(ctx context.Context, opts ...grpc.CallOption) (SubscriptionPolicyDiscoveryService_StreamSubscriptionPoliciesClient, error)
}

SubscriptionPolicyDiscoveryServiceClient is the client API for SubscriptionPolicyDiscoveryService service.

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

func NewSubscriptionPolicyDiscoveryServiceClient(cc grpc.ClientConnInterface) SubscriptionPolicyDiscoveryServiceClient

type SubscriptionPolicyDiscoveryServiceServer ¶

type SubscriptionPolicyDiscoveryServiceServer interface {
	StreamSubscriptionPolicies(SubscriptionPolicyDiscoveryService_StreamSubscriptionPoliciesServer) error
}

SubscriptionPolicyDiscoveryServiceServer is the server API for SubscriptionPolicyDiscoveryService service.

type SubscriptionPolicyDiscoveryService_StreamSubscriptionPoliciesClient ¶

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

type SubscriptionPolicyDiscoveryService_StreamSubscriptionPoliciesServer ¶

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

type UnimplementedApiListDiscoveryServiceServer ¶

type UnimplementedApiListDiscoveryServiceServer struct {
}

UnimplementedApiListDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedApiListDiscoveryServiceServer) StreamApiList(ApiListDiscoveryService_StreamApiListServer) error

type UnimplementedApplicationDiscoveryServiceServer ¶

type UnimplementedApplicationDiscoveryServiceServer struct {
}

UnimplementedApplicationDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedApplicationDiscoveryServiceServer) StreamApplications(ApplicationDiscoveryService_StreamApplicationsServer) error

type UnimplementedApplicationKeyMappingDiscoveryServiceServer ¶

type UnimplementedApplicationKeyMappingDiscoveryServiceServer struct {
}

UnimplementedApplicationKeyMappingDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedApplicationKeyMappingDiscoveryServiceServer) StreamApplicationKeyMappings(ApplicationKeyMappingDiscoveryService_StreamApplicationKeyMappingsServer) error

type UnimplementedApplicationPolicyDiscoveryServiceServer ¶

type UnimplementedApplicationPolicyDiscoveryServiceServer struct {
}

UnimplementedApplicationPolicyDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedApplicationPolicyDiscoveryServiceServer) StreamApplicationPolicies(ApplicationPolicyDiscoveryService_StreamApplicationPoliciesServer) error

type UnimplementedSubscriptionDiscoveryServiceServer ¶

type UnimplementedSubscriptionDiscoveryServiceServer struct {
}

UnimplementedSubscriptionDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscriptionDiscoveryServiceServer) StreamSubscriptions(SubscriptionDiscoveryService_StreamSubscriptionsServer) error

type UnimplementedSubscriptionPolicyDiscoveryServiceServer ¶

type UnimplementedSubscriptionPolicyDiscoveryServiceServer struct {
}

UnimplementedSubscriptionPolicyDiscoveryServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSubscriptionPolicyDiscoveryServiceServer) StreamSubscriptionPolicies(SubscriptionPolicyDiscoveryService_StreamSubscriptionPoliciesServer) error