localv1

package
v0.0.0-...-edb81cd Latest Latest
Warning

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

 Go to latest Published: Jul 9, 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 

func (Protocol) Type() protoreflect.EnumType

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.go.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.

func (UnimplementedSetsServer) Watch 

func (UnimplementedSetsServer) Watch(Sets_WatchServer) error

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.