proto

package
v0.0.0-...-0290855 Latest Latest
Warning

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

 Go to latest Published: Nov 9, 2024 License: Apache-2.0 Imports: 9 Imported by: 22

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	DiscoveryState_name = map[int32]string{
		0: "UNKNOWN",
		1: "TRACKING",
		2: "COMPLETE",
	}
	DiscoveryState_value = map[string]int32{
		"UNKNOWN":  0,
		"TRACKING": 1,
		"COMPLETE": 2,
	}
)

Enum value maps for DiscoveryState.

View Source 
var (
	InternalState_ServingState_name = map[int32]string{
		0: "UNKNOWN",
		1: "SERVING",
		2: "NOT_SERVING",
		3: "UNREACHABLE",
	}
	InternalState_ServingState_value = map[string]int32{
		"UNKNOWN":     0,
		"SERVING":     1,
		"NOT_SERVING": 2,
		"UNREACHABLE": 3,
	}
)

Enum value maps for InternalState_ServingState.

View Source 
var (
	RegistryEntry_Version_name = map[int32]string{
		0: "V1",
		1: "V2",
	}
	RegistryEntry_Version_value = map[string]int32{
		"V1": 0,
		"V2": 1,
	}
)

Enum value maps for RegistryEntry_Version.

View Source 
var File_discovery_proto protoreflect.FileDescriptor

Functions

func RegisterDiscoveryServiceServer 

func RegisterDiscoveryServiceServer(s grpc.ServiceRegistrar, srv DiscoveryServiceServer)

func RegisterDiscoveryServiceV2Server 

func RegisterDiscoveryServiceV2Server(s grpc.ServiceRegistrar, srv DiscoveryServiceV2Server)

Types

type Config 

type Config struct {
	FriendState map[string]*InternalState `` /* 182-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Config) Descriptor deprecated 

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

Deprecated: Use Config.ProtoReflect.Descriptor instead.

func (*Config) GetFriendState 

func (x *Config) GetFriendState() map[string]*InternalState

func (*Config) ProtoMessage 

func (*Config) ProtoMessage()

func (*Config) ProtoReflect 

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

func (*Config) Reset 

func (x *Config) Reset()

func (*Config) String 

func (x *Config) String() string

type DiscoverRequest 

type DiscoverRequest struct {
	Request *RegistryEntry `protobuf:"bytes,1,opt,name=request,proto3" json:"request,omitempty"`
	Caller  string         `protobuf:"bytes,2,opt,name=caller,proto3" json:"caller,omitempty"`
	// contains filtered or unexported fields
}

func (*DiscoverRequest) Descriptor deprecated 

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

Deprecated: Use DiscoverRequest.ProtoReflect.Descriptor instead.

func (*DiscoverRequest) GetCaller 

func (x *DiscoverRequest) GetCaller() string

func (*DiscoverRequest) GetRequest 

func (x *DiscoverRequest) GetRequest() *RegistryEntry

func (*DiscoverRequest) ProtoMessage 

func (*DiscoverRequest) ProtoMessage()

func (*DiscoverRequest) ProtoReflect 

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

func (*DiscoverRequest) Reset 

func (x *DiscoverRequest) Reset()

func (*DiscoverRequest) String 

func (x *DiscoverRequest) String() string

type DiscoverResponse 

type DiscoverResponse struct {
	Service *RegistryEntry `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*DiscoverResponse) Descriptor deprecated 

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

Deprecated: Use DiscoverResponse.ProtoReflect.Descriptor instead.

func (*DiscoverResponse) GetService 

func (x *DiscoverResponse) GetService() *RegistryEntry

func (*DiscoverResponse) ProtoMessage 

func (*DiscoverResponse) ProtoMessage()

func (*DiscoverResponse) ProtoReflect 

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

func (*DiscoverResponse) Reset 

func (x *DiscoverResponse) Reset()

func (*DiscoverResponse) String 

func (x *DiscoverResponse) String() string

type DiscoveryServiceClient 

type DiscoveryServiceClient interface {
	RegisterService(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	Discover(ctx context.Context, in *DiscoverRequest, opts ...grpc.CallOption) (*DiscoverResponse, error)
	ListAllServices(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error)
	State(ctx context.Context, in *StateRequest, opts ...grpc.CallOption) (*StateResponse, error)
}

DiscoveryServiceClient is the client API for DiscoveryService 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 NewDiscoveryServiceClient 

func NewDiscoveryServiceClient(cc grpc.ClientConnInterface) DiscoveryServiceClient

type DiscoveryServiceServer 

type DiscoveryServiceServer interface {
	RegisterService(context.Context, *RegisterRequest) (*RegisterResponse, error)
	Discover(context.Context, *DiscoverRequest) (*DiscoverResponse, error)
	ListAllServices(context.Context, *ListRequest) (*ListResponse, error)
	State(context.Context, *StateRequest) (*StateResponse, error)
}

DiscoveryServiceServer is the server API for DiscoveryService service. All implementations should embed UnimplementedDiscoveryServiceServer for forward compatibility

type DiscoveryServiceV2Client 

type DiscoveryServiceV2Client interface {
	Lock(ctx context.Context, in *LockRequest, opts ...grpc.CallOption) (*LockResponse, error)
	RegisterV2(ctx context.Context, in *RegisterRequest, opts ...grpc.CallOption) (*RegisterResponse, error)
	Get(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error)
	Unregister(ctx context.Context, in *UnregisterRequest, opts ...grpc.CallOption) (*UnregisterResponse, error)
	GetFriends(ctx context.Context, in *GetFriendsRequest, opts ...grpc.CallOption) (*GetFriendsResponse, error)
	GetInternalState(ctx context.Context, in *GetStateRequest, opts ...grpc.CallOption) (*GetStateResponse, error)
	GetConfig(ctx context.Context, in *GetConfigRequest, opts ...grpc.CallOption) (*GetConfigResponse, error)
	SetZone(ctx context.Context, in *SetZoneRequest, opts ...grpc.CallOption) (*SetZoneResponse, error)
}

DiscoveryServiceV2Client is the client API for DiscoveryServiceV2 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 NewDiscoveryServiceV2Client 

func NewDiscoveryServiceV2Client(cc grpc.ClientConnInterface) DiscoveryServiceV2Client

type DiscoveryServiceV2Server 

type DiscoveryServiceV2Server interface {
	Lock(context.Context, *LockRequest) (*LockResponse, error)
	RegisterV2(context.Context, *RegisterRequest) (*RegisterResponse, error)
	Get(context.Context, *GetRequest) (*GetResponse, error)
	Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, error)
	GetFriends(context.Context, *GetFriendsRequest) (*GetFriendsResponse, error)
	GetInternalState(context.Context, *GetStateRequest) (*GetStateResponse, error)
	GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)
	SetZone(context.Context, *SetZoneRequest) (*SetZoneResponse, error)
}

DiscoveryServiceV2Server is the server API for DiscoveryServiceV2 service. All implementations should embed UnimplementedDiscoveryServiceV2Server for forward compatibility

type DiscoveryState 

type DiscoveryState int32
const (
	DiscoveryState_UNKNOWN  DiscoveryState = 0
	DiscoveryState_TRACKING DiscoveryState = 1
	DiscoveryState_COMPLETE DiscoveryState = 2
)

func (DiscoveryState) Descriptor 

func (DiscoveryState) Descriptor() protoreflect.EnumDescriptor

func (DiscoveryState) Enum 

func (x DiscoveryState) Enum() *DiscoveryState

func (DiscoveryState) EnumDescriptor deprecated 

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

Deprecated: Use DiscoveryState.Descriptor instead.

func (DiscoveryState) Number 

func (x DiscoveryState) Number() protoreflect.EnumNumber

func (DiscoveryState) String 

func (x DiscoveryState) String() string

func (DiscoveryState) Type 

func (DiscoveryState) Type() protoreflect.EnumType

type Empty 

type Empty struct {
	// contains filtered or unexported fields
}

func (*Empty) Descriptor deprecated 

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

Deprecated: Use Empty.ProtoReflect.Descriptor instead.

func (*Empty) ProtoMessage 

func (*Empty) ProtoMessage()

func (*Empty) ProtoReflect 

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

func (*Empty) Reset 

func (x *Empty) Reset()

func (*Empty) String 

func (x *Empty) String() string

type GetConfigRequest 

type GetConfigRequest struct {
	// contains filtered or unexported fields
}

func (*GetConfigRequest) Descriptor deprecated 

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

Deprecated: Use GetConfigRequest.ProtoReflect.Descriptor instead.

func (*GetConfigRequest) ProtoMessage 

func (*GetConfigRequest) ProtoMessage()

func (*GetConfigRequest) ProtoReflect 

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

func (*GetConfigRequest) Reset 

func (x *GetConfigRequest) Reset()

func (*GetConfigRequest) String 

func (x *GetConfigRequest) String() string

type GetConfigResponse 

type GetConfigResponse struct {
	Config *Config `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	// contains filtered or unexported fields
}

func (*GetConfigResponse) Descriptor deprecated 

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

Deprecated: Use GetConfigResponse.ProtoReflect.Descriptor instead.

func (*GetConfigResponse) GetConfig 

func (x *GetConfigResponse) GetConfig() *Config

func (*GetConfigResponse) ProtoMessage 

func (*GetConfigResponse) ProtoMessage()

func (*GetConfigResponse) ProtoReflect 

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

func (*GetConfigResponse) Reset 

func (x *GetConfigResponse) Reset()

func (*GetConfigResponse) String 

func (x *GetConfigResponse) String() string

type GetFriendsRequest 

type GetFriendsRequest struct {
	// contains filtered or unexported fields
}

func (*GetFriendsRequest) Descriptor deprecated 

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

Deprecated: Use GetFriendsRequest.ProtoReflect.Descriptor instead.

func (*GetFriendsRequest) ProtoMessage 

func (*GetFriendsRequest) ProtoMessage()

func (*GetFriendsRequest) ProtoReflect 

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

func (*GetFriendsRequest) Reset 

func (x *GetFriendsRequest) Reset()

func (*GetFriendsRequest) String 

func (x *GetFriendsRequest) String() string

type GetFriendsResponse 

type GetFriendsResponse struct {
	Friends []string `protobuf:"bytes,1,rep,name=friends,proto3" json:"friends,omitempty"`
	// contains filtered or unexported fields
}

func (*GetFriendsResponse) Descriptor deprecated 

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

Deprecated: Use GetFriendsResponse.ProtoReflect.Descriptor instead.

func (*GetFriendsResponse) GetFriends 

func (x *GetFriendsResponse) GetFriends() []string

func (*GetFriendsResponse) ProtoMessage 

func (*GetFriendsResponse) ProtoMessage()

func (*GetFriendsResponse) ProtoReflect 

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

func (*GetFriendsResponse) Reset 

func (x *GetFriendsResponse) Reset()

func (*GetFriendsResponse) String 

func (x *GetFriendsResponse) String() string

type GetRequest 

type GetRequest struct {
	Job    string `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	Server string `protobuf:"bytes,2,opt,name=server,proto3" json:"server,omitempty"`
	Friend string `protobuf:"bytes,3,opt,name=friend,proto3" json:"friend,omitempty"`
	// contains filtered or unexported fields
}

func (*GetRequest) Descriptor deprecated 

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

Deprecated: Use GetRequest.ProtoReflect.Descriptor instead.

func (*GetRequest) GetFriend 

func (x *GetRequest) GetFriend() string

func (*GetRequest) GetJob 

func (x *GetRequest) GetJob() string

func (*GetRequest) GetServer 

func (x *GetRequest) GetServer() string

func (*GetRequest) ProtoMessage 

func (*GetRequest) ProtoMessage()

func (*GetRequest) ProtoReflect 

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

func (*GetRequest) Reset 

func (x *GetRequest) Reset()

func (*GetRequest) String 

func (x *GetRequest) String() string

type GetResponse 

type GetResponse struct {
	Services []*RegistryEntry `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	State    DiscoveryState   `protobuf:"varint,2,opt,name=state,proto3,enum=discovery.DiscoveryState" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*GetResponse) Descriptor deprecated 

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

Deprecated: Use GetResponse.ProtoReflect.Descriptor instead.

func (*GetResponse) GetServices 

func (x *GetResponse) GetServices() []*RegistryEntry

func (*GetResponse) GetState 

func (x *GetResponse) GetState() DiscoveryState

func (*GetResponse) ProtoMessage 

func (*GetResponse) ProtoMessage()

func (*GetResponse) ProtoReflect 

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

func (*GetResponse) Reset 

func (x *GetResponse) Reset()

func (*GetResponse) String 

func (x *GetResponse) String() string

type GetStateRequest 

type GetStateRequest struct {
	// contains filtered or unexported fields
}

func (*GetStateRequest) Descriptor deprecated 

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

Deprecated: Use GetStateRequest.ProtoReflect.Descriptor instead.

func (*GetStateRequest) ProtoMessage 

func (*GetStateRequest) ProtoMessage()

func (*GetStateRequest) ProtoReflect 

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

func (*GetStateRequest) Reset 

func (x *GetStateRequest) Reset()

func (*GetStateRequest) String 

func (x *GetStateRequest) String() string

type GetStateResponse 

type GetStateResponse struct {
	State *InternalState `protobuf:"bytes,1,opt,name=state,proto3" json:"state,omitempty"`
	// contains filtered or unexported fields
}

func (*GetStateResponse) Descriptor deprecated 

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

Deprecated: Use GetStateResponse.ProtoReflect.Descriptor instead.

func (*GetStateResponse) GetState 

func (x *GetStateResponse) GetState() *InternalState

func (*GetStateResponse) ProtoMessage 

func (*GetStateResponse) ProtoMessage()

func (*GetStateResponse) ProtoReflect 

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

func (*GetStateResponse) Reset 

func (x *GetStateResponse) Reset()

func (*GetStateResponse) String 

func (x *GetStateResponse) String() string

type InternalState 

type InternalState struct {
	State    InternalState_ServingState `protobuf:"varint,1,opt,name=state,proto3,enum=discovery.InternalState_ServingState" json:"state,omitempty"`
	LastSeen int64                      `protobuf:"varint,2,opt,name=last_seen,json=lastSeen,proto3" json:"last_seen,omitempty"`
	// contains filtered or unexported fields
}

func (*InternalState) Descriptor deprecated 

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

Deprecated: Use InternalState.ProtoReflect.Descriptor instead.

func (*InternalState) GetLastSeen 

func (x *InternalState) GetLastSeen() int64

func (*InternalState) GetState 

func (x *InternalState) GetState() InternalState_ServingState

func (*InternalState) ProtoMessage 

func (*InternalState) ProtoMessage()

func (*InternalState) ProtoReflect 

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

func (*InternalState) Reset 

func (x *InternalState) Reset()

func (*InternalState) String 

func (x *InternalState) String() string

type InternalState_ServingState 

type InternalState_ServingState int32
const (
	InternalState_UNKNOWN     InternalState_ServingState = 0
	InternalState_SERVING     InternalState_ServingState = 1
	InternalState_NOT_SERVING InternalState_ServingState = 2
	InternalState_UNREACHABLE InternalState_ServingState = 3
)

func (InternalState_ServingState) Descriptor 

func (InternalState_ServingState) Descriptor() protoreflect.EnumDescriptor

func (InternalState_ServingState) Enum 

func (x InternalState_ServingState) Enum() *InternalState_ServingState

func (InternalState_ServingState) EnumDescriptor deprecated 

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

Deprecated: Use InternalState_ServingState.Descriptor instead.

func (InternalState_ServingState) Number 

func (x InternalState_ServingState) Number() protoreflect.EnumNumber

func (InternalState_ServingState) String 

func (x InternalState_ServingState) String() string

func (InternalState_ServingState) Type 

func (InternalState_ServingState) Type() protoreflect.EnumType

type ListRequest 

type ListRequest struct {
	Caller string `protobuf:"bytes,1,opt,name=caller,proto3" json:"caller,omitempty"`
	// contains filtered or unexported fields
}

func (*ListRequest) Descriptor deprecated 

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

Deprecated: Use ListRequest.ProtoReflect.Descriptor instead.

func (*ListRequest) GetCaller 

func (x *ListRequest) GetCaller() string

func (*ListRequest) ProtoMessage 

func (*ListRequest) ProtoMessage()

func (*ListRequest) ProtoReflect 

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

func (*ListRequest) Reset 

func (x *ListRequest) Reset()

func (*ListRequest) String 

func (x *ListRequest) String() string

type ListResponse 

type ListResponse struct {
	Services *ServiceList `protobuf:"bytes,1,opt,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*ListResponse) Descriptor deprecated 

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

Deprecated: Use ListResponse.ProtoReflect.Descriptor instead.

func (*ListResponse) GetServices 

func (x *ListResponse) GetServices() *ServiceList

func (*ListResponse) ProtoMessage 

func (*ListResponse) ProtoMessage()

func (*ListResponse) ProtoReflect 

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

func (*ListResponse) Reset 

func (x *ListResponse) Reset()

func (*ListResponse) String 

func (x *ListResponse) String() string

type LockRequest 

type LockRequest struct {
	Job       string `protobuf:"bytes,1,opt,name=job,proto3" json:"job,omitempty"`
	LockKey   int64  `protobuf:"varint,2,opt,name=lock_key,json=lockKey,proto3" json:"lock_key,omitempty"`
	Requestor string `protobuf:"bytes,3,opt,name=requestor,proto3" json:"requestor,omitempty"`
	// contains filtered or unexported fields
}

func (*LockRequest) Descriptor deprecated 

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

Deprecated: Use LockRequest.ProtoReflect.Descriptor instead.

func (*LockRequest) GetJob 

func (x *LockRequest) GetJob() string

func (*LockRequest) GetLockKey 

func (x *LockRequest) GetLockKey() int64

func (*LockRequest) GetRequestor 

func (x *LockRequest) GetRequestor() string

func (*LockRequest) ProtoMessage 

func (*LockRequest) ProtoMessage()

func (*LockRequest) ProtoReflect 

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

func (*LockRequest) Reset 

func (x *LockRequest) Reset()

func (*LockRequest) String 

func (x *LockRequest) String() string

type LockResponse 

type LockResponse struct {
	// contains filtered or unexported fields
}

func (*LockResponse) Descriptor deprecated 

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

Deprecated: Use LockResponse.ProtoReflect.Descriptor instead.

func (*LockResponse) ProtoMessage 

func (*LockResponse) ProtoMessage()

func (*LockResponse) ProtoReflect 

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

func (*LockResponse) Reset 

func (x *LockResponse) Reset()

func (*LockResponse) String 

func (x *LockResponse) String() string

type MasterRequest 

type MasterRequest struct {
	Service     *RegistryEntry `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	LockKey     int64          `protobuf:"varint,2,opt,name=lock_key,json=lockKey,proto3" json:"lock_key,omitempty"`
	MasterElect bool           `protobuf:"varint,3,opt,name=master_elect,json=masterElect,proto3" json:"master_elect,omitempty"`
	Fanout      bool           `protobuf:"varint,4,opt,name=fanout,proto3" json:"fanout,omitempty"`
	// contains filtered or unexported fields
}

func (*MasterRequest) Descriptor deprecated 

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

Deprecated: Use MasterRequest.ProtoReflect.Descriptor instead.

func (*MasterRequest) GetFanout 

func (x *MasterRequest) GetFanout() bool

func (*MasterRequest) GetLockKey 

func (x *MasterRequest) GetLockKey() int64

func (*MasterRequest) GetMasterElect 

func (x *MasterRequest) GetMasterElect() bool

func (*MasterRequest) GetService 

func (x *MasterRequest) GetService() *RegistryEntry

func (*MasterRequest) ProtoMessage 

func (*MasterRequest) ProtoMessage()

func (*MasterRequest) ProtoReflect 

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

func (*MasterRequest) Reset 

func (x *MasterRequest) Reset()

func (*MasterRequest) String 

func (x *MasterRequest) String() string

type MasterResponse 

type MasterResponse struct {
	Service *RegistryEntry `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*MasterResponse) Descriptor deprecated 

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

Deprecated: Use MasterResponse.ProtoReflect.Descriptor instead.

func (*MasterResponse) GetService 

func (x *MasterResponse) GetService() *RegistryEntry

func (*MasterResponse) ProtoMessage 

func (*MasterResponse) ProtoMessage()

func (*MasterResponse) ProtoReflect 

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

func (*MasterResponse) Reset 

func (x *MasterResponse) Reset()

func (*MasterResponse) String 

func (x *MasterResponse) String() string

type RegisterRequest 

type RegisterRequest struct {
	Service *RegistryEntry `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Caller  string         `protobuf:"bytes,2,opt,name=caller,proto3" json:"caller,omitempty"`
	Fanout  bool           `protobuf:"varint,4,opt,name=fanout,proto3" json:"fanout,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterRequest) Descriptor deprecated 

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

Deprecated: Use RegisterRequest.ProtoReflect.Descriptor instead.

func (*RegisterRequest) GetCaller 

func (x *RegisterRequest) GetCaller() string

func (*RegisterRequest) GetFanout 

func (x *RegisterRequest) GetFanout() bool

func (*RegisterRequest) GetService 

func (x *RegisterRequest) GetService() *RegistryEntry

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) ProtoReflect 

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

func (*RegisterRequest) Reset 

func (x *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (x *RegisterRequest) String() string

type RegisterResponse 

type RegisterResponse struct {
	Service *RegistryEntry `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// contains filtered or unexported fields
}

func (*RegisterResponse) Descriptor deprecated 

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

Deprecated: Use RegisterResponse.ProtoReflect.Descriptor instead.

func (*RegisterResponse) GetService 

func (x *RegisterResponse) GetService() *RegistryEntry

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) ProtoReflect 

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

func (*RegisterResponse) Reset 

func (x *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (x *RegisterResponse) String() string

type RegistryEntry 

type RegistryEntry struct {

	// The ip address associated with this entry
	Ip string `protobuf:"bytes,1,opt,name=ip,proto3" json:"ip,omitempty"`
	// The port number assigned / requested for this entry
	Port int32 `protobuf:"varint,2,opt,name=port,proto3" json:"port,omitempty"`
	// The name of this service
	Name string `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	// Is this an external facing port
	ExternalPort bool `protobuf:"varint,4,opt,name=external_port,json=externalPort,proto3" json:"external_port,omitempty"`
	// This is the machine identifier
	Identifier string `protobuf:"bytes,5,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// The time at which this binary was registered
	RegisterTime int64 `protobuf:"varint,7,opt,name=register_time,json=registerTime,proto3" json:"register_time,omitempty"`
	// The time at which this binary should be cleaned
	TimeToClean int64 `protobuf:"varint,8,opt,name=time_to_clean,json=timeToClean,proto3" json:"time_to_clean,omitempty"`
	// The time at which this binary was last seen
	LastSeenTime int64 `protobuf:"varint,9,opt,name=last_seen_time,json=lastSeenTime,proto3" json:"last_seen_time,omitempty"`
	// The time at which we were set master
	MasterTime int64                 `protobuf:"varint,11,opt,name=master_time,json=masterTime,proto3" json:"master_time,omitempty"`
	Version    RegistryEntry_Version `protobuf:"varint,13,opt,name=version,proto3,enum=discovery.RegistryEntry_Version" json:"version,omitempty"`
	Zone       string                `protobuf:"bytes,14,opt,name=zone,proto3" json:"zone,omitempty"`
	// contains filtered or unexported fields
}

func (*RegistryEntry) Descriptor deprecated 

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

Deprecated: Use RegistryEntry.ProtoReflect.Descriptor instead.

func (*RegistryEntry) GetExternalPort 

func (x *RegistryEntry) GetExternalPort() bool

func (*RegistryEntry) GetIdentifier 

func (x *RegistryEntry) GetIdentifier() string

func (*RegistryEntry) GetIp 

func (x *RegistryEntry) GetIp() string

func (*RegistryEntry) GetLastSeenTime 

func (x *RegistryEntry) GetLastSeenTime() int64

func (*RegistryEntry) GetMasterTime 

func (x *RegistryEntry) GetMasterTime() int64

func (*RegistryEntry) GetName 

func (x *RegistryEntry) GetName() string

func (*RegistryEntry) GetPort 

func (x *RegistryEntry) GetPort() int32

func (*RegistryEntry) GetRegisterTime 

func (x *RegistryEntry) GetRegisterTime() int64

func (*RegistryEntry) GetTimeToClean 

func (x *RegistryEntry) GetTimeToClean() int64

func (*RegistryEntry) GetVersion 

func (x *RegistryEntry) GetVersion() RegistryEntry_Version

func (*RegistryEntry) GetZone 

func (x *RegistryEntry) GetZone() string

func (*RegistryEntry) ProtoMessage 

func (*RegistryEntry) ProtoMessage()

func (*RegistryEntry) ProtoReflect 

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

func (*RegistryEntry) Reset 

func (x *RegistryEntry) Reset()

func (*RegistryEntry) String 

func (x *RegistryEntry) String() string

type RegistryEntry_Version 

type RegistryEntry_Version int32
const (
	RegistryEntry_V1 RegistryEntry_Version = 0
	RegistryEntry_V2 RegistryEntry_Version = 1
)

func (RegistryEntry_Version) Descriptor 

func (RegistryEntry_Version) Descriptor() protoreflect.EnumDescriptor

func (RegistryEntry_Version) Enum 

func (x RegistryEntry_Version) Enum() *RegistryEntry_Version

func (RegistryEntry_Version) EnumDescriptor deprecated 

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

Deprecated: Use RegistryEntry_Version.Descriptor instead.

func (RegistryEntry_Version) Number 

func (x RegistryEntry_Version) Number() protoreflect.EnumNumber

func (RegistryEntry_Version) String 

func (x RegistryEntry_Version) String() string

func (RegistryEntry_Version) Type 

func (RegistryEntry_Version) Type() protoreflect.EnumType

type ServiceList 

type ServiceList struct {
	Services []*RegistryEntry `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	// contains filtered or unexported fields
}

func (*ServiceList) Descriptor deprecated 

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

Deprecated: Use ServiceList.ProtoReflect.Descriptor instead.

func (*ServiceList) GetServices 

func (x *ServiceList) GetServices() []*RegistryEntry

func (*ServiceList) ProtoMessage 

func (*ServiceList) ProtoMessage()

func (*ServiceList) ProtoReflect 

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

func (*ServiceList) Reset 

func (x *ServiceList) Reset()

func (*ServiceList) String 

func (x *ServiceList) String() string

type SetZoneRequest 

type SetZoneRequest struct {
	Zone string `protobuf:"bytes,1,opt,name=zone,proto3" json:"zone,omitempty"`
	// contains filtered or unexported fields
}

func (*SetZoneRequest) Descriptor deprecated 

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

Deprecated: Use SetZoneRequest.ProtoReflect.Descriptor instead.

func (*SetZoneRequest) GetZone 

func (x *SetZoneRequest) GetZone() string

func (*SetZoneRequest) ProtoMessage 

func (*SetZoneRequest) ProtoMessage()

func (*SetZoneRequest) ProtoReflect 

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

func (*SetZoneRequest) Reset 

func (x *SetZoneRequest) Reset()

func (*SetZoneRequest) String 

func (x *SetZoneRequest) String() string

type SetZoneResponse 

type SetZoneResponse struct {
	// contains filtered or unexported fields
}

func (*SetZoneResponse) Descriptor deprecated 

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

Deprecated: Use SetZoneResponse.ProtoReflect.Descriptor instead.

func (*SetZoneResponse) ProtoMessage 

func (*SetZoneResponse) ProtoMessage()

func (*SetZoneResponse) ProtoReflect 

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

func (*SetZoneResponse) Reset 

func (x *SetZoneResponse) Reset()

func (*SetZoneResponse) String 

func (x *SetZoneResponse) String() string

type StateRequest 

type StateRequest struct {
	// contains filtered or unexported fields
}

func (*StateRequest) Descriptor deprecated 

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

Deprecated: Use StateRequest.ProtoReflect.Descriptor instead.

func (*StateRequest) ProtoMessage 

func (*StateRequest) ProtoMessage()

func (*StateRequest) ProtoReflect 

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

func (*StateRequest) Reset 

func (x *StateRequest) Reset()

func (*StateRequest) String 

func (x *StateRequest) String() string

type StateResponse 

type StateResponse struct {
	LongestCall  int64  `protobuf:"varint,1,opt,name=longest_call,json=longestCall,proto3" json:"longest_call,omitempty"`
	MostFrequent string `protobuf:"bytes,2,opt,name=most_frequent,json=mostFrequent,proto3" json:"most_frequent,omitempty"`
	Frequency    int32  `protobuf:"varint,3,opt,name=frequency,proto3" json:"frequency,omitempty"`
	Count        string `protobuf:"bytes,4,opt,name=count,proto3" json:"count,omitempty"`
	// contains filtered or unexported fields
}

func (*StateResponse) Descriptor deprecated 

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

Deprecated: Use StateResponse.ProtoReflect.Descriptor instead.

func (*StateResponse) GetCount 

func (x *StateResponse) GetCount() string

func (*StateResponse) GetFrequency 

func (x *StateResponse) GetFrequency() int32

func (*StateResponse) GetLongestCall 

func (x *StateResponse) GetLongestCall() int64

func (*StateResponse) GetMostFrequent 

func (x *StateResponse) GetMostFrequent() string

func (*StateResponse) ProtoMessage 

func (*StateResponse) ProtoMessage()

func (*StateResponse) ProtoReflect 

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

func (*StateResponse) Reset 

func (x *StateResponse) Reset()

func (*StateResponse) String 

func (x *StateResponse) String() string

type UnimplementedDiscoveryServiceServer 

type UnimplementedDiscoveryServiceServer struct {
}

UnimplementedDiscoveryServiceServer should be embedded to have forward compatible implementations.

func (UnimplementedDiscoveryServiceServer) Discover 

func (UnimplementedDiscoveryServiceServer) Discover(context.Context, *DiscoverRequest) (*DiscoverResponse, error)

func (UnimplementedDiscoveryServiceServer) ListAllServices 

func (UnimplementedDiscoveryServiceServer) ListAllServices(context.Context, *ListRequest) (*ListResponse, error)

func (UnimplementedDiscoveryServiceServer) RegisterService 

func (UnimplementedDiscoveryServiceServer) RegisterService(context.Context, *RegisterRequest) (*RegisterResponse, error)

func (UnimplementedDiscoveryServiceServer) State 

func (UnimplementedDiscoveryServiceServer) State(context.Context, *StateRequest) (*StateResponse, error)

type UnimplementedDiscoveryServiceV2Server 

type UnimplementedDiscoveryServiceV2Server struct {
}

UnimplementedDiscoveryServiceV2Server should be embedded to have forward compatible implementations.

func (UnimplementedDiscoveryServiceV2Server) Get 

func (UnimplementedDiscoveryServiceV2Server) Get(context.Context, *GetRequest) (*GetResponse, error)

func (UnimplementedDiscoveryServiceV2Server) GetConfig 

func (UnimplementedDiscoveryServiceV2Server) GetConfig(context.Context, *GetConfigRequest) (*GetConfigResponse, error)

func (UnimplementedDiscoveryServiceV2Server) GetFriends 

func (UnimplementedDiscoveryServiceV2Server) GetFriends(context.Context, *GetFriendsRequest) (*GetFriendsResponse, error)

func (UnimplementedDiscoveryServiceV2Server) GetInternalState 

func (UnimplementedDiscoveryServiceV2Server) GetInternalState(context.Context, *GetStateRequest) (*GetStateResponse, error)

func (UnimplementedDiscoveryServiceV2Server) Lock 

func (UnimplementedDiscoveryServiceV2Server) Lock(context.Context, *LockRequest) (*LockResponse, error)

func (UnimplementedDiscoveryServiceV2Server) RegisterV2 

func (UnimplementedDiscoveryServiceV2Server) RegisterV2(context.Context, *RegisterRequest) (*RegisterResponse, error)

func (UnimplementedDiscoveryServiceV2Server) SetZone 

func (UnimplementedDiscoveryServiceV2Server) SetZone(context.Context, *SetZoneRequest) (*SetZoneResponse, error)

func (UnimplementedDiscoveryServiceV2Server) Unregister 

func (UnimplementedDiscoveryServiceV2Server) Unregister(context.Context, *UnregisterRequest) (*UnregisterResponse, error)

type UnregisterRequest 

type UnregisterRequest struct {
	Service *RegistryEntry `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	Address string         `protobuf:"bytes,3,opt,name=address,proto3" json:"address,omitempty"`
	Caller  string         `protobuf:"bytes,4,opt,name=caller,proto3" json:"caller,omitempty"`
	Fanout  bool           `protobuf:"varint,2,opt,name=fanout,proto3" json:"fanout,omitempty"`
	Reason  string         `protobuf:"bytes,5,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*UnregisterRequest) Descriptor deprecated 

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

Deprecated: Use UnregisterRequest.ProtoReflect.Descriptor instead.

func (*UnregisterRequest) GetAddress 

func (x *UnregisterRequest) GetAddress() string

func (*UnregisterRequest) GetCaller 

func (x *UnregisterRequest) GetCaller() string

func (*UnregisterRequest) GetFanout 

func (x *UnregisterRequest) GetFanout() bool

func (*UnregisterRequest) GetReason 

func (x *UnregisterRequest) GetReason() string

func (*UnregisterRequest) GetService 

func (x *UnregisterRequest) GetService() *RegistryEntry

func (*UnregisterRequest) ProtoMessage 

func (*UnregisterRequest) ProtoMessage()

func (*UnregisterRequest) ProtoReflect 

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

func (*UnregisterRequest) Reset 

func (x *UnregisterRequest) Reset()

func (*UnregisterRequest) String 

func (x *UnregisterRequest) String() string

type UnregisterResponse 

type UnregisterResponse struct {
	// contains filtered or unexported fields
}

func (*UnregisterResponse) Descriptor deprecated 

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

Deprecated: Use UnregisterResponse.ProtoReflect.Descriptor instead.

func (*UnregisterResponse) ProtoMessage 

func (*UnregisterResponse) ProtoMessage()

func (*UnregisterResponse) ProtoReflect 

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

func (*UnregisterResponse) Reset 

func (x *UnregisterResponse) Reset()

func (*UnregisterResponse) String 

func (x *UnregisterResponse) String() string

type UnsafeDiscoveryServiceServer 

type UnsafeDiscoveryServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeDiscoveryServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DiscoveryServiceServer will result in compilation errors.

type UnsafeDiscoveryServiceV2Server 

type UnsafeDiscoveryServiceV2Server interface {
	// contains filtered or unexported methods
}

UnsafeDiscoveryServiceV2Server may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DiscoveryServiceV2Server will result in compilation errors.

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.