go_micro_srv_discovery_discovery

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
  • func NewDiscoveryClient(serviceName string, c client.Client) DiscoveryClient
• type DiscoveryHandler
• type EndpointsRequest
  • func (*EndpointsRequest) Descriptor() ([]byte, []int)
  • func (*EndpointsRequest) ProtoMessage()
  • func (m *EndpointsRequest) Reset()
  • func (m *EndpointsRequest) String() string
• type EndpointsResponse
  • func (*EndpointsResponse) Descriptor() ([]byte, []int)
  • func (m *EndpointsResponse) GetEndpoints() []*ServiceEndpoint
  • func (*EndpointsResponse) ProtoMessage()
  • func (m *EndpointsResponse) Reset()
  • func (m *EndpointsResponse) String() string
• type HeartbeatsRequest
  • func (*HeartbeatsRequest) Descriptor() ([]byte, []int)
  • func (*HeartbeatsRequest) ProtoMessage()
  • func (m *HeartbeatsRequest) Reset()
  • func (m *HeartbeatsRequest) String() string
• type HeartbeatsResponse
  • func (*HeartbeatsResponse) Descriptor() ([]byte, []int)
  • func (m *HeartbeatsResponse) GetHeartbeats() []*discovery.Heartbeat
  • func (*HeartbeatsResponse) ProtoMessage()
  • func (m *HeartbeatsResponse) Reset()
  • func (m *HeartbeatsResponse) String() string
• type ServiceEndpoint
  • func (*ServiceEndpoint) Descriptor() ([]byte, []int)
  • func (m *ServiceEndpoint) GetEndpoint() *discovery.Endpoint
  • func (*ServiceEndpoint) ProtoMessage()
  • func (m *ServiceEndpoint) Reset()
  • func (m *ServiceEndpoint) String() string
• type WatchResultsRequest
  • func (*WatchResultsRequest) Descriptor() ([]byte, []int)
  • func (*WatchResultsRequest) ProtoMessage()
  • func (m *WatchResultsRequest) Reset()
  • func (m *WatchResultsRequest) String() string
• type WatchResultsResponse
  • func (*WatchResultsResponse) Descriptor() ([]byte, []int)
  • func (m *WatchResultsResponse) GetResults() []*discovery.Result
  • func (*WatchResultsResponse) ProtoMessage()
  • func (m *WatchResultsResponse) Reset()
  • func (m *WatchResultsResponse) String() string

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