go_micro_srv_discovery_registry

package
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_registry is a generated protocol buffer package.

It is generated from these files: 

github.com/micro/discovery-srv/proto/registry/registry.proto

It has these top-level messages: 

RegisterRequest
RegisterResponse
DeregisterRequest
DeregisterResponse
GetServiceRequest
GetServiceResponse
ListServicesRequest
ListServicesResponse
WatchRequest
WatchResponse

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRegistryHandler 

func RegisterRegistryHandler(s server.Server, hdlr RegistryHandler)

Types

type DeregisterRequest 

type DeregisterRequest struct {
	Service *discovery.Service `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
}

func (*DeregisterRequest) Descriptor 

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

func (*DeregisterRequest) GetService 

func (m *DeregisterRequest) GetService() *discovery.Service

func (*DeregisterRequest) ProtoMessage 

func (*DeregisterRequest) ProtoMessage()

func (*DeregisterRequest) Reset 

func (m *DeregisterRequest) Reset()

func (*DeregisterRequest) String 

func (m *DeregisterRequest) String() string

type DeregisterResponse 

type DeregisterResponse struct {
}

func (*DeregisterResponse) Descriptor 

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

func (*DeregisterResponse) ProtoMessage 

func (*DeregisterResponse) ProtoMessage()

func (*DeregisterResponse) Reset 

func (m *DeregisterResponse) Reset()

func (*DeregisterResponse) String 

func (m *DeregisterResponse) String() string

type GetServiceRequest 

type GetServiceRequest struct {
	Service string `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
}

func (*GetServiceRequest) Descriptor 

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

func (*GetServiceRequest) ProtoMessage 

func (*GetServiceRequest) ProtoMessage()

func (*GetServiceRequest) Reset 

func (m *GetServiceRequest) Reset()

func (*GetServiceRequest) String 

func (m *GetServiceRequest) String() string

type GetServiceResponse 

type GetServiceResponse struct {
	Services []*discovery.Service `protobuf:"bytes,1,rep,name=services" json:"services,omitempty"`
}

func (*GetServiceResponse) Descriptor 

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

func (*GetServiceResponse) GetServices 

func (m *GetServiceResponse) GetServices() []*discovery.Service

func (*GetServiceResponse) ProtoMessage 

func (*GetServiceResponse) ProtoMessage()

func (*GetServiceResponse) Reset 

func (m *GetServiceResponse) Reset()

func (*GetServiceResponse) String 

func (m *GetServiceResponse) String() string

type ListServicesRequest 

type ListServicesRequest struct {
}

func (*ListServicesRequest) Descriptor 

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

func (*ListServicesRequest) ProtoMessage 

func (*ListServicesRequest) ProtoMessage()

func (*ListServicesRequest) Reset 

func (m *ListServicesRequest) Reset()

func (*ListServicesRequest) String 

func (m *ListServicesRequest) String() string

type ListServicesResponse 

type ListServicesResponse struct {
	Services []*discovery.Service `protobuf:"bytes,1,rep,name=services" json:"services,omitempty"`
}

func (*ListServicesResponse) Descriptor 

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

func (*ListServicesResponse) GetServices 

func (m *ListServicesResponse) GetServices() []*discovery.Service

func (*ListServicesResponse) ProtoMessage 

func (*ListServicesResponse) ProtoMessage()

func (*ListServicesResponse) Reset 

func (m *ListServicesResponse) Reset()

func (*ListServicesResponse) String 

func (m *ListServicesResponse) String() string

type RegisterRequest 

type RegisterRequest struct {
	Service *discovery.Service `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
}

func (*RegisterRequest) Descriptor 

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

func (*RegisterRequest) GetService 

func (m *RegisterRequest) GetService() *discovery.Service

func (*RegisterRequest) ProtoMessage 

func (*RegisterRequest) ProtoMessage()

func (*RegisterRequest) Reset 

func (m *RegisterRequest) Reset()

func (*RegisterRequest) String 

func (m *RegisterRequest) String() string

type RegisterResponse 

type RegisterResponse struct {
}

func (*RegisterResponse) Descriptor 

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

func (*RegisterResponse) ProtoMessage 

func (*RegisterResponse) ProtoMessage()

func (*RegisterResponse) Reset 

func (m *RegisterResponse) Reset()

func (*RegisterResponse) String 

func (m *RegisterResponse) String() string

type Registry 

type Registry struct {
	RegistryHandler
}

func (*Registry) Deregister 

func (h *Registry) Deregister(ctx context.Context, in *DeregisterRequest, out *DeregisterResponse) error

func (*Registry) GetService 

func (h *Registry) GetService(ctx context.Context, in *GetServiceRequest, out *GetServiceResponse) error

func (*Registry) ListServices 

func (h *Registry) ListServices(ctx context.Context, in *ListServicesRequest, out *ListServicesResponse) error

func (*Registry) Register 

func (h *Registry) Register(ctx context.Context, in *RegisterRequest, out *RegisterResponse) error

func (*Registry) Watch 

func (h *Registry) Watch(ctx context.Context, stream server.Streamer) error

type RegistryClient 

type RegistryClient interface {
	Register(ctx context.Context, in *RegisterRequest, opts ...client.CallOption) (*RegisterResponse, error)
	Deregister(ctx context.Context, in *DeregisterRequest, opts ...client.CallOption) (*DeregisterResponse, error)
	GetService(ctx context.Context, in *GetServiceRequest, opts ...client.CallOption) (*GetServiceResponse, error)
	ListServices(ctx context.Context, in *ListServicesRequest, opts ...client.CallOption) (*ListServicesResponse, error)
	Watch(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Registry_WatchClient, error)
}

func NewRegistryClient 

func NewRegistryClient(serviceName string, c client.Client) RegistryClient

type RegistryHandler 

type RegistryHandler interface {
	Register(context.Context, *RegisterRequest, *RegisterResponse) error
	Deregister(context.Context, *DeregisterRequest, *DeregisterResponse) error
	GetService(context.Context, *GetServiceRequest, *GetServiceResponse) error
	ListServices(context.Context, *ListServicesRequest, *ListServicesResponse) error
	Watch(context.Context, *WatchRequest, Registry_WatchStream) error
}

type Registry_WatchClient 

type Registry_WatchClient interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Recv() (*WatchResponse, error)
}

type Registry_WatchStream 

type Registry_WatchStream interface {
	SendMsg(interface{}) error
	RecvMsg(interface{}) error
	Close() error
	Send(*WatchResponse) error
}

type WatchRequest 

type WatchRequest struct {
	Service string `protobuf:"bytes,1,opt,name=service" json:"service,omitempty"`
}

func (*WatchRequest) Descriptor 

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

func (*WatchRequest) ProtoMessage 

func (*WatchRequest) ProtoMessage()

func (*WatchRequest) Reset 

func (m *WatchRequest) Reset()

func (*WatchRequest) String 

func (m *WatchRequest) String() string

type WatchResponse 

type WatchResponse struct {
	Result *discovery.Result `protobuf:"bytes,1,opt,name=result" json:"result,omitempty"`
}

func (*WatchResponse) Descriptor 

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

func (*WatchResponse) GetResult 

func (m *WatchResponse) GetResult() *discovery.Result

func (*WatchResponse) ProtoMessage 

func (*WatchResponse) ProtoMessage()

func (*WatchResponse) Reset 

func (m *WatchResponse) Reset()

func (*WatchResponse) String 

func (m *WatchResponse) String() string

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.