localv1

package
v0.0.0-...-c7476d4 Latest Latest
Warning

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

Go to latest
Published: Jan 19, 2024 License: Apache-2.0 Imports: 12 Imported by: 34

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

View Source
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.

View Source
var File_api_localv1_api_proto protoreflect.FileDescriptor
View Source
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

func (*ClientIPAffinity) Reset

func (x *ClientIPAffinity) Reset()

func (*ClientIPAffinity) String

func (x *ClientIPAffinity) String() string

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

func (*EmptyOp) Reset

func (x *EmptyOp) Reset()

func (*EmptyOp) String

func (x *EmptyOp) String() string

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) GetIPs

func (x *Endpoint) GetIPs() *IPSet

func (*Endpoint) GetLocal

func (x *Endpoint) GetLocal() bool

func (*Endpoint) GetPortOverrides

func (x *Endpoint) GetPortOverrides() []*PortName

func (*Endpoint) GetScopes

func (x *Endpoint) GetScopes() *EndpointScopes

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

func (*Endpoint) Reset

func (x *Endpoint) Reset()

func (*Endpoint) String

func (x *Endpoint) String() string

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

func (*EndpointScopes) Reset

func (x *EndpointScopes) Reset()

func (*EndpointScopes) String

func (x *EndpointScopes) String() string

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

func (*IPFilter) Reset

func (x *IPFilter) Reset()

func (*IPFilter) String

func (x *IPFilter) String() string

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 NewIPSet

func NewIPSet(ips ...string) (set *IPSet)

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) AddAll

func (set *IPSet) AddAll(ips []string)

func (*IPSet) AddSet

func (set *IPSet) AddSet(set2 *IPSet)

func (*IPSet) All

func (set *IPSet) All() []string

func (*IPSet) Descriptor deprecated

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

Deprecated: Use IPSet.ProtoReflect.Descriptor instead.

func (*IPSet) Diff

func (from *IPSet) Diff(to *IPSet) (added, removed *IPSet)

func (*IPSet) First

func (set *IPSet) First() string

func (*IPSet) GetV4

func (x *IPSet) GetV4() []string

func (*IPSet) GetV6

func (x *IPSet) GetV6() []string

func (*IPSet) IsEmpty

func (set *IPSet) IsEmpty() bool

func (*IPSet) ProtoMessage

func (*IPSet) ProtoMessage()

func (*IPSet) ProtoReflect

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

func (*IPSet) Reset

func (x *IPSet) Reset()

func (*IPSet) String

func (x *IPSet) String() string

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) GetDelete

func (x *OpItem) GetDelete() *Ref

func (*OpItem) GetOp

func (m *OpItem) GetOp() isOpItem_Op

func (*OpItem) GetReset_

func (x *OpItem) GetReset_() *EmptyOp

func (*OpItem) GetSet

func (x *OpItem) GetSet() *Value

func (*OpItem) GetSync

func (x *OpItem) GetSync() *EmptyOp

func (*OpItem) ProtoMessage

func (*OpItem) ProtoMessage()

func (*OpItem) ProtoReflect

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

func (*OpItem) Reset

func (x *OpItem) Reset()

func (*OpItem) String

func (x *OpItem) String() string

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 OpSink

type OpSink interface {
	Send(op *OpItem) error
}

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) GetName

func (x *PortMapping) GetName() string

func (*PortMapping) GetNodePort

func (x *PortMapping) GetNodePort() int32

func (*PortMapping) GetPort

func (x *PortMapping) GetPort() 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

func (*PortMapping) Reset

func (x *PortMapping) Reset()

func (*PortMapping) SrcPorts

func (p *PortMapping) SrcPorts() []int32

func (*PortMapping) String

func (x *PortMapping) String() string

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) GetName

func (x *PortName) GetName() string

func (*PortName) GetPort

func (x *PortName) GetPort() int32

func (*PortName) ProtoMessage

func (*PortName) ProtoMessage()

func (*PortName) ProtoReflect

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

func (*PortName) Reset

func (x *PortName) Reset()

func (*PortName) String

func (x *PortName) String() string

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) Enum

func (x Protocol) Enum() *Protocol

func (Protocol) EnumDescriptor deprecated

func (Protocol) EnumDescriptor() ([]byte, []int)

Deprecated: Use Protocol.Descriptor instead.

func (Protocol) Number

func (x Protocol) Number() protoreflect.EnumNumber

func (Protocol) String

func (x Protocol) String() string

func (Protocol) Type

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) GetPath

func (x *Ref) GetPath() string

func (*Ref) GetSet

func (x *Ref) GetSet() Set

func (*Ref) ProtoMessage

func (*Ref) ProtoMessage()

func (*Ref) ProtoReflect

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

func (*Ref) Reset

func (x *Ref) Reset()

func (*Ref) String

func (x *Ref) String() string

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) GetIPs

func (x *Service) GetIPs() *ServiceIPs

func (*Service) GetInternalTrafficToLocal

func (x *Service) GetInternalTrafficToLocal() bool

func (*Service) GetLabels

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

func (*Service) GetMapIP

func (x *Service) GetMapIP() bool

func (*Service) GetName

func (x *Service) GetName() string

func (*Service) GetNamespace

func (x *Service) GetNamespace() string

func (*Service) GetPorts

func (x *Service) GetPorts() []*PortMapping

func (*Service) GetSessionAffinity

func (m *Service) GetSessionAffinity() isService_SessionAffinity

func (*Service) GetType

func (x *Service) GetType() string

func (*Service) NamespacedName

func (s *Service) NamespacedName() string

func (*Service) ProtoMessage

func (*Service) ProtoMessage()

func (*Service) ProtoReflect

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

func (*Service) Reset

func (x *Service) Reset()

func (*Service) String

func (x *Service) String() string

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) All

func (s *ServiceIPs) All() (all *IPSet)

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

func (*ServiceIPs) Reset

func (x *ServiceIPs) Reset()

func (*ServiceIPs) String

func (x *ServiceIPs) String() string

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) Enum

func (x Set) Enum() *Set

func (Set) EnumDescriptor deprecated

func (Set) EnumDescriptor() ([]byte, []int)

Deprecated: Use Set.Descriptor instead.

func (Set) Number

func (x Set) Number() protoreflect.EnumNumber

func (Set) String

func (x Set) String() string

func (Set) Type

func (Set) Type() protoreflect.EnumType

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://pkg.golang.ir/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.

func (UnimplementedSetsServer) Watch

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) GetBytes

func (x *Value) GetBytes() []byte

func (*Value) GetRef

func (x *Value) GetRef() *Ref

func (*Value) ProtoMessage

func (*Value) ProtoMessage()

func (*Value) ProtoReflect

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

func (*Value) Reset

func (x *Value) Reset()

func (*Value) String

func (x *Value) String() string

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

func (*WatchReq) Reset

func (x *WatchReq) Reset()

func (*WatchReq) String

func (x *WatchReq) String() string

Jump to

Keyboard shortcuts

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