Documentation ¶
Index ¶
- func RegisterNetworkServiceDiscoveryServer(s *grpc.Server, srv NetworkServiceDiscoveryServer)
- func RegisterNetworkServiceRegistryServer(s *grpc.Server, srv NetworkServiceRegistryServer)
- func RegisterNsmRegistryServer(s *grpc.Server, srv NsmRegistryServer)
- type Destination
- func (*Destination) Descriptor() ([]byte, []int)
- func (m *Destination) GetDestinationSelector() map[string]string
- func (m *Destination) GetWeight() uint32
- func (*Destination) ProtoMessage()
- func (m *Destination) Reset()
- func (m *Destination) String() string
- func (m *Destination) XXX_DiscardUnknown()
- func (m *Destination) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Destination) XXX_Merge(src proto.Message)
- func (m *Destination) XXX_Size() int
- func (m *Destination) XXX_Unmarshal(b []byte) error
- type EndpointNSMName
- type FindNetworkServiceRequest
- func (*FindNetworkServiceRequest) Descriptor() ([]byte, []int)
- func (m *FindNetworkServiceRequest) GetNetworkServiceName() string
- func (*FindNetworkServiceRequest) ProtoMessage()
- func (m *FindNetworkServiceRequest) Reset()
- func (m *FindNetworkServiceRequest) String() string
- func (m *FindNetworkServiceRequest) XXX_DiscardUnknown()
- func (m *FindNetworkServiceRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FindNetworkServiceRequest) XXX_Merge(src proto.Message)
- func (m *FindNetworkServiceRequest) XXX_Size() int
- func (m *FindNetworkServiceRequest) XXX_Unmarshal(b []byte) error
- type FindNetworkServiceResponse
- func (*FindNetworkServiceResponse) Descriptor() ([]byte, []int)
- func (m *FindNetworkServiceResponse) GetNetworkService() *NetworkService
- func (m *FindNetworkServiceResponse) GetNetworkServiceEndpoints() []*NetworkServiceEndpoint
- func (m *FindNetworkServiceResponse) GetNetworkServiceManagers() map[string]*NetworkServiceManager
- func (m *FindNetworkServiceResponse) GetPayload() string
- func (*FindNetworkServiceResponse) ProtoMessage()
- func (m *FindNetworkServiceResponse) Reset()
- func (m *FindNetworkServiceResponse) String() string
- func (m *FindNetworkServiceResponse) XXX_DiscardUnknown()
- func (m *FindNetworkServiceResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *FindNetworkServiceResponse) XXX_Merge(src proto.Message)
- func (m *FindNetworkServiceResponse) XXX_Size() int
- func (m *FindNetworkServiceResponse) XXX_Unmarshal(b []byte) error
- type Match
- func (*Match) Descriptor() ([]byte, []int)
- func (m *Match) GetRoutes() []*Destination
- func (m *Match) GetSourceSelector() map[string]string
- func (*Match) ProtoMessage()
- func (m *Match) Reset()
- func (m *Match) String() string
- func (m *Match) XXX_DiscardUnknown()
- func (m *Match) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Match) XXX_Merge(src proto.Message)
- func (m *Match) XXX_Size() int
- func (m *Match) XXX_Unmarshal(b []byte) error
- type NSERegistration
- func (*NSERegistration) Descriptor() ([]byte, []int)
- func (nse *NSERegistration) GetEndpointNSMName() EndpointNSMName
- func (m *NSERegistration) GetNetworkService() *NetworkService
- func (m *NSERegistration) GetNetworkServiceEndpoint() *NetworkServiceEndpoint
- func (m *NSERegistration) GetNetworkServiceManager() *NetworkServiceManager
- func (*NSERegistration) ProtoMessage()
- func (m *NSERegistration) Reset()
- func (m *NSERegistration) String() string
- func (m *NSERegistration) XXX_DiscardUnknown()
- func (m *NSERegistration) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NSERegistration) XXX_Merge(src proto.Message)
- func (m *NSERegistration) XXX_Size() int
- func (m *NSERegistration) XXX_Unmarshal(b []byte) error
- type NetworkService
- func (*NetworkService) Descriptor() ([]byte, []int)
- func (m *NetworkService) GetMatches() []*Match
- func (m *NetworkService) GetName() string
- func (m *NetworkService) GetPayload() string
- func (*NetworkService) ProtoMessage()
- func (m *NetworkService) Reset()
- func (m *NetworkService) String() string
- func (m *NetworkService) XXX_DiscardUnknown()
- func (m *NetworkService) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NetworkService) XXX_Merge(src proto.Message)
- func (m *NetworkService) XXX_Size() int
- func (m *NetworkService) XXX_Unmarshal(b []byte) error
- type NetworkServiceDiscoveryClient
- type NetworkServiceDiscoveryServer
- type NetworkServiceEndpoint
- func (*NetworkServiceEndpoint) Descriptor() ([]byte, []int)
- func (m *NetworkServiceEndpoint) GetLabels() map[string]string
- func (m *NetworkServiceEndpoint) GetName() string
- func (m *NetworkServiceEndpoint) GetNetworkServiceManagerName() string
- func (m *NetworkServiceEndpoint) GetNetworkServiceName() string
- func (m *NetworkServiceEndpoint) GetPayload() string
- func (m *NetworkServiceEndpoint) GetState() string
- func (*NetworkServiceEndpoint) ProtoMessage()
- func (m *NetworkServiceEndpoint) Reset()
- func (m *NetworkServiceEndpoint) String() string
- func (m *NetworkServiceEndpoint) XXX_DiscardUnknown()
- func (m *NetworkServiceEndpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NetworkServiceEndpoint) XXX_Merge(src proto.Message)
- func (m *NetworkServiceEndpoint) XXX_Size() int
- func (m *NetworkServiceEndpoint) XXX_Unmarshal(b []byte) error
- type NetworkServiceEndpointList
- func (*NetworkServiceEndpointList) Descriptor() ([]byte, []int)
- func (m *NetworkServiceEndpointList) GetNetworkServiceEndpoints() []*NetworkServiceEndpoint
- func (*NetworkServiceEndpointList) ProtoMessage()
- func (m *NetworkServiceEndpointList) Reset()
- func (m *NetworkServiceEndpointList) String() string
- func (m *NetworkServiceEndpointList) XXX_DiscardUnknown()
- func (m *NetworkServiceEndpointList) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NetworkServiceEndpointList) XXX_Merge(src proto.Message)
- func (m *NetworkServiceEndpointList) XXX_Size() int
- func (m *NetworkServiceEndpointList) XXX_Unmarshal(b []byte) error
- type NetworkServiceManager
- func (*NetworkServiceManager) Descriptor() ([]byte, []int)
- func (m *NetworkServiceManager) GetExpirationTime() *timestamp.Timestamp
- func (m *NetworkServiceManager) GetName() string
- func (m *NetworkServiceManager) GetState() string
- func (m *NetworkServiceManager) GetUrl() string
- func (*NetworkServiceManager) ProtoMessage()
- func (m *NetworkServiceManager) Reset()
- func (m *NetworkServiceManager) String() string
- func (m *NetworkServiceManager) XXX_DiscardUnknown()
- func (m *NetworkServiceManager) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *NetworkServiceManager) XXX_Merge(src proto.Message)
- func (m *NetworkServiceManager) XXX_Size() int
- func (m *NetworkServiceManager) XXX_Unmarshal(b []byte) error
- type NetworkServiceRegistryClient
- type NetworkServiceRegistryServer
- type NetworkServiceRegistry_BulkRegisterNSEClient
- type NetworkServiceRegistry_BulkRegisterNSEServer
- type NsmRegistryClient
- type NsmRegistryServer
- type RemoveNSERequest
- func (*RemoveNSERequest) Descriptor() ([]byte, []int)
- func (m *RemoveNSERequest) GetNetworkServiceEndpointName() string
- func (*RemoveNSERequest) ProtoMessage()
- func (m *RemoveNSERequest) Reset()
- func (m *RemoveNSERequest) String() string
- func (m *RemoveNSERequest) XXX_DiscardUnknown()
- func (m *RemoveNSERequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *RemoveNSERequest) XXX_Merge(src proto.Message)
- func (m *RemoveNSERequest) XXX_Size() int
- func (m *RemoveNSERequest) XXX_Unmarshal(b []byte) error
- type UnimplementedNetworkServiceDiscoveryServer
- type UnimplementedNetworkServiceRegistryServer
- func (*UnimplementedNetworkServiceRegistryServer) BulkRegisterNSE(srv NetworkServiceRegistry_BulkRegisterNSEServer) error
- func (*UnimplementedNetworkServiceRegistryServer) RegisterNSE(ctx context.Context, req *NSERegistration) (*NSERegistration, error)
- func (*UnimplementedNetworkServiceRegistryServer) RemoveNSE(ctx context.Context, req *RemoveNSERequest) (*empty.Empty, error)
- type UnimplementedNsmRegistryServer
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) GetRoutes ¶
func (m *Match) GetRoutes() []*Destination
func (*Match) GetSourceSelector ¶
func (*Match) ProtoMessage ¶
func (*Match) ProtoMessage()
func (*Match) XXX_DiscardUnknown ¶
func (m *Match) XXX_DiscardUnknown()
func (*Match) XXX_Marshal ¶
func (*Match) XXX_Unmarshal ¶
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.
func NewNetworkServiceDiscoveryClient ¶
func NewNetworkServiceDiscoveryClient(cc grpc.ClientConnInterface) NetworkServiceDiscoveryClient
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.
func NewNetworkServiceRegistryClient ¶
func NewNetworkServiceRegistryClient(cc grpc.ClientConnInterface) NetworkServiceRegistryClient
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.
func NewNsmRegistryClient ¶
func NewNsmRegistryClient(cc grpc.ClientConnInterface) NsmRegistryClient
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 ¶
func (*UnimplementedNetworkServiceDiscoveryServer) FindNetworkService(ctx context.Context, req *FindNetworkServiceRequest) (*FindNetworkServiceResponse, error)
type UnimplementedNetworkServiceRegistryServer ¶
type UnimplementedNetworkServiceRegistryServer struct { }
UnimplementedNetworkServiceRegistryServer can be embedded to have forward compatible implementations.
func (*UnimplementedNetworkServiceRegistryServer) BulkRegisterNSE ¶
func (*UnimplementedNetworkServiceRegistryServer) BulkRegisterNSE(srv NetworkServiceRegistry_BulkRegisterNSEServer) error
func (*UnimplementedNetworkServiceRegistryServer) RegisterNSE ¶
func (*UnimplementedNetworkServiceRegistryServer) RegisterNSE(ctx context.Context, req *NSERegistration) (*NSERegistration, error)
func (*UnimplementedNetworkServiceRegistryServer) RemoveNSE ¶
func (*UnimplementedNetworkServiceRegistryServer) RemoveNSE(ctx context.Context, req *RemoveNSERequest) (*empty.Empty, error)
type UnimplementedNsmRegistryServer ¶
type UnimplementedNsmRegistryServer struct { }
UnimplementedNsmRegistryServer can be embedded to have forward compatible implementations.
func (*UnimplementedNsmRegistryServer) GetEndpoints ¶
func (*UnimplementedNsmRegistryServer) GetEndpoints(ctx context.Context, req *empty.Empty) (*NetworkServiceEndpointList, error)
func (*UnimplementedNsmRegistryServer) RegisterNSM ¶
func (*UnimplementedNsmRegistryServer) RegisterNSM(ctx context.Context, req *NetworkServiceManager) (*NetworkServiceManager, error)