go_micro_srv_discovery_discovery

package
Version: v0.0.0-...-4a97e6e Latest Latest
Warning

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

Go to latest
Published: May 16, 2016 License: Apache-2.0 Imports: 7 Imported by: 0

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

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
t or T : Toggle theme light dark auto
y or Y : Canonical URL