proto

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

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
}

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

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

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

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

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

type DiscoveryState int32

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

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

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

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

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

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
}

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
}

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

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

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
}

type InternalState_ServingState int32

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

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

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
}

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

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
}

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

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
}

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

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
}

type RegistryEntry_Version int32

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

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

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

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

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
}

type UnimplementedDiscoveryServiceServer struct {
}

type UnimplementedDiscoveryServiceV2Server struct {
}

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
}

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

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

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