go_micro_srv_discovery_registry

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

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