registry

package
v1.13.0 Latest Latest
Warning

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

 Go to latest Published: Mar 25, 2024 License: Apache-2.0 Imports: 11 Imported by: 92

Documentation

Overview

Package registry provides the

Index

Constants

This section is empty.

Variables

View Source 
var File_registry_proto protoreflect.FileDescriptor

Functions

func ReadNetworkServiceChannel 

func ReadNetworkServiceChannel(stream NetworkServiceRegistry_FindClient) <-chan *NetworkServiceResponse

ReadNetworkServiceChannel reads NetworkServices from the stream and puts it into result channel

func ReadNetworkServiceEndpointChannel 

func ReadNetworkServiceEndpointChannel(stream NetworkServiceEndpointRegistry_FindClient) <-chan *NetworkServiceEndpointResponse

ReadNetworkServiceEndpointChannel reads NetworkServiceEndpoint from the stream and puts it into result channel

func RegisterNetworkServiceEndpointRegistryServer 

func RegisterNetworkServiceEndpointRegistryServer(s *grpc.Server, srv NetworkServiceEndpointRegistryServer)

func RegisterNetworkServiceRegistryServer 

func RegisterNetworkServiceRegistryServer(s *grpc.Server, srv NetworkServiceRegistryServer)

func ServiceNames 

func ServiceNames(impl interface{}, existingServiceNames ...string) []string

ServiceNames - returns grpc ServiceNames implemented by impl

Types

type Destination 

type Destination struct {
	DestinationSelector map[string]string `` /* 206-byte string literal not displayed */
	Weight              uint32            `protobuf:"varint,2,opt,name=weight,proto3" json:"weight,omitempty"`
	// contains filtered or unexported fields
}

func (*Destination) Descriptor deprecated 

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

Deprecated: Use Destination.ProtoReflect.Descriptor instead.

func (*Destination) GetDestinationSelector 

func (x *Destination) GetDestinationSelector() map[string]string

func (*Destination) GetWeight 

func (x *Destination) GetWeight() uint32

func (*Destination) ProtoMessage 

func (*Destination) ProtoMessage()

func (*Destination) ProtoReflect 

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

func (*Destination) Reset 

func (x *Destination) Reset()

func (*Destination) String 

func (x *Destination) String() string

type Match 

type Match struct {
	SourceSelector map[string]string `` /* 191-byte string literal not displayed */
	Routes         []*Destination    `protobuf:"bytes,2,rep,name=routes,proto3" json:"routes,omitempty"`
	Fallthrough    bool              `protobuf:"varint,3,opt,name=fallthrough,proto3" json:"fallthrough,omitempty"`
	Metadata       *Metadata         `protobuf:"bytes,4,opt,name=metadata,proto3" json:"metadata,omitempty"`
	// contains filtered or unexported fields
}

func (*Match) Descriptor deprecated 

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

Deprecated: Use Match.ProtoReflect.Descriptor instead.

func (*Match) GetFallthrough added in v1.1.0 

func (x *Match) GetFallthrough() bool

func (*Match) GetMetadata added in v1.1.0 

func (x *Match) GetMetadata() *Metadata

func (*Match) GetRoutes 

func (x *Match) GetRoutes() []*Destination

func (*Match) GetSourceSelector 

func (x *Match) GetSourceSelector() map[string]string

func (*Match) ProtoMessage 

func (*Match) ProtoMessage()

func (*Match) ProtoReflect 

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

func (*Match) Reset 

func (x *Match) Reset()

func (*Match) String 

func (x *Match) String() string

type Metadata added in v1.1.0 

type Metadata struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Metadata) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use Metadata.ProtoReflect.Descriptor instead.

func (*Metadata) GetLabels added in v1.1.0 

func (x *Metadata) GetLabels() map[string]string

func (*Metadata) ProtoMessage added in v1.1.0 

func (*Metadata) ProtoMessage()

func (*Metadata) ProtoReflect added in v1.1.0 

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

func (*Metadata) Reset added in v1.1.0 

func (x *Metadata) Reset()

func (*Metadata) String added in v1.1.0 

func (x *Metadata) String() string

type NetworkService 

type NetworkService struct {
	Name    string   `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Payload string   `protobuf:"bytes,2,opt,name=payload,proto3" json:"payload,omitempty"`
	Matches []*Match `protobuf:"bytes,3,rep,name=matches,proto3" json:"matches,omitempty"`
	PathIds []string `protobuf:"bytes,4,rep,name=path_ids,json=pathIds,proto3" json:"path_ids,omitempty"`
	// contains filtered or unexported fields
}

func ReadNetworkServiceList 

func ReadNetworkServiceList(stream NetworkServiceRegistry_FindClient) []*NetworkService

ReadNetworkServiceList read list of NetworkServices from passed stream

func (*NetworkService) Clone 

func (x *NetworkService) Clone() *NetworkService

Clone clones request

func (*NetworkService) Descriptor deprecated 

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

Deprecated: Use NetworkService.ProtoReflect.Descriptor instead.

func (*NetworkService) GetMatches 

func (x *NetworkService) GetMatches() []*Match

func (*NetworkService) GetName 

func (x *NetworkService) GetName() string

func (*NetworkService) GetPathIds added in v1.7.0 

func (x *NetworkService) GetPathIds() []string

func (*NetworkService) GetPayload 

func (x *NetworkService) GetPayload() string

func (*NetworkService) ProtoMessage 

func (*NetworkService) ProtoMessage()

func (*NetworkService) ProtoReflect 

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

func (*NetworkService) Reset 

func (x *NetworkService) Reset()

func (*NetworkService) String 

func (x *NetworkService) String() string

type NetworkServiceEndpoint 

type NetworkServiceEndpoint struct {
	Name                    string                           `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	NetworkServiceNames     []string                         `protobuf:"bytes,2,rep,name=network_service_names,json=networkServiceNames,proto3" json:"network_service_names,omitempty"`
	NetworkServiceLabels    map[string]*NetworkServiceLabels `` /* 211-byte string literal not displayed */
	Url                     string                           `protobuf:"bytes,4,opt,name=url,proto3" json:"url,omitempty"`
	ExpirationTime          *timestamppb.Timestamp           `protobuf:"bytes,5,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
	InitialRegistrationTime *timestamppb.Timestamp           `` /* 132-byte string literal not displayed */
	PathIds                 []string                         `protobuf:"bytes,7,rep,name=path_ids,json=pathIds,proto3" json:"path_ids,omitempty"`
	// contains filtered or unexported fields
}

func ReadNetworkServiceEndpointList 

func ReadNetworkServiceEndpointList(stream NetworkServiceEndpointRegistry_FindClient) []*NetworkServiceEndpoint

ReadNetworkServiceEndpointList read list of NetworkServiceEndpoints from passed stream

func (*NetworkServiceEndpoint) Clone 

func (x *NetworkServiceEndpoint) Clone() *NetworkServiceEndpoint

Clone clones request

func (*NetworkServiceEndpoint) Descriptor deprecated 

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

Deprecated: Use NetworkServiceEndpoint.ProtoReflect.Descriptor instead.

func (*NetworkServiceEndpoint) GetExpirationTime 

func (x *NetworkServiceEndpoint) GetExpirationTime() *timestamppb.Timestamp

func (*NetworkServiceEndpoint) GetInitialRegistrationTime added in v1.1.0 

func (x *NetworkServiceEndpoint) GetInitialRegistrationTime() *timestamppb.Timestamp

func (*NetworkServiceEndpoint) GetName 

func (x *NetworkServiceEndpoint) GetName() string

func (*NetworkServiceEndpoint) GetNetworkServiceLabels 

func (x *NetworkServiceEndpoint) GetNetworkServiceLabels() map[string]*NetworkServiceLabels

func (*NetworkServiceEndpoint) GetNetworkServiceNames 

func (x *NetworkServiceEndpoint) GetNetworkServiceNames() []string

func (*NetworkServiceEndpoint) GetPathIds added in v1.7.0 

func (x *NetworkServiceEndpoint) GetPathIds() []string

func (*NetworkServiceEndpoint) GetUrl 

func (x *NetworkServiceEndpoint) GetUrl() string

func (*NetworkServiceEndpoint) ProtoMessage 

func (*NetworkServiceEndpoint) ProtoMessage()

func (*NetworkServiceEndpoint) ProtoReflect 

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

func (*NetworkServiceEndpoint) Reset 

func (x *NetworkServiceEndpoint) Reset()

func (*NetworkServiceEndpoint) String 

func (x *NetworkServiceEndpoint) String() string

type NetworkServiceEndpointQuery 

type NetworkServiceEndpointQuery struct {
	NetworkServiceEndpoint *NetworkServiceEndpoint `` /* 129-byte string literal not displayed */
	Watch                  bool                    `protobuf:"varint,2,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkServiceEndpointQuery) Descriptor deprecated 

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

Deprecated: Use NetworkServiceEndpointQuery.ProtoReflect.Descriptor instead.

func (*NetworkServiceEndpointQuery) GetNetworkServiceEndpoint 

func (x *NetworkServiceEndpointQuery) GetNetworkServiceEndpoint() *NetworkServiceEndpoint

func (*NetworkServiceEndpointQuery) GetWatch 

func (x *NetworkServiceEndpointQuery) GetWatch() bool

func (*NetworkServiceEndpointQuery) ProtoMessage 

func (*NetworkServiceEndpointQuery) ProtoMessage()

func (*NetworkServiceEndpointQuery) ProtoReflect 

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

func (*NetworkServiceEndpointQuery) Reset 

func (x *NetworkServiceEndpointQuery) Reset()

func (*NetworkServiceEndpointQuery) String 

func (x *NetworkServiceEndpointQuery) String() string

type NetworkServiceEndpointRegistryClient 

type NetworkServiceEndpointRegistryClient interface {
	Register(ctx context.Context, in *NetworkServiceEndpoint, opts ...grpc.CallOption) (*NetworkServiceEndpoint, error)
	Find(ctx context.Context, in *NetworkServiceEndpointQuery, opts ...grpc.CallOption) (NetworkServiceEndpointRegistry_FindClient, error)
	Unregister(ctx context.Context, in *NetworkServiceEndpoint, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

NetworkServiceEndpointRegistryClient is the client API for NetworkServiceEndpointRegistry service.

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

func NewNetworkServiceEndpointRegistryClient 

func NewNetworkServiceEndpointRegistryClient(cc grpc.ClientConnInterface) NetworkServiceEndpointRegistryClient

type NetworkServiceEndpointRegistryServer 

type NetworkServiceEndpointRegistryServer interface {
	Register(context.Context, *NetworkServiceEndpoint) (*NetworkServiceEndpoint, error)
	Find(*NetworkServiceEndpointQuery, NetworkServiceEndpointRegistry_FindServer) error
	Unregister(context.Context, *NetworkServiceEndpoint) (*emptypb.Empty, error)
}

NetworkServiceEndpointRegistryServer is the server API for NetworkServiceEndpointRegistry service.

type NetworkServiceEndpointRegistry_FindClient 

type NetworkServiceEndpointRegistry_FindClient interface {
	Recv() (*NetworkServiceEndpointResponse, error)
	grpc.ClientStream
}

type NetworkServiceEndpointRegistry_FindServer 

type NetworkServiceEndpointRegistry_FindServer interface {
	Send(*NetworkServiceEndpointResponse) error
	grpc.ServerStream
}

type NetworkServiceEndpointResponse added in v1.1.0 

type NetworkServiceEndpointResponse struct {
	NetworkServiceEndpoint *NetworkServiceEndpoint `` /* 129-byte string literal not displayed */
	Deleted                bool                    `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkServiceEndpointResponse) Clone added in v1.1.0 

func (x *NetworkServiceEndpointResponse) Clone() *NetworkServiceEndpointResponse

Clone clones NetworkServiceEndpointResponse

func (*NetworkServiceEndpointResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use NetworkServiceEndpointResponse.ProtoReflect.Descriptor instead.

func (*NetworkServiceEndpointResponse) GetDeleted added in v1.1.0 

func (x *NetworkServiceEndpointResponse) GetDeleted() bool

func (*NetworkServiceEndpointResponse) GetNetworkServiceEndpoint added in v1.1.0 

func (x *NetworkServiceEndpointResponse) GetNetworkServiceEndpoint() *NetworkServiceEndpoint

func (*NetworkServiceEndpointResponse) ProtoMessage added in v1.1.0 

func (*NetworkServiceEndpointResponse) ProtoMessage()

func (*NetworkServiceEndpointResponse) ProtoReflect added in v1.1.0 

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

func (*NetworkServiceEndpointResponse) Reset added in v1.1.0 

func (x *NetworkServiceEndpointResponse) Reset()

func (*NetworkServiceEndpointResponse) String added in v1.1.0 

func (x *NetworkServiceEndpointResponse) String() string

type NetworkServiceLabels 

type NetworkServiceLabels struct {
	Labels map[string]string `` /* 153-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*NetworkServiceLabels) Descriptor deprecated 

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

Deprecated: Use NetworkServiceLabels.ProtoReflect.Descriptor instead.

func (*NetworkServiceLabels) GetLabels 

func (x *NetworkServiceLabels) GetLabels() map[string]string

func (*NetworkServiceLabels) ProtoMessage 

func (*NetworkServiceLabels) ProtoMessage()

func (*NetworkServiceLabels) ProtoReflect 

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

func (*NetworkServiceLabels) Reset 

func (x *NetworkServiceLabels) Reset()

func (*NetworkServiceLabels) String 

func (x *NetworkServiceLabels) String() string

type NetworkServiceQuery 

type NetworkServiceQuery struct {
	NetworkService *NetworkService `protobuf:"bytes,1,opt,name=network_service,json=networkService,proto3" json:"network_service,omitempty"`
	Watch          bool            `protobuf:"varint,2,opt,name=watch,proto3" json:"watch,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkServiceQuery) Descriptor deprecated 

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

Deprecated: Use NetworkServiceQuery.ProtoReflect.Descriptor instead.

func (*NetworkServiceQuery) GetNetworkService 

func (x *NetworkServiceQuery) GetNetworkService() *NetworkService

func (*NetworkServiceQuery) GetWatch 

func (x *NetworkServiceQuery) GetWatch() bool

func (*NetworkServiceQuery) ProtoMessage 

func (*NetworkServiceQuery) ProtoMessage()

func (*NetworkServiceQuery) ProtoReflect 

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

func (*NetworkServiceQuery) Reset 

func (x *NetworkServiceQuery) Reset()

func (*NetworkServiceQuery) String 

func (x *NetworkServiceQuery) String() string

type NetworkServiceRegistryClient 

type NetworkServiceRegistryClient interface {
	Register(ctx context.Context, in *NetworkService, opts ...grpc.CallOption) (*NetworkService, error)
	Find(ctx context.Context, in *NetworkServiceQuery, opts ...grpc.CallOption) (NetworkServiceRegistry_FindClient, error)
	Unregister(ctx context.Context, in *NetworkService, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

NetworkServiceRegistryClient is the client API for NetworkServiceRegistry service.

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

func NewNetworkServiceRegistryClient 

func NewNetworkServiceRegistryClient(cc grpc.ClientConnInterface) NetworkServiceRegistryClient

type NetworkServiceRegistryServer 

type NetworkServiceRegistryServer interface {
	Register(context.Context, *NetworkService) (*NetworkService, error)
	Find(*NetworkServiceQuery, NetworkServiceRegistry_FindServer) error
	Unregister(context.Context, *NetworkService) (*emptypb.Empty, error)
}

NetworkServiceRegistryServer is the server API for NetworkServiceRegistry service.

type NetworkServiceRegistry_FindClient 

type NetworkServiceRegistry_FindClient interface {
	Recv() (*NetworkServiceResponse, error)
	grpc.ClientStream
}

type NetworkServiceRegistry_FindServer 

type NetworkServiceRegistry_FindServer interface {
	Send(*NetworkServiceResponse) error
	grpc.ServerStream
}

type NetworkServiceResponse added in v1.1.0 

type NetworkServiceResponse struct {
	NetworkService *NetworkService `protobuf:"bytes,1,opt,name=network_service,json=networkService,proto3" json:"network_service,omitempty"`
	Deleted        bool            `protobuf:"varint,2,opt,name=deleted,proto3" json:"deleted,omitempty"`
	// contains filtered or unexported fields
}

func (*NetworkServiceResponse) Clone added in v1.1.0 

func (x *NetworkServiceResponse) Clone() *NetworkServiceResponse

Clone clones NetworkServiceResponse

func (*NetworkServiceResponse) Descriptor deprecated added in v1.1.0 

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

Deprecated: Use NetworkServiceResponse.ProtoReflect.Descriptor instead.

func (*NetworkServiceResponse) GetDeleted added in v1.1.0 

func (x *NetworkServiceResponse) GetDeleted() bool

func (*NetworkServiceResponse) GetNetworkService added in v1.1.0 

func (x *NetworkServiceResponse) GetNetworkService() *NetworkService

func (*NetworkServiceResponse) ProtoMessage added in v1.1.0 

func (*NetworkServiceResponse) ProtoMessage()

func (*NetworkServiceResponse) ProtoReflect added in v1.1.0 

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

func (*NetworkServiceResponse) Reset added in v1.1.0 

func (x *NetworkServiceResponse) Reset()

func (*NetworkServiceResponse) String added in v1.1.0 

func (x *NetworkServiceResponse) String() string

type UnimplementedNetworkServiceEndpointRegistryServer 

type UnimplementedNetworkServiceEndpointRegistryServer struct {
}

UnimplementedNetworkServiceEndpointRegistryServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkServiceEndpointRegistryServer) Find 

func (*UnimplementedNetworkServiceEndpointRegistryServer) Find(*NetworkServiceEndpointQuery, NetworkServiceEndpointRegistry_FindServer) error

func (*UnimplementedNetworkServiceEndpointRegistryServer) Register 

func (*UnimplementedNetworkServiceEndpointRegistryServer) Register(context.Context, *NetworkServiceEndpoint) (*NetworkServiceEndpoint, error)

func (*UnimplementedNetworkServiceEndpointRegistryServer) Unregister 

func (*UnimplementedNetworkServiceEndpointRegistryServer) Unregister(context.Context, *NetworkServiceEndpoint) (*emptypb.Empty, error)

type UnimplementedNetworkServiceRegistryServer 

type UnimplementedNetworkServiceRegistryServer struct {
}

UnimplementedNetworkServiceRegistryServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkServiceRegistryServer) Find 

func (*UnimplementedNetworkServiceRegistryServer) Find(*NetworkServiceQuery, NetworkServiceRegistry_FindServer) error

func (*UnimplementedNetworkServiceRegistryServer) Register 

func (*UnimplementedNetworkServiceRegistryServer) Register(context.Context, *NetworkService) (*NetworkService, error)

func (*UnimplementedNetworkServiceRegistryServer) Unregister 

func (*UnimplementedNetworkServiceRegistryServer) Unregister(context.Context, *NetworkService) (*emptypb.Empty, error)

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.