registry

package
v1.0.13 Latest Latest
Warning

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

Go to latest
Published: Dec 17, 2020 License: Apache-2.0 Imports: 9 Imported by: 5

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterNetworkServiceDiscoveryServer

func RegisterNetworkServiceDiscoveryServer(s *grpc.Server, srv NetworkServiceDiscoveryServer)

func RegisterNetworkServiceRegistryServer

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

func RegisterNsmRegistryServer

func RegisterNsmRegistryServer(s *grpc.Server, srv NsmRegistryServer)

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Destination) Descriptor

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

func (*Destination) GetDestinationSelector

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

func (*Destination) GetWeight

func (m *Destination) GetWeight() uint32

func (*Destination) ProtoMessage

func (*Destination) ProtoMessage()

func (*Destination) Reset

func (m *Destination) Reset()

func (*Destination) String

func (m *Destination) String() string

func (*Destination) XXX_DiscardUnknown

func (m *Destination) XXX_DiscardUnknown()

func (*Destination) XXX_Marshal

func (m *Destination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Destination) XXX_Merge

func (m *Destination) XXX_Merge(src proto.Message)

func (*Destination) XXX_Size

func (m *Destination) XXX_Size() int

func (*Destination) XXX_Unmarshal

func (m *Destination) XXX_Unmarshal(b []byte) error

type EndpointNSMName

type EndpointNSMName string

EndpointNSMName - - a type to hold endpoint and nsm url composite type.

func NewEndpointNSMName

func NewEndpointNSMName(endpoint *NetworkServiceEndpoint, manager *NetworkServiceManager) EndpointNSMName

NewEndpointNSMName - construct an NewEndpointNSMName from endpoint and manager

type FindNetworkServiceRequest

type FindNetworkServiceRequest struct {
	NetworkServiceName   string   `protobuf:"bytes,1,opt,name=network_service_name,json=networkServiceName,proto3" json:"network_service_name,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*FindNetworkServiceRequest) Descriptor

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

func (*FindNetworkServiceRequest) GetNetworkServiceName

func (m *FindNetworkServiceRequest) GetNetworkServiceName() string

func (*FindNetworkServiceRequest) ProtoMessage

func (*FindNetworkServiceRequest) ProtoMessage()

func (*FindNetworkServiceRequest) Reset

func (m *FindNetworkServiceRequest) Reset()

func (*FindNetworkServiceRequest) String

func (m *FindNetworkServiceRequest) String() string

func (*FindNetworkServiceRequest) XXX_DiscardUnknown

func (m *FindNetworkServiceRequest) XXX_DiscardUnknown()

func (*FindNetworkServiceRequest) XXX_Marshal

func (m *FindNetworkServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindNetworkServiceRequest) XXX_Merge

func (m *FindNetworkServiceRequest) XXX_Merge(src proto.Message)

func (*FindNetworkServiceRequest) XXX_Size

func (m *FindNetworkServiceRequest) XXX_Size() int

func (*FindNetworkServiceRequest) XXX_Unmarshal

func (m *FindNetworkServiceRequest) XXX_Unmarshal(b []byte) error

type FindNetworkServiceResponse

type FindNetworkServiceResponse struct {
	Payload                 string                            `protobuf:"bytes,1,opt,name=payload,proto3" json:"payload,omitempty"`
	NetworkService          *NetworkService                   `protobuf:"bytes,2,opt,name=network_service,json=networkService,proto3" json:"network_service,omitempty"`
	NetworkServiceManagers  map[string]*NetworkServiceManager `` /* 217-byte string literal not displayed */
	NetworkServiceEndpoints []*NetworkServiceEndpoint         `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}                          `json:"-"`
	XXX_unrecognized        []byte                            `json:"-"`
	XXX_sizecache           int32                             `json:"-"`
}

func (*FindNetworkServiceResponse) Descriptor

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

func (*FindNetworkServiceResponse) GetNetworkService

func (m *FindNetworkServiceResponse) GetNetworkService() *NetworkService

func (*FindNetworkServiceResponse) GetNetworkServiceEndpoints

func (m *FindNetworkServiceResponse) GetNetworkServiceEndpoints() []*NetworkServiceEndpoint

func (*FindNetworkServiceResponse) GetNetworkServiceManagers

func (m *FindNetworkServiceResponse) GetNetworkServiceManagers() map[string]*NetworkServiceManager

func (*FindNetworkServiceResponse) GetPayload

func (m *FindNetworkServiceResponse) GetPayload() string

func (*FindNetworkServiceResponse) ProtoMessage

func (*FindNetworkServiceResponse) ProtoMessage()

func (*FindNetworkServiceResponse) Reset

func (m *FindNetworkServiceResponse) Reset()

func (*FindNetworkServiceResponse) String

func (m *FindNetworkServiceResponse) String() string

func (*FindNetworkServiceResponse) XXX_DiscardUnknown

func (m *FindNetworkServiceResponse) XXX_DiscardUnknown()

func (*FindNetworkServiceResponse) XXX_Marshal

func (m *FindNetworkServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*FindNetworkServiceResponse) XXX_Merge

func (m *FindNetworkServiceResponse) XXX_Merge(src proto.Message)

func (*FindNetworkServiceResponse) XXX_Size

func (m *FindNetworkServiceResponse) XXX_Size() int

func (*FindNetworkServiceResponse) XXX_Unmarshal

func (m *FindNetworkServiceResponse) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{}          `json:"-"`
	XXX_unrecognized     []byte            `json:"-"`
	XXX_sizecache        int32             `json:"-"`
}

func (*Match) Descriptor

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

func (*Match) GetRoutes

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

func (*Match) GetSourceSelector

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

func (*Match) ProtoMessage

func (*Match) ProtoMessage()

func (*Match) Reset

func (m *Match) Reset()

func (*Match) String

func (m *Match) String() string

func (*Match) XXX_DiscardUnknown

func (m *Match) XXX_DiscardUnknown()

func (*Match) XXX_Marshal

func (m *Match) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Match) XXX_Merge

func (m *Match) XXX_Merge(src proto.Message)

func (*Match) XXX_Size

func (m *Match) XXX_Size() int

func (*Match) XXX_Unmarshal

func (m *Match) XXX_Unmarshal(b []byte) error

type NSERegistration

type NSERegistration struct {
	NetworkService         *NetworkService         `protobuf:"bytes,1,opt,name=network_service,json=networkService,proto3" json:"network_service,omitempty"`
	NetworkServiceManager  *NetworkServiceManager  `` /* 126-byte string literal not displayed */
	NetworkServiceEndpoint *NetworkServiceEndpoint `` /* 129-byte string literal not displayed */
	XXX_NoUnkeyedLiteral   struct{}                `json:"-"`
	XXX_unrecognized       []byte                  `json:"-"`
	XXX_sizecache          int32                   `json:"-"`
}

func (*NSERegistration) Descriptor

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

func (*NSERegistration) GetEndpointNSMName

func (nse *NSERegistration) GetEndpointNSMName() EndpointNSMName

GetEndpointNSMName - return a Endpoint.Name + ":" + NetworkServiceManager.Url

func (*NSERegistration) GetNetworkService

func (m *NSERegistration) GetNetworkService() *NetworkService

func (*NSERegistration) GetNetworkServiceEndpoint

func (m *NSERegistration) GetNetworkServiceEndpoint() *NetworkServiceEndpoint

func (*NSERegistration) GetNetworkServiceManager

func (m *NSERegistration) GetNetworkServiceManager() *NetworkServiceManager

func (*NSERegistration) ProtoMessage

func (*NSERegistration) ProtoMessage()

func (*NSERegistration) Reset

func (m *NSERegistration) Reset()

func (*NSERegistration) String

func (m *NSERegistration) String() string

func (*NSERegistration) XXX_DiscardUnknown

func (m *NSERegistration) XXX_DiscardUnknown()

func (*NSERegistration) XXX_Marshal

func (m *NSERegistration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NSERegistration) XXX_Merge

func (m *NSERegistration) XXX_Merge(src proto.Message)

func (*NSERegistration) XXX_Size

func (m *NSERegistration) XXX_Size() int

func (*NSERegistration) XXX_Unmarshal

func (m *NSERegistration) XXX_Unmarshal(b []byte) error

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"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*NetworkService) Descriptor

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

func (*NetworkService) GetMatches

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

func (*NetworkService) GetName

func (m *NetworkService) GetName() string

func (*NetworkService) GetPayload

func (m *NetworkService) GetPayload() string

func (*NetworkService) ProtoMessage

func (*NetworkService) ProtoMessage()

func (*NetworkService) Reset

func (m *NetworkService) Reset()

func (*NetworkService) String

func (m *NetworkService) String() string

func (*NetworkService) XXX_DiscardUnknown

func (m *NetworkService) XXX_DiscardUnknown()

func (*NetworkService) XXX_Marshal

func (m *NetworkService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetworkService) XXX_Merge

func (m *NetworkService) XXX_Merge(src proto.Message)

func (*NetworkService) XXX_Size

func (m *NetworkService) XXX_Size() int

func (*NetworkService) XXX_Unmarshal

func (m *NetworkService) XXX_Unmarshal(b []byte) error

type NetworkServiceDiscoveryClient

type NetworkServiceDiscoveryClient interface {
	FindNetworkService(ctx context.Context, in *FindNetworkServiceRequest, opts ...grpc.CallOption) (*FindNetworkServiceResponse, error)
}

NetworkServiceDiscoveryClient is the client API for NetworkServiceDiscovery service.

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

type NetworkServiceDiscoveryServer

type NetworkServiceDiscoveryServer interface {
	FindNetworkService(context.Context, *FindNetworkServiceRequest) (*FindNetworkServiceResponse, error)
}

NetworkServiceDiscoveryServer is the server API for NetworkServiceDiscovery service.

type NetworkServiceEndpoint

type NetworkServiceEndpoint 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"`
	NetworkServiceName        string            `protobuf:"bytes,3,opt,name=network_service_name,json=networkServiceName,proto3" json:"network_service_name,omitempty"`
	NetworkServiceManagerName string            `` /* 140-byte string literal not displayed */
	Labels                    map[string]string `` /* 153-byte string literal not displayed */
	State                     string            `protobuf:"bytes,6,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral      struct{}          `json:"-"`
	XXX_unrecognized          []byte            `json:"-"`
	XXX_sizecache             int32             `json:"-"`
}

func (*NetworkServiceEndpoint) Descriptor

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

func (*NetworkServiceEndpoint) GetLabels

func (m *NetworkServiceEndpoint) GetLabels() map[string]string

func (*NetworkServiceEndpoint) GetName

func (m *NetworkServiceEndpoint) GetName() string

func (*NetworkServiceEndpoint) GetNetworkServiceManagerName

func (m *NetworkServiceEndpoint) GetNetworkServiceManagerName() string

func (*NetworkServiceEndpoint) GetNetworkServiceName

func (m *NetworkServiceEndpoint) GetNetworkServiceName() string

func (*NetworkServiceEndpoint) GetPayload

func (m *NetworkServiceEndpoint) GetPayload() string

func (*NetworkServiceEndpoint) GetState

func (m *NetworkServiceEndpoint) GetState() string

func (*NetworkServiceEndpoint) ProtoMessage

func (*NetworkServiceEndpoint) ProtoMessage()

func (*NetworkServiceEndpoint) Reset

func (m *NetworkServiceEndpoint) Reset()

func (*NetworkServiceEndpoint) String

func (m *NetworkServiceEndpoint) String() string

func (*NetworkServiceEndpoint) XXX_DiscardUnknown

func (m *NetworkServiceEndpoint) XXX_DiscardUnknown()

func (*NetworkServiceEndpoint) XXX_Marshal

func (m *NetworkServiceEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetworkServiceEndpoint) XXX_Merge

func (m *NetworkServiceEndpoint) XXX_Merge(src proto.Message)

func (*NetworkServiceEndpoint) XXX_Size

func (m *NetworkServiceEndpoint) XXX_Size() int

func (*NetworkServiceEndpoint) XXX_Unmarshal

func (m *NetworkServiceEndpoint) XXX_Unmarshal(b []byte) error

type NetworkServiceEndpointList

type NetworkServiceEndpointList struct {
	NetworkServiceEndpoints []*NetworkServiceEndpoint `` /* 132-byte string literal not displayed */
	XXX_NoUnkeyedLiteral    struct{}                  `json:"-"`
	XXX_unrecognized        []byte                    `json:"-"`
	XXX_sizecache           int32                     `json:"-"`
}

func (*NetworkServiceEndpointList) Descriptor

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

func (*NetworkServiceEndpointList) GetNetworkServiceEndpoints

func (m *NetworkServiceEndpointList) GetNetworkServiceEndpoints() []*NetworkServiceEndpoint

func (*NetworkServiceEndpointList) ProtoMessage

func (*NetworkServiceEndpointList) ProtoMessage()

func (*NetworkServiceEndpointList) Reset

func (m *NetworkServiceEndpointList) Reset()

func (*NetworkServiceEndpointList) String

func (m *NetworkServiceEndpointList) String() string

func (*NetworkServiceEndpointList) XXX_DiscardUnknown

func (m *NetworkServiceEndpointList) XXX_DiscardUnknown()

func (*NetworkServiceEndpointList) XXX_Marshal

func (m *NetworkServiceEndpointList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetworkServiceEndpointList) XXX_Merge

func (m *NetworkServiceEndpointList) XXX_Merge(src proto.Message)

func (*NetworkServiceEndpointList) XXX_Size

func (m *NetworkServiceEndpointList) XXX_Size() int

func (*NetworkServiceEndpointList) XXX_Unmarshal

func (m *NetworkServiceEndpointList) XXX_Unmarshal(b []byte) error

type NetworkServiceManager

type NetworkServiceManager struct {
	Name                 string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Url                  string               `protobuf:"bytes,2,opt,name=url,proto3" json:"url,omitempty"`
	ExpirationTime       *timestamp.Timestamp `protobuf:"bytes,3,opt,name=expiration_time,json=expirationTime,proto3" json:"expiration_time,omitempty"`
	State                string               `protobuf:"bytes,4,opt,name=state,proto3" json:"state,omitempty"`
	XXX_NoUnkeyedLiteral struct{}             `json:"-"`
	XXX_unrecognized     []byte               `json:"-"`
	XXX_sizecache        int32                `json:"-"`
}

func (*NetworkServiceManager) Descriptor

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

func (*NetworkServiceManager) GetExpirationTime

func (m *NetworkServiceManager) GetExpirationTime() *timestamp.Timestamp

func (*NetworkServiceManager) GetName

func (m *NetworkServiceManager) GetName() string

func (*NetworkServiceManager) GetState

func (m *NetworkServiceManager) GetState() string

func (*NetworkServiceManager) GetUrl

func (m *NetworkServiceManager) GetUrl() string

func (*NetworkServiceManager) ProtoMessage

func (*NetworkServiceManager) ProtoMessage()

func (*NetworkServiceManager) Reset

func (m *NetworkServiceManager) Reset()

func (*NetworkServiceManager) String

func (m *NetworkServiceManager) String() string

func (*NetworkServiceManager) XXX_DiscardUnknown

func (m *NetworkServiceManager) XXX_DiscardUnknown()

func (*NetworkServiceManager) XXX_Marshal

func (m *NetworkServiceManager) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetworkServiceManager) XXX_Merge

func (m *NetworkServiceManager) XXX_Merge(src proto.Message)

func (*NetworkServiceManager) XXX_Size

func (m *NetworkServiceManager) XXX_Size() int

func (*NetworkServiceManager) XXX_Unmarshal

func (m *NetworkServiceManager) XXX_Unmarshal(b []byte) error

type NetworkServiceRegistryClient

type NetworkServiceRegistryClient interface {
	RegisterNSE(ctx context.Context, in *NSERegistration, opts ...grpc.CallOption) (*NSERegistration, error)
	BulkRegisterNSE(ctx context.Context, opts ...grpc.CallOption) (NetworkServiceRegistry_BulkRegisterNSEClient, error)
	RemoveNSE(ctx context.Context, in *RemoveNSERequest, opts ...grpc.CallOption) (*empty.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.

type NetworkServiceRegistryServer

type NetworkServiceRegistryServer interface {
	RegisterNSE(context.Context, *NSERegistration) (*NSERegistration, error)
	BulkRegisterNSE(NetworkServiceRegistry_BulkRegisterNSEServer) error
	RemoveNSE(context.Context, *RemoveNSERequest) (*empty.Empty, error)
}

NetworkServiceRegistryServer is the server API for NetworkServiceRegistry service.

type NetworkServiceRegistry_BulkRegisterNSEClient

type NetworkServiceRegistry_BulkRegisterNSEClient interface {
	Send(*NSERegistration) error
	Recv() (*NSERegistration, error)
	grpc.ClientStream
}

type NetworkServiceRegistry_BulkRegisterNSEServer

type NetworkServiceRegistry_BulkRegisterNSEServer interface {
	Send(*NSERegistration) error
	Recv() (*NSERegistration, error)
	grpc.ServerStream
}

type NsmRegistryClient

type NsmRegistryClient interface {
	RegisterNSM(ctx context.Context, in *NetworkServiceManager, opts ...grpc.CallOption) (*NetworkServiceManager, error)
	GetEndpoints(ctx context.Context, in *empty.Empty, opts ...grpc.CallOption) (*NetworkServiceEndpointList, error)
}

NsmRegistryClient is the client API for NsmRegistry service.

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

type NsmRegistryServer

type NsmRegistryServer interface {
	RegisterNSM(context.Context, *NetworkServiceManager) (*NetworkServiceManager, error)
	GetEndpoints(context.Context, *empty.Empty) (*NetworkServiceEndpointList, error)
}

NsmRegistryServer is the server API for NsmRegistry service.

type RemoveNSERequest

type RemoveNSERequest struct {
	NetworkServiceEndpointName string   `` /* 143-byte string literal not displayed */
	XXX_NoUnkeyedLiteral       struct{} `json:"-"`
	XXX_unrecognized           []byte   `json:"-"`
	XXX_sizecache              int32    `json:"-"`
}

func (*RemoveNSERequest) Descriptor

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

func (*RemoveNSERequest) GetNetworkServiceEndpointName

func (m *RemoveNSERequest) GetNetworkServiceEndpointName() string

func (*RemoveNSERequest) ProtoMessage

func (*RemoveNSERequest) ProtoMessage()

func (*RemoveNSERequest) Reset

func (m *RemoveNSERequest) Reset()

func (*RemoveNSERequest) String

func (m *RemoveNSERequest) String() string

func (*RemoveNSERequest) XXX_DiscardUnknown

func (m *RemoveNSERequest) XXX_DiscardUnknown()

func (*RemoveNSERequest) XXX_Marshal

func (m *RemoveNSERequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RemoveNSERequest) XXX_Merge

func (m *RemoveNSERequest) XXX_Merge(src proto.Message)

func (*RemoveNSERequest) XXX_Size

func (m *RemoveNSERequest) XXX_Size() int

func (*RemoveNSERequest) XXX_Unmarshal

func (m *RemoveNSERequest) XXX_Unmarshal(b []byte) error

type UnimplementedNetworkServiceDiscoveryServer

type UnimplementedNetworkServiceDiscoveryServer struct {
}

UnimplementedNetworkServiceDiscoveryServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkServiceDiscoveryServer) FindNetworkService

type UnimplementedNetworkServiceRegistryServer

type UnimplementedNetworkServiceRegistryServer struct {
}

UnimplementedNetworkServiceRegistryServer can be embedded to have forward compatible implementations.

func (*UnimplementedNetworkServiceRegistryServer) BulkRegisterNSE

func (*UnimplementedNetworkServiceRegistryServer) RegisterNSE

func (*UnimplementedNetworkServiceRegistryServer) RemoveNSE

type UnimplementedNsmRegistryServer

type UnimplementedNsmRegistryServer struct {
}

UnimplementedNsmRegistryServer can be embedded to have forward compatible implementations.

func (*UnimplementedNsmRegistryServer) GetEndpoints

func (*UnimplementedNsmRegistryServer) RegisterNSM

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL