Documentation
¶
Index ¶
- Variables
- func RegisterSetsServer(s grpc.ServiceRegistrar, srv SetsServer)
- type ClientIPAffinity
- type EmptyOp
- type Endpoint
- func (ep *Endpoint) AddAddress(s string) (ip net.IP)
- func (*Endpoint) Descriptor() ([]byte, []int)deprecated
- func (x *Endpoint) GetHostname() string
- func (x *Endpoint) GetIPs() *IPSet
- func (x *Endpoint) GetLocal() bool
- func (x *Endpoint) GetPortOverrides() []*PortName
- func (x *Endpoint) GetScopes() *EndpointScopes
- func (ep *Endpoint) PortMapping(port *PortMapping) (int32, error)
- func (ep *Endpoint) PortMappings(ports []*PortMapping) (mapping map[int32]int32)
- func (ep *Endpoint) PortNameMappings(ports []*PortMapping) (mapping map[string]int32)
- func (*Endpoint) ProtoMessage()
- func (x *Endpoint) ProtoReflect() protoreflect.Message
- func (x *Endpoint) Reset()
- func (x *Endpoint) String() string
- type EndpointScopes
- func (s *EndpointScopes) Any() bool
- func (*EndpointScopes) Descriptor() ([]byte, []int)deprecated
- func (x *EndpointScopes) GetExternal() bool
- func (x *EndpointScopes) GetInternal() bool
- func (*EndpointScopes) ProtoMessage()
- func (x *EndpointScopes) ProtoReflect() protoreflect.Message
- func (x *EndpointScopes) Reset()
- func (x *EndpointScopes) String() string
- type IPFilter
- type IPSet
- func (set *IPSet) Add(s string) (ip net.IP)
- func (set *IPSet) AddAll(ips []string)
- func (set *IPSet) AddSet(set2 *IPSet)
- func (set *IPSet) All() []string
- func (*IPSet) Descriptor() ([]byte, []int)deprecated
- func (from *IPSet) Diff(to *IPSet) (added, removed *IPSet)
- func (set *IPSet) First() string
- func (x *IPSet) GetV4() []string
- func (x *IPSet) GetV6() []string
- func (set *IPSet) IsEmpty() bool
- func (*IPSet) ProtoMessage()
- func (x *IPSet) ProtoReflect() protoreflect.Message
- func (x *IPSet) Reset()
- func (x *IPSet) String() string
- type OpItem
- func (*OpItem) Descriptor() ([]byte, []int)deprecated
- func (x *OpItem) GetDelete() *Ref
- func (m *OpItem) GetOp() isOpItem_Op
- func (x *OpItem) GetReset_() *EmptyOp
- func (x *OpItem) GetSet() *Value
- func (x *OpItem) GetSync() *EmptyOp
- func (*OpItem) ProtoMessage()
- func (x *OpItem) ProtoReflect() protoreflect.Message
- func (x *OpItem) Reset()
- func (x *OpItem) String() string
- type OpItem_Delete
- type OpItem_Reset_
- type OpItem_Set
- type OpItem_Sync
- type OpSink
- type PortMapping
- func (*PortMapping) Descriptor() ([]byte, []int)deprecated
- func (x *PortMapping) GetName() string
- func (x *PortMapping) GetNodePort() int32
- func (x *PortMapping) GetPort() int32
- func (x *PortMapping) GetProtocol() Protocol
- func (x *PortMapping) GetTargetPort() int32
- func (x *PortMapping) GetTargetPortName() string
- func (*PortMapping) ProtoMessage()
- func (x *PortMapping) ProtoReflect() protoreflect.Message
- func (x *PortMapping) Reset()
- func (p *PortMapping) SrcPorts() []int32
- func (x *PortMapping) String() string
- type PortName
- type Protocol
- type Ref
- type Service
- func (*Service) Descriptor() ([]byte, []int)deprecated
- func (x *Service) GetAnnotations() map[string]string
- func (x *Service) GetClientIP() *ClientIPAffinity
- func (x *Service) GetExternalTrafficToLocal() bool
- func (x *Service) GetHealthCheckNodePort() int32
- func (x *Service) GetIPFilters() []*IPFilter
- func (x *Service) GetIPs() *ServiceIPs
- func (x *Service) GetInternalTrafficToLocal() bool
- func (x *Service) GetLabels() map[string]string
- func (x *Service) GetMapIP() bool
- func (x *Service) GetName() string
- func (x *Service) GetNamespace() string
- func (x *Service) GetPorts() []*PortMapping
- func (m *Service) GetSessionAffinity() isService_SessionAffinity
- func (x *Service) GetType() string
- func (s *Service) NamespacedName() string
- func (*Service) ProtoMessage()
- func (x *Service) ProtoReflect() protoreflect.Message
- func (x *Service) Reset()
- func (x *Service) String() string
- type ServiceIPs
- func (s *ServiceIPs) All() (all *IPSet)
- func (s *ServiceIPs) AllIngress() (all *IPSet)
- func (*ServiceIPs) Descriptor() ([]byte, []int)deprecated
- func (x *ServiceIPs) GetClusterIPs() *IPSet
- func (x *ServiceIPs) GetExternalIPs() *IPSet
- func (x *ServiceIPs) GetHeadless() bool
- func (x *ServiceIPs) GetLoadBalancerIPs() *IPSet
- func (*ServiceIPs) ProtoMessage()
- func (x *ServiceIPs) ProtoReflect() protoreflect.Message
- func (x *ServiceIPs) Reset()
- func (x *ServiceIPs) String() string
- type Service_ClientIP
- type Set
- type SetsClient
- type SetsServer
- type Sets_WatchClient
- type Sets_WatchServer
- type UnimplementedSetsServer
- type UnsafeSetsServer
- type Value
- type WatchReq
Constants ¶
This section is empty.
Variables ¶
var (
Set_name = map[int32]string{
0: "UnknownSet",
1: "ServicesSet",
2: "EndpointsSet",
10: "GlobalServiceInfos",
11: "GlobalEndpointInfos",
12: "GlobalNodeInfos",
}
Set_value = map[string]int32{
"UnknownSet": 0,
"ServicesSet": 1,
"EndpointsSet": 2,
"GlobalServiceInfos": 10,
"GlobalEndpointInfos": 11,
"GlobalNodeInfos": 12,
}
)
Enum value maps for Set.
var (
Protocol_name = map[int32]string{
0: "UnknownProtocol",
1: "TCP",
2: "UDP",
3: "SCTP",
}
Protocol_value = map[string]int32{
"UnknownProtocol": 0,
"TCP": 1,
"UDP": 2,
"SCTP": 3,
}
)
Enum value maps for Protocol.
var File_api_localv1_api_proto protoreflect.FileDescriptor
var Sets_ServiceDesc = grpc.ServiceDesc{
ServiceName: "localv1.Sets",
HandlerType: (*SetsServer)(nil),
Methods: []grpc.MethodDesc{},
Streams: []grpc.StreamDesc{
{
StreamName: "Watch",
Handler: _Sets_Watch_Handler,
ServerStreams: true,
ClientStreams: true,
},
},
Metadata: "api/localv1/api.proto",
}
Sets_ServiceDesc is the grpc.ServiceDesc for Sets service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)
Functions ¶
func RegisterSetsServer ¶
func RegisterSetsServer(s grpc.ServiceRegistrar, srv SetsServer)
Types ¶
type ClientIPAffinity ¶
type ClientIPAffinity struct {
TimeoutSeconds int32 `protobuf:"varint,1,opt,name=TimeoutSeconds,proto3" json:"TimeoutSeconds,omitempty"`
// contains filtered or unexported fields
}
func (*ClientIPAffinity) Descriptor
deprecated
func (*ClientIPAffinity) Descriptor() ([]byte, []int)
Deprecated: Use ClientIPAffinity.ProtoReflect.Descriptor instead.
func (*ClientIPAffinity) GetTimeoutSeconds ¶
func (x *ClientIPAffinity) GetTimeoutSeconds() int32
func (*ClientIPAffinity) ProtoMessage ¶
func (*ClientIPAffinity) ProtoMessage()
func (*ClientIPAffinity) ProtoReflect ¶
func (x *ClientIPAffinity) ProtoReflect() protoreflect.Message
type EmptyOp ¶
type EmptyOp struct {
// contains filtered or unexported fields
}
func (*EmptyOp) Descriptor
deprecated
func (*EmptyOp) Descriptor() ([]byte, []int)
Deprecated: Use EmptyOp.ProtoReflect.Descriptor instead.
func (*EmptyOp) ProtoMessage ¶
func (*EmptyOp) ProtoMessage()
func (*EmptyOp) ProtoReflect ¶
func (x *EmptyOp) ProtoReflect() protoreflect.Message
type Endpoint ¶
type Endpoint struct {
Hostname string `protobuf:"bytes,1,opt,name=Hostname,proto3" json:"Hostname,omitempty"`
IPs *IPSet `protobuf:"bytes,2,opt,name=IPs,proto3" json:"IPs,omitempty"`
Local bool `protobuf:"varint,3,opt,name=Local,proto3" json:"Local,omitempty"`
PortOverrides []*PortName `protobuf:"bytes,4,rep,name=PortOverrides,proto3" json:"PortOverrides,omitempty"`
Scopes *EndpointScopes `protobuf:"bytes,5,opt,name=Scopes,proto3" json:"Scopes,omitempty"`
// contains filtered or unexported fields
}
func (*Endpoint) AddAddress ¶
func (ep *Endpoint) AddAddress(s string) (ip net.IP)
AddAddress adds an address to this endpoint, returning the parsed IP. `ìp` will be nil if it couldn't be parsed.
func (*Endpoint) Descriptor
deprecated
func (*Endpoint) Descriptor() ([]byte, []int)
Deprecated: Use Endpoint.ProtoReflect.Descriptor instead.
func (*Endpoint) GetHostname ¶
func (x *Endpoint) GetHostname() string
func (*Endpoint) GetPortOverrides ¶
func (x *Endpoint) GetPortOverrides() []*PortName
func (*Endpoint) PortMapping ¶
func (ep *Endpoint) PortMapping(port *PortMapping) (int32, error)
func (*Endpoint) PortMappings ¶
func (ep *Endpoint) PortMappings(ports []*PortMapping) (mapping map[int32]int32)
func (*Endpoint) PortNameMappings ¶
func (ep *Endpoint) PortNameMappings(ports []*PortMapping) (mapping map[string]int32)
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) ProtoReflect ¶
func (x *Endpoint) ProtoReflect() protoreflect.Message
type EndpointScopes ¶
type EndpointScopes struct {
Internal bool `protobuf:"varint,1,opt,name=Internal,proto3" json:"Internal,omitempty"`
External bool `protobuf:"varint,2,opt,name=External,proto3" json:"External,omitempty"`
// contains filtered or unexported fields
}
func (*EndpointScopes) Any ¶
func (s *EndpointScopes) Any() bool
Any returns true iff there's any scope at true
func (*EndpointScopes) Descriptor
deprecated
func (*EndpointScopes) Descriptor() ([]byte, []int)
Deprecated: Use EndpointScopes.ProtoReflect.Descriptor instead.
func (*EndpointScopes) GetExternal ¶
func (x *EndpointScopes) GetExternal() bool
func (*EndpointScopes) GetInternal ¶
func (x *EndpointScopes) GetInternal() bool
func (*EndpointScopes) ProtoMessage ¶
func (*EndpointScopes) ProtoMessage()
func (*EndpointScopes) ProtoReflect ¶
func (x *EndpointScopes) ProtoReflect() protoreflect.Message
type IPFilter ¶
type IPFilter struct {
// TargetIPs are the destination IPs to match (before DNAT)
TargetIPs *IPSet `protobuf:"bytes,1,opt,name=TargetIPs,proto3" json:"TargetIPs,omitempty"`
// SourceRanges are the CIDRs of IPs that are allowed by this filter rule
SourceRanges []string `protobuf:"bytes,2,rep,name=SourceRanges,proto3" json:"SourceRanges,omitempty"`
// contains filtered or unexported fields
}
func (*IPFilter) Descriptor
deprecated
func (*IPFilter) Descriptor() ([]byte, []int)
Deprecated: Use IPFilter.ProtoReflect.Descriptor instead.
func (*IPFilter) GetSourceRanges ¶
func (x *IPFilter) GetSourceRanges() []string
func (*IPFilter) GetTargetIPs ¶
func (x *IPFilter) GetTargetIPs() *IPSet
func (*IPFilter) ProtoMessage ¶
func (*IPFilter) ProtoMessage()
func (*IPFilter) ProtoReflect ¶
func (x *IPFilter) ProtoReflect() protoreflect.Message
type IPSet ¶
type IPSet struct {
V4 []string `protobuf:"bytes,1,rep,name=V4,proto3" json:"V4,omitempty"`
V6 []string `protobuf:"bytes,2,rep,name=V6,proto3" json:"V6,omitempty"`
// contains filtered or unexported fields
}
func (*IPSet) Add ¶
func (set *IPSet) Add(s string) (ip net.IP)
Add adds an address to this set, returning the parsed IP. `ìp` will be nil if it couldn't be parsed.
func (*IPSet) Descriptor
deprecated
func (*IPSet) Descriptor() ([]byte, []int)
Deprecated: Use IPSet.ProtoReflect.Descriptor instead.
func (*IPSet) ProtoMessage ¶
func (*IPSet) ProtoMessage()
func (*IPSet) ProtoReflect ¶
func (x *IPSet) ProtoReflect() protoreflect.Message
type OpItem ¶
type OpItem struct {
// Types that are assignable to Op:
//
// *OpItem_Sync
// *OpItem_Reset_
// *OpItem_Set
// *OpItem_Delete
Op isOpItem_Op `protobuf_oneof:"Op"`
// contains filtered or unexported fields
}
func (*OpItem) Descriptor
deprecated
func (*OpItem) Descriptor() ([]byte, []int)
Deprecated: Use OpItem.ProtoReflect.Descriptor instead.
func (*OpItem) ProtoMessage ¶
func (*OpItem) ProtoMessage()
func (*OpItem) ProtoReflect ¶
func (x *OpItem) ProtoReflect() protoreflect.Message
type OpItem_Delete ¶
type OpItem_Delete struct {
// Delete a value in a set
Delete *Ref `protobuf:"bytes,3,opt,name=Delete,proto3,oneof"`
}
type OpItem_Reset_ ¶
type OpItem_Reset_ struct {
// Reset signals that the whole data set will be sent next
Reset_ *EmptyOp `protobuf:"bytes,4,opt,name=Reset,proto3,oneof"`
}
type OpItem_Set ¶
type OpItem_Set struct {
// Add/update a value in a set
Set *Value `protobuf:"bytes,2,opt,name=Set,proto3,oneof"`
}
type OpItem_Sync ¶
type OpItem_Sync struct {
// Sync signals that the change set is complete (especially useful to know when the initial state is complete)
Sync *EmptyOp `protobuf:"bytes,1,opt,name=Sync,proto3,oneof"`
}
type PortMapping ¶
type PortMapping struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
Protocol Protocol `protobuf:"varint,2,opt,name=Protocol,proto3,enum=localv1.Protocol" json:"Protocol,omitempty"`
Port int32 `protobuf:"varint,3,opt,name=Port,proto3" json:"Port,omitempty"`
NodePort int32 `protobuf:"varint,4,opt,name=NodePort,proto3" json:"NodePort,omitempty"`
TargetPort int32 `protobuf:"varint,5,opt,name=TargetPort,proto3" json:"TargetPort,omitempty"`
TargetPortName string `protobuf:"bytes,6,opt,name=TargetPortName,proto3" json:"TargetPortName,omitempty"`
// contains filtered or unexported fields
}
func (*PortMapping) Descriptor
deprecated
func (*PortMapping) Descriptor() ([]byte, []int)
Deprecated: Use PortMapping.ProtoReflect.Descriptor instead.
func (*PortMapping) GetNodePort ¶
func (x *PortMapping) GetNodePort() int32
func (*PortMapping) GetProtocol ¶
func (x *PortMapping) GetProtocol() Protocol
func (*PortMapping) GetTargetPort ¶
func (x *PortMapping) GetTargetPort() int32
func (*PortMapping) GetTargetPortName ¶
func (x *PortMapping) GetTargetPortName() string
func (*PortMapping) ProtoMessage ¶
func (*PortMapping) ProtoMessage()
func (*PortMapping) ProtoReflect ¶
func (x *PortMapping) ProtoReflect() protoreflect.Message
type PortName ¶
type PortName struct {
Name string `protobuf:"bytes,1,opt,name=Name,proto3" json:"Name,omitempty"`
Port int32 `protobuf:"varint,2,opt,name=Port,proto3" json:"Port,omitempty"`
// contains filtered or unexported fields
}
func (*PortName) Descriptor
deprecated
func (*PortName) Descriptor() ([]byte, []int)
Deprecated: Use PortName.ProtoReflect.Descriptor instead.
func (*PortName) ProtoMessage ¶
func (*PortName) ProtoMessage()
func (*PortName) ProtoReflect ¶
func (x *PortName) ProtoReflect() protoreflect.Message
type Protocol ¶
type Protocol int32
const (
Protocol_UnknownProtocol Protocol = 0
Protocol_TCP Protocol = 1
Protocol_UDP Protocol = 2
Protocol_SCTP Protocol = 3
)
func ParseProtocol ¶
func ParseProtocol(s string) Protocol
func (Protocol) Descriptor ¶
func (Protocol) Descriptor() protoreflect.EnumDescriptor
func (Protocol) EnumDescriptor
deprecated
func (Protocol) EnumDescriptor() ([]byte, []int)
Deprecated: Use Protocol.Descriptor instead.
type Ref ¶
type Ref struct {
Set Set `protobuf:"varint,1,opt,name=Set,proto3,enum=localv1.Set" json:"Set,omitempty"`
Path string `protobuf:"bytes,2,opt,name=Path,proto3" json:"Path,omitempty"`
// contains filtered or unexported fields
}
func (*Ref) Descriptor
deprecated
func (*Ref) Descriptor() ([]byte, []int)
Deprecated: Use Ref.ProtoReflect.Descriptor instead.
func (*Ref) ProtoMessage ¶
func (*Ref) ProtoMessage()
func (*Ref) ProtoReflect ¶
func (x *Ref) ProtoReflect() protoreflect.Message
type Service ¶
type Service struct {
Namespace string `protobuf:"bytes,1,opt,name=Namespace,proto3" json:"Namespace,omitempty"`
Name string `protobuf:"bytes,2,opt,name=Name,proto3" json:"Name,omitempty"`
Type string `protobuf:"bytes,3,opt,name=Type,proto3" json:"Type,omitempty"`
Labels map[string]string `` /* 153-byte string literal not displayed */
Annotations map[string]string `` /* 163-byte string literal not displayed */
IPs *ServiceIPs `protobuf:"bytes,4,opt,name=IPs,proto3" json:"IPs,omitempty"`
IPFilters []*IPFilter `protobuf:"bytes,10,rep,name=IPFilters,proto3" json:"IPFilters,omitempty"`
// true if the service maps the whole IP, not just individual ports.
MapIP bool `protobuf:"varint,5,opt,name=MapIP,proto3" json:"MapIP,omitempty"`
// Individual ports mapped for the this service
Ports []*PortMapping `protobuf:"bytes,6,rep,name=Ports,proto3" json:"Ports,omitempty"`
ExternalTrafficToLocal bool `protobuf:"varint,7,opt,name=ExternalTrafficToLocal,proto3" json:"ExternalTrafficToLocal,omitempty"`
// Types that are assignable to SessionAffinity:
//
// *Service_ClientIP
SessionAffinity isService_SessionAffinity `protobuf_oneof:"SessionAffinity"`
InternalTrafficToLocal bool `protobuf:"varint,12,opt,name=InternalTrafficToLocal,proto3" json:"InternalTrafficToLocal,omitempty"`
HealthCheckNodePort int32 `protobuf:"varint,13,opt,name=HealthCheckNodePort,proto3" json:"HealthCheckNodePort,omitempty"`
// contains filtered or unexported fields
}
func (*Service) Descriptor
deprecated
func (*Service) Descriptor() ([]byte, []int)
Deprecated: Use Service.ProtoReflect.Descriptor instead.
func (*Service) GetAnnotations ¶
func (x *Service) GetAnnotations() map[string]string
func (*Service) GetClientIP ¶
func (x *Service) GetClientIP() *ClientIPAffinity
func (*Service) GetExternalTrafficToLocal ¶
func (x *Service) GetExternalTrafficToLocal() bool
func (*Service) GetHealthCheckNodePort ¶
func (x *Service) GetHealthCheckNodePort() int32
func (*Service) GetIPFilters ¶
func (x *Service) GetIPFilters() []*IPFilter
func (*Service) GetInternalTrafficToLocal ¶
func (x *Service) GetInternalTrafficToLocal() bool
func (*Service) GetNamespace ¶
func (x *Service) GetNamespace() string
func (*Service) GetSessionAffinity ¶
func (m *Service) GetSessionAffinity() isService_SessionAffinity
func (*Service) NamespacedName ¶
func (s *Service) NamespacedName() string
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) ProtoReflect ¶
func (x *Service) ProtoReflect() protoreflect.Message
type ServiceIPs ¶
type ServiceIPs struct {
ClusterIPs *IPSet `protobuf:"bytes,1,opt,name=ClusterIPs,proto3" json:"ClusterIPs,omitempty"`
ExternalIPs *IPSet `protobuf:"bytes,2,opt,name=ExternalIPs,proto3" json:"ExternalIPs,omitempty"`
LoadBalancerIPs *IPSet `protobuf:"bytes,4,opt,name=LoadBalancerIPs,proto3" json:"LoadBalancerIPs,omitempty"`
Headless bool `protobuf:"varint,3,opt,name=Headless,proto3" json:"Headless,omitempty"`
// contains filtered or unexported fields
}
func (*ServiceIPs) AllIngress ¶
func (s *ServiceIPs) AllIngress() (all *IPSet)
func (*ServiceIPs) Descriptor
deprecated
func (*ServiceIPs) Descriptor() ([]byte, []int)
Deprecated: Use ServiceIPs.ProtoReflect.Descriptor instead.
func (*ServiceIPs) GetClusterIPs ¶
func (x *ServiceIPs) GetClusterIPs() *IPSet
func (*ServiceIPs) GetExternalIPs ¶
func (x *ServiceIPs) GetExternalIPs() *IPSet
func (*ServiceIPs) GetHeadless ¶
func (x *ServiceIPs) GetHeadless() bool
func (*ServiceIPs) GetLoadBalancerIPs ¶
func (x *ServiceIPs) GetLoadBalancerIPs() *IPSet
func (*ServiceIPs) ProtoMessage ¶
func (*ServiceIPs) ProtoMessage()
func (*ServiceIPs) ProtoReflect ¶
func (x *ServiceIPs) ProtoReflect() protoreflect.Message
type Service_ClientIP ¶
type Service_ClientIP struct {
ClientIP *ClientIPAffinity `protobuf:"bytes,11,opt,name=ClientIP,proto3,oneof"`
}
type Set ¶
type Set int32
const (
Set_UnknownSet Set = 0
Set_ServicesSet Set = 1
Set_EndpointsSet Set = 2
// FIXME move to a 3rd generic proto ???
Set_GlobalServiceInfos Set = 10
Set_GlobalEndpointInfos Set = 11
Set_GlobalNodeInfos Set = 12
)
func (Set) Descriptor ¶
func (Set) Descriptor() protoreflect.EnumDescriptor
func (Set) EnumDescriptor
deprecated
func (Set) EnumDescriptor() ([]byte, []int)
Deprecated: Use Set.Descriptor instead.
type SetsClient ¶
type SetsClient interface {
// Returns all the endpoints for this node.
Watch(ctx context.Context, opts ...grpc.CallOption) (Sets_WatchClient, error)
}
SetsClient is the client API for Sets service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkgo.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.
func NewSetsClient ¶
func NewSetsClient(cc grpc.ClientConnInterface) SetsClient
type SetsServer ¶
type SetsServer interface {
// Returns all the endpoints for this node.
Watch(Sets_WatchServer) error
// contains filtered or unexported methods
}
SetsServer is the server API for Sets service. All implementations must embed UnimplementedSetsServer for forward compatibility
type Sets_WatchClient ¶
type Sets_WatchClient interface {
Send(*WatchReq) error
Recv() (*OpItem, error)
grpc.ClientStream
}
type Sets_WatchServer ¶
type Sets_WatchServer interface {
Send(*OpItem) error
Recv() (*WatchReq, error)
grpc.ServerStream
}
type UnimplementedSetsServer ¶
type UnimplementedSetsServer struct {
}
UnimplementedSetsServer must be embedded to have forward compatible implementations.
type UnsafeSetsServer ¶
type UnsafeSetsServer interface {
// contains filtered or unexported methods
}
UnsafeSetsServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to SetsServer will result in compilation errors.
type Value ¶
type Value struct {
Ref *Ref `protobuf:"bytes,1,opt,name=Ref,proto3" json:"Ref,omitempty"`
Bytes []byte `protobuf:"bytes,2,opt,name=Bytes,proto3" json:"Bytes,omitempty"`
// contains filtered or unexported fields
}
func (*Value) Descriptor
deprecated
func (*Value) Descriptor() ([]byte, []int)
Deprecated: Use Value.ProtoReflect.Descriptor instead.
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) ProtoReflect ¶
func (x *Value) ProtoReflect() protoreflect.Message
type WatchReq ¶
type WatchReq struct {
// NodeName of the requester
NodeName string `protobuf:"bytes,1,opt,name=NodeName,proto3" json:"NodeName,omitempty"`
// contains filtered or unexported fields
}
To request ENLS(Expected Node Local State) a client must specify the desired NodeName "location" from where we are watching.
func (*WatchReq) Descriptor
deprecated
func (*WatchReq) Descriptor() ([]byte, []int)
Deprecated: Use WatchReq.ProtoReflect.Descriptor instead.
func (*WatchReq) GetNodeName ¶
func (x *WatchReq) GetNodeName() string
func (*WatchReq) ProtoMessage ¶
func (*WatchReq) ProtoMessage()
func (*WatchReq) ProtoReflect ¶
func (x *WatchReq) ProtoReflect() protoreflect.Message