Documentation
¶
Overview ¶
Package go_micro_srv_discovery_discovery is a generated protocol buffer package.
It is generated from these files:
github.com/micro/discovery-srv/proto/discovery/discovery.proto
It has these top-level messages:
ServiceEndpoint EndpointsRequest EndpointsResponse HeartbeatsRequest HeartbeatsResponse WatchResultsRequest WatchResultsResponse
Index ¶
- func RegisterDiscoveryHandler(s server.Server, hdlr DiscoveryHandler)
- type Discovery
- func (h *Discovery) Endpoints(ctx context.Context, in *EndpointsRequest, out *EndpointsResponse) error
- func (h *Discovery) Heartbeats(ctx context.Context, in *HeartbeatsRequest, out *HeartbeatsResponse) error
- func (h *Discovery) WatchResults(ctx context.Context, in *WatchResultsRequest, out *WatchResultsResponse) error
- type DiscoveryClient
- type DiscoveryHandler
- type EndpointsRequest
- type EndpointsResponse
- type HeartbeatsRequest
- type HeartbeatsResponse
- type ServiceEndpoint
- type WatchResultsRequest
- type WatchResultsResponse
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func RegisterDiscoveryHandler ¶
func RegisterDiscoveryHandler(s server.Server, hdlr DiscoveryHandler)
Types ¶
type Discovery ¶
type Discovery struct {
DiscoveryHandler
}
func (*Discovery) Endpoints ¶
func (h *Discovery) Endpoints(ctx context.Context, in *EndpointsRequest, out *EndpointsResponse) error
func (*Discovery) Heartbeats ¶
func (h *Discovery) Heartbeats(ctx context.Context, in *HeartbeatsRequest, out *HeartbeatsResponse) error
func (*Discovery) WatchResults ¶
func (h *Discovery) WatchResults(ctx context.Context, in *WatchResultsRequest, out *WatchResultsResponse) error
type DiscoveryClient ¶
type DiscoveryClient interface {
Endpoints(ctx context.Context, in *EndpointsRequest, opts ...client.CallOption) (*EndpointsResponse, error)
Heartbeats(ctx context.Context, in *HeartbeatsRequest, opts ...client.CallOption) (*HeartbeatsResponse, error)
WatchResults(ctx context.Context, in *WatchResultsRequest, opts ...client.CallOption) (*WatchResultsResponse, error)
}
func NewDiscoveryClient ¶
func NewDiscoveryClient(serviceName string, c client.Client) DiscoveryClient
type DiscoveryHandler ¶
type DiscoveryHandler interface {
Endpoints(context.Context, *EndpointsRequest, *EndpointsResponse) error
Heartbeats(context.Context, *HeartbeatsRequest, *HeartbeatsResponse) error
WatchResults(context.Context, *WatchResultsRequest, *WatchResultsResponse) error
}
type EndpointsRequest ¶
type EndpointsRequest struct {
Service string `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
Version string `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
Limit uint64 `protobuf:"varint,3,opt,name=limit" json:"limit,omitempty"`
Offset uint64 `protobuf:"varint,4,opt,name=offset" json:"offset,omitempty"`
}
func (*EndpointsRequest) Descriptor ¶
func (*EndpointsRequest) Descriptor() ([]byte, []int)
func (*EndpointsRequest) ProtoMessage ¶
func (*EndpointsRequest) ProtoMessage()
func (*EndpointsRequest) Reset ¶
func (m *EndpointsRequest) Reset()
func (*EndpointsRequest) String ¶
func (m *EndpointsRequest) String() string
type EndpointsResponse ¶
type EndpointsResponse struct {
Endpoints []*ServiceEndpoint `protobuf:"bytes,1,rep,name=endpoints" json:"endpoints,omitempty"`
}
func (*EndpointsResponse) Descriptor ¶
func (*EndpointsResponse) Descriptor() ([]byte, []int)
func (*EndpointsResponse) GetEndpoints ¶
func (m *EndpointsResponse) GetEndpoints() []*ServiceEndpoint
func (*EndpointsResponse) ProtoMessage ¶
func (*EndpointsResponse) ProtoMessage()
func (*EndpointsResponse) Reset ¶
func (m *EndpointsResponse) Reset()
func (*EndpointsResponse) String ¶
func (m *EndpointsResponse) String() string
type HeartbeatsRequest ¶
type HeartbeatsRequest struct {
Id string `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
After uint64 `protobuf:"varint,2,opt,name=after" json:"after,omitempty"`
Limit uint64 `protobuf:"varint,3,opt,name=limit" json:"limit,omitempty"`
Offset uint64 `protobuf:"varint,4,opt,name=offset" json:"offset,omitempty"`
}
func (*HeartbeatsRequest) Descriptor ¶
func (*HeartbeatsRequest) Descriptor() ([]byte, []int)
func (*HeartbeatsRequest) ProtoMessage ¶
func (*HeartbeatsRequest) ProtoMessage()
func (*HeartbeatsRequest) Reset ¶
func (m *HeartbeatsRequest) Reset()
func (*HeartbeatsRequest) String ¶
func (m *HeartbeatsRequest) String() string
type HeartbeatsResponse ¶
type HeartbeatsResponse struct {
Heartbeats []*discovery.Heartbeat `protobuf:"bytes,1,rep,name=heartbeats" json:"heartbeats,omitempty"`
}
func (*HeartbeatsResponse) Descriptor ¶
func (*HeartbeatsResponse) Descriptor() ([]byte, []int)
func (*HeartbeatsResponse) GetHeartbeats ¶
func (m *HeartbeatsResponse) GetHeartbeats() []*discovery.Heartbeat
func (*HeartbeatsResponse) ProtoMessage ¶
func (*HeartbeatsResponse) ProtoMessage()
func (*HeartbeatsResponse) Reset ¶
func (m *HeartbeatsResponse) Reset()
func (*HeartbeatsResponse) String ¶
func (m *HeartbeatsResponse) String() string
type ServiceEndpoint ¶
type ServiceEndpoint struct {
Service string `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
Version string `protobuf:"bytes,2,opt,name=version" json:"version,omitempty"`
Endpoint *discovery.Endpoint `protobuf:"bytes,3,opt,name=endpoint" json:"endpoint,omitempty"`
}
func (*ServiceEndpoint) Descriptor ¶
func (*ServiceEndpoint) Descriptor() ([]byte, []int)
func (*ServiceEndpoint) GetEndpoint ¶
func (m *ServiceEndpoint) GetEndpoint() *discovery.Endpoint
func (*ServiceEndpoint) ProtoMessage ¶
func (*ServiceEndpoint) ProtoMessage()
func (*ServiceEndpoint) Reset ¶
func (m *ServiceEndpoint) Reset()
func (*ServiceEndpoint) String ¶
func (m *ServiceEndpoint) String() string
type WatchResultsRequest ¶
type WatchResultsRequest struct {
Service string `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
After uint64 `protobuf:"varint,2,opt,name=after" json:"after,omitempty"`
Limit uint64 `protobuf:"varint,3,opt,name=limit" json:"limit,omitempty"`
Offset uint64 `protobuf:"varint,4,opt,name=offset" json:"offset,omitempty"`
}
func (*WatchResultsRequest) Descriptor ¶
func (*WatchResultsRequest) Descriptor() ([]byte, []int)
func (*WatchResultsRequest) ProtoMessage ¶
func (*WatchResultsRequest) ProtoMessage()
func (*WatchResultsRequest) Reset ¶
func (m *WatchResultsRequest) Reset()
func (*WatchResultsRequest) String ¶
func (m *WatchResultsRequest) String() string
type WatchResultsResponse ¶
type WatchResultsResponse struct {
Results []*discovery.Result `protobuf:"bytes,1,rep,name=results" json:"results,omitempty"`
}
func (*WatchResultsResponse) Descriptor ¶
func (*WatchResultsResponse) Descriptor() ([]byte, []int)
func (*WatchResultsResponse) GetResults ¶
func (m *WatchResultsResponse) GetResults() []*discovery.Result
func (*WatchResultsResponse) ProtoMessage ¶
func (*WatchResultsResponse) ProtoMessage()
func (*WatchResultsResponse) Reset ¶
func (m *WatchResultsResponse) Reset()
func (*WatchResultsResponse) String ¶
func (m *WatchResultsResponse) String() string
Source Files
Click to show internal directories.
Click to hide internal directories.