go_micro_srv_discovery_registry

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

• func RegisterRegistryHandler(s server.Server, hdlr RegistryHandler)
• type DeregisterRequest
  • func (*DeregisterRequest) Descriptor() ([]byte, []int)
  • func (m *DeregisterRequest) GetService() *discovery.Service
  • func (*DeregisterRequest) ProtoMessage()
  • func (m *DeregisterRequest) Reset()
  • func (m *DeregisterRequest) String() string
• type DeregisterResponse
  • func (*DeregisterResponse) Descriptor() ([]byte, []int)
  • func (*DeregisterResponse) ProtoMessage()
  • func (m *DeregisterResponse) Reset()
  • func (m *DeregisterResponse) String() string
• type GetServiceRequest
  • func (*GetServiceRequest) Descriptor() ([]byte, []int)
  • func (*GetServiceRequest) ProtoMessage()
  • func (m *GetServiceRequest) Reset()
  • func (m *GetServiceRequest) String() string
• type GetServiceResponse
  • func (*GetServiceResponse) Descriptor() ([]byte, []int)
  • func (m *GetServiceResponse) GetServices() []*discovery.Service
  • func (*GetServiceResponse) ProtoMessage()
  • func (m *GetServiceResponse) Reset()
  • func (m *GetServiceResponse) String() string
• type ListServicesRequest
  • func (*ListServicesRequest) Descriptor() ([]byte, []int)
  • func (*ListServicesRequest) ProtoMessage()
  • func (m *ListServicesRequest) Reset()
  • func (m *ListServicesRequest) String() string
• type ListServicesResponse
  • func (*ListServicesResponse) Descriptor() ([]byte, []int)
  • func (m *ListServicesResponse) GetServices() []*discovery.Service
  • func (*ListServicesResponse) ProtoMessage()
  • func (m *ListServicesResponse) Reset()
  • func (m *ListServicesResponse) String() string
• type RegisterRequest
  • func (*RegisterRequest) Descriptor() ([]byte, []int)
  • func (m *RegisterRequest) GetService() *discovery.Service
  • func (*RegisterRequest) ProtoMessage()
  • func (m *RegisterRequest) Reset()
  • func (m *RegisterRequest) String() string
• type RegisterResponse
  • func (*RegisterResponse) Descriptor() ([]byte, []int)
  • func (*RegisterResponse) ProtoMessage()
  • func (m *RegisterResponse) Reset()
  • func (m *RegisterResponse) String() string
• type Registry
  • func (h *Registry) Deregister(ctx context.Context, in *DeregisterRequest, out *DeregisterResponse) error
  • func (h *Registry) GetService(ctx context.Context, in *GetServiceRequest, out *GetServiceResponse) error
  • func (h *Registry) ListServices(ctx context.Context, in *ListServicesRequest, out *ListServicesResponse) error
  • func (h *Registry) Register(ctx context.Context, in *RegisterRequest, out *RegisterResponse) error
  • func (h *Registry) Watch(ctx context.Context, stream server.Streamer) error
• type RegistryClient
  • func NewRegistryClient(serviceName string, c client.Client) RegistryClient
• type RegistryHandler
• type Registry_WatchClient
• type Registry_WatchStream
• type WatchRequest
  • func (*WatchRequest) Descriptor() ([]byte, []int)
  • func (*WatchRequest) ProtoMessage()
  • func (m *WatchRequest) Reset()
  • func (m *WatchRequest) String() string
• type WatchResponse
  • func (*WatchResponse) Descriptor() ([]byte, []int)
  • func (m *WatchResponse) GetResult() *discovery.Result
  • func (*WatchResponse) ProtoMessage()
  • func (m *WatchResponse) Reset()
  • func (m *WatchResponse) String() string

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