Documentation
¶
Index ¶
- Variables
- func NewRegistryEndpoints() []*api.Endpoint
- func RegisterRegistryHandler(s server.Server, hdlr RegistryHandler, opts ...server.HandlerOption) error
- func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)
- type EmptyResponse
- func (*EmptyResponse) Descriptor() ([]byte, []int)
- func (m *EmptyResponse) Marshal() (dAtA []byte, err error)
- func (m *EmptyResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *EmptyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*EmptyResponse) ProtoMessage()
- func (m *EmptyResponse) Reset()
- func (m *EmptyResponse) Size() (n int)
- func (m *EmptyResponse) String() string
- func (m *EmptyResponse) Unmarshal(dAtA []byte) error
- func (m *EmptyResponse) XXX_DiscardUnknown()
- func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *EmptyResponse) XXX_Merge(src proto.Message)
- func (m *EmptyResponse) XXX_Size() int
- func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
- type Endpoint
- func (*Endpoint) Descriptor() ([]byte, []int)
- func (m *Endpoint) GetMetadata() map[string]string
- func (m *Endpoint) GetName() string
- func (m *Endpoint) GetRequest() *Value
- func (m *Endpoint) GetResponse() *Value
- func (m *Endpoint) Marshal() (dAtA []byte, err error)
- func (m *Endpoint) MarshalTo(dAtA []byte) (int, error)
- func (m *Endpoint) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Endpoint) ProtoMessage()
- func (m *Endpoint) Reset()
- func (m *Endpoint) Size() (n int)
- func (m *Endpoint) String() string
- func (m *Endpoint) Unmarshal(dAtA []byte) error
- func (m *Endpoint) XXX_DiscardUnknown()
- func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Endpoint) XXX_Merge(src proto.Message)
- func (m *Endpoint) XXX_Size() int
- func (m *Endpoint) XXX_Unmarshal(b []byte) error
- type Event
- func (*Event) Descriptor() ([]byte, []int)
- func (m *Event) GetId() string
- func (m *Event) GetService() *Service
- func (m *Event) GetTimestamp() int64
- func (m *Event) GetType() EventType
- func (m *Event) Marshal() (dAtA []byte, err error)
- func (m *Event) MarshalTo(dAtA []byte) (int, error)
- func (m *Event) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Event) ProtoMessage()
- func (m *Event) Reset()
- func (m *Event) Size() (n int)
- func (m *Event) String() string
- func (m *Event) Unmarshal(dAtA []byte) error
- func (m *Event) XXX_DiscardUnknown()
- func (m *Event) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Event) XXX_Merge(src proto.Message)
- func (m *Event) XXX_Size() int
- func (m *Event) XXX_Unmarshal(b []byte) error
- type EventType
- type GetRequest
- func (*GetRequest) Descriptor() ([]byte, []int)
- func (m *GetRequest) GetService() string
- func (m *GetRequest) Marshal() (dAtA []byte, err error)
- func (m *GetRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetRequest) ProtoMessage()
- func (m *GetRequest) Reset()
- func (m *GetRequest) Size() (n int)
- func (m *GetRequest) String() string
- func (m *GetRequest) Unmarshal(dAtA []byte) error
- func (m *GetRequest) XXX_DiscardUnknown()
- func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetRequest) XXX_Merge(src proto.Message)
- func (m *GetRequest) XXX_Size() int
- func (m *GetRequest) XXX_Unmarshal(b []byte) error
- type GetResponse
- func (*GetResponse) Descriptor() ([]byte, []int)
- func (m *GetResponse) GetServices() []*Service
- func (m *GetResponse) Marshal() (dAtA []byte, err error)
- func (m *GetResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*GetResponse) ProtoMessage()
- func (m *GetResponse) Reset()
- func (m *GetResponse) Size() (n int)
- func (m *GetResponse) String() string
- func (m *GetResponse) Unmarshal(dAtA []byte) error
- func (m *GetResponse) XXX_DiscardUnknown()
- func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *GetResponse) XXX_Merge(src proto.Message)
- func (m *GetResponse) XXX_Size() int
- func (m *GetResponse) XXX_Unmarshal(b []byte) error
- type ListRequest
- func (*ListRequest) Descriptor() ([]byte, []int)
- func (m *ListRequest) Marshal() (dAtA []byte, err error)
- func (m *ListRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *ListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListRequest) ProtoMessage()
- func (m *ListRequest) Reset()
- func (m *ListRequest) Size() (n int)
- func (m *ListRequest) String() string
- func (m *ListRequest) Unmarshal(dAtA []byte) error
- func (m *ListRequest) XXX_DiscardUnknown()
- func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListRequest) XXX_Merge(src proto.Message)
- func (m *ListRequest) XXX_Size() int
- func (m *ListRequest) XXX_Unmarshal(b []byte) error
- type ListResponse
- func (*ListResponse) Descriptor() ([]byte, []int)
- func (m *ListResponse) GetServices() []*Service
- func (m *ListResponse) Marshal() (dAtA []byte, err error)
- func (m *ListResponse) MarshalTo(dAtA []byte) (int, error)
- func (m *ListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*ListResponse) ProtoMessage()
- func (m *ListResponse) Reset()
- func (m *ListResponse) Size() (n int)
- func (m *ListResponse) String() string
- func (m *ListResponse) Unmarshal(dAtA []byte) error
- func (m *ListResponse) XXX_DiscardUnknown()
- func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ListResponse) XXX_Merge(src proto.Message)
- func (m *ListResponse) XXX_Size() int
- func (m *ListResponse) XXX_Unmarshal(b []byte) error
- type Node
- func (*Node) Descriptor() ([]byte, []int)
- func (m *Node) GetAddress() string
- func (m *Node) GetId() string
- func (m *Node) GetMetadata() map[string]string
- func (m *Node) GetPort() int64
- func (m *Node) Marshal() (dAtA []byte, err error)
- func (m *Node) MarshalTo(dAtA []byte) (int, error)
- func (m *Node) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Node) ProtoMessage()
- func (m *Node) Reset()
- func (m *Node) Size() (n int)
- func (m *Node) String() string
- func (m *Node) Unmarshal(dAtA []byte) error
- func (m *Node) XXX_DiscardUnknown()
- func (m *Node) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Node) XXX_Merge(src proto.Message)
- func (m *Node) XXX_Size() int
- func (m *Node) XXX_Unmarshal(b []byte) error
- type Options
- func (*Options) Descriptor() ([]byte, []int)
- func (m *Options) GetTtl() int64
- func (m *Options) Marshal() (dAtA []byte, err error)
- func (m *Options) MarshalTo(dAtA []byte) (int, error)
- func (m *Options) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Options) ProtoMessage()
- func (m *Options) Reset()
- func (m *Options) Size() (n int)
- func (m *Options) String() string
- func (m *Options) Unmarshal(dAtA []byte) error
- func (m *Options) XXX_DiscardUnknown()
- func (m *Options) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Options) XXX_Merge(src proto.Message)
- func (m *Options) XXX_Size() int
- func (m *Options) XXX_Unmarshal(b []byte) error
- type RegistryClient
- type RegistryHandler
- type RegistryServer
- type RegistryService
- type Registry_WatchClient
- type Registry_WatchServer
- type Registry_WatchService
- type Registry_WatchStream
- type Result
- func (*Result) Descriptor() ([]byte, []int)
- func (m *Result) GetAction() string
- func (m *Result) GetService() *Service
- func (m *Result) GetTimestamp() int64
- func (m *Result) Marshal() (dAtA []byte, err error)
- func (m *Result) MarshalTo(dAtA []byte) (int, error)
- func (m *Result) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Result) ProtoMessage()
- func (m *Result) Reset()
- func (m *Result) Size() (n int)
- func (m *Result) String() string
- func (m *Result) Unmarshal(dAtA []byte) error
- func (m *Result) XXX_DiscardUnknown()
- func (m *Result) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Result) XXX_Merge(src proto.Message)
- func (m *Result) XXX_Size() int
- func (m *Result) XXX_Unmarshal(b []byte) error
- type Service
- func (*Service) Descriptor() ([]byte, []int)
- func (m *Service) GetEndpoints() []*Endpoint
- func (m *Service) GetMetadata() map[string]string
- func (m *Service) GetName() string
- func (m *Service) GetNodes() []*Node
- func (m *Service) GetOptions() *Options
- func (m *Service) GetVersion() string
- func (m *Service) Marshal() (dAtA []byte, err error)
- func (m *Service) MarshalTo(dAtA []byte) (int, error)
- func (m *Service) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Service) ProtoMessage()
- func (m *Service) Reset()
- func (m *Service) Size() (n int)
- func (m *Service) String() string
- func (m *Service) Unmarshal(dAtA []byte) error
- func (m *Service) XXX_DiscardUnknown()
- func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Service) XXX_Merge(src proto.Message)
- func (m *Service) XXX_Size() int
- func (m *Service) XXX_Unmarshal(b []byte) error
- type UnimplementedRegistryServer
- func (*UnimplementedRegistryServer) Deregister(ctx context.Context, req *Service) (*EmptyResponse, error)
- func (*UnimplementedRegistryServer) GetService(ctx context.Context, req *GetRequest) (*GetResponse, error)
- func (*UnimplementedRegistryServer) ListServices(ctx context.Context, req *ListRequest) (*ListResponse, error)
- func (*UnimplementedRegistryServer) Register(ctx context.Context, req *Service) (*EmptyResponse, error)
- func (*UnimplementedRegistryServer) Watch(req *WatchRequest, srv Registry_WatchServer) error
- type Value
- func (*Value) Descriptor() ([]byte, []int)
- func (m *Value) GetName() string
- func (m *Value) GetType() string
- func (m *Value) GetValues() []*Value
- func (m *Value) Marshal() (dAtA []byte, err error)
- func (m *Value) MarshalTo(dAtA []byte) (int, error)
- func (m *Value) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*Value) ProtoMessage()
- func (m *Value) Reset()
- func (m *Value) Size() (n int)
- func (m *Value) String() string
- func (m *Value) Unmarshal(dAtA []byte) error
- func (m *Value) XXX_DiscardUnknown()
- func (m *Value) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *Value) XXX_Merge(src proto.Message)
- func (m *Value) XXX_Size() int
- func (m *Value) XXX_Unmarshal(b []byte) error
- type WatchRequest
- func (*WatchRequest) Descriptor() ([]byte, []int)
- func (m *WatchRequest) GetService() string
- func (m *WatchRequest) Marshal() (dAtA []byte, err error)
- func (m *WatchRequest) MarshalTo(dAtA []byte) (int, error)
- func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
- func (*WatchRequest) ProtoMessage()
- func (m *WatchRequest) Reset()
- func (m *WatchRequest) Size() (n int)
- func (m *WatchRequest) String() string
- func (m *WatchRequest) Unmarshal(dAtA []byte) error
- func (m *WatchRequest) XXX_DiscardUnknown()
- func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *WatchRequest) XXX_Merge(src proto.Message)
- func (m *WatchRequest) XXX_Size() int
- func (m *WatchRequest) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
var ( ErrInvalidLengthRegistry = fmt.Errorf("proto: negative length found during unmarshaling") ErrIntOverflowRegistry = fmt.Errorf("proto: integer overflow") ErrUnexpectedEndOfGroupRegistry = fmt.Errorf("proto: unexpected end of group") )
var EventType_name = map[int32]string{
0: "Create",
1: "Delete",
2: "Update",
}
var EventType_value = map[string]int32{
"Create": 0,
"Delete": 1,
"Update": 2,
}
Functions ¶
func NewRegistryEndpoints ¶
Api Endpoints for Registry service
func RegisterRegistryHandler ¶
func RegisterRegistryHandler(s server.Server, hdlr RegistryHandler, opts ...server.HandlerOption) error
func RegisterRegistryServer ¶
func RegisterRegistryServer(s *grpc.Server, srv RegistryServer)
Types ¶
type EmptyResponse ¶
type EmptyResponse struct { }
func (*EmptyResponse) Descriptor ¶
func (*EmptyResponse) Descriptor() ([]byte, []int)
func (*EmptyResponse) Marshal ¶
func (m *EmptyResponse) Marshal() (dAtA []byte, err error)
func (*EmptyResponse) MarshalToSizedBuffer ¶
func (m *EmptyResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*EmptyResponse) ProtoMessage ¶
func (*EmptyResponse) ProtoMessage()
func (*EmptyResponse) Reset ¶
func (m *EmptyResponse) Reset()
func (*EmptyResponse) Size ¶
func (m *EmptyResponse) Size() (n int)
func (*EmptyResponse) String ¶
func (m *EmptyResponse) String() string
func (*EmptyResponse) Unmarshal ¶
func (m *EmptyResponse) Unmarshal(dAtA []byte) error
func (*EmptyResponse) XXX_DiscardUnknown ¶
func (m *EmptyResponse) XXX_DiscardUnknown()
func (*EmptyResponse) XXX_Marshal ¶
func (m *EmptyResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*EmptyResponse) XXX_Merge ¶
func (m *EmptyResponse) XXX_Merge(src proto.Message)
func (*EmptyResponse) XXX_Size ¶
func (m *EmptyResponse) XXX_Size() int
func (*EmptyResponse) XXX_Unmarshal ¶
func (m *EmptyResponse) XXX_Unmarshal(b []byte) error
type Endpoint ¶
type Endpoint struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Request *Value `protobuf:"bytes,2,opt,name=request,proto3" json:"request,omitempty"` Response *Value `protobuf:"bytes,3,opt,name=response,proto3" json:"response,omitempty"` Metadata map[string]string `` /* 157-byte string literal not displayed */ }
Endpoint is a endpoint provided by a service
func (*Endpoint) Descriptor ¶
func (*Endpoint) GetMetadata ¶
func (*Endpoint) GetRequest ¶
func (*Endpoint) GetResponse ¶
func (*Endpoint) MarshalToSizedBuffer ¶
func (*Endpoint) ProtoMessage ¶
func (*Endpoint) ProtoMessage()
func (*Endpoint) XXX_DiscardUnknown ¶
func (m *Endpoint) XXX_DiscardUnknown()
func (*Endpoint) XXX_Marshal ¶
func (*Endpoint) XXX_Unmarshal ¶
type Event ¶
type Event struct { // Event Id Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` // type of event Type EventType `protobuf:"varint,2,opt,name=type,proto3,enum=registry.EventType" json:"type,omitempty"` // unix timestamp of event Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` // service entry Service *Service `protobuf:"bytes,4,opt,name=service,proto3" json:"service,omitempty"` }
Event is registry event
func (*Event) Descriptor ¶
func (*Event) GetService ¶
func (*Event) GetTimestamp ¶
func (*Event) ProtoMessage ¶
func (*Event) ProtoMessage()
func (*Event) XXX_DiscardUnknown ¶
func (m *Event) XXX_DiscardUnknown()
func (*Event) XXX_Marshal ¶
func (*Event) XXX_Unmarshal ¶
type EventType ¶
type EventType int32
EventType defines the type of event
func (EventType) EnumDescriptor ¶
type GetRequest ¶
type GetRequest struct {
Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
}
func (*GetRequest) Descriptor ¶
func (*GetRequest) Descriptor() ([]byte, []int)
func (*GetRequest) GetService ¶
func (m *GetRequest) GetService() string
func (*GetRequest) Marshal ¶
func (m *GetRequest) Marshal() (dAtA []byte, err error)
func (*GetRequest) MarshalToSizedBuffer ¶
func (m *GetRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetRequest) ProtoMessage ¶
func (*GetRequest) ProtoMessage()
func (*GetRequest) Reset ¶
func (m *GetRequest) Reset()
func (*GetRequest) Size ¶
func (m *GetRequest) Size() (n int)
func (*GetRequest) String ¶
func (m *GetRequest) String() string
func (*GetRequest) Unmarshal ¶
func (m *GetRequest) Unmarshal(dAtA []byte) error
func (*GetRequest) XXX_DiscardUnknown ¶
func (m *GetRequest) XXX_DiscardUnknown()
func (*GetRequest) XXX_Marshal ¶
func (m *GetRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetRequest) XXX_Merge ¶
func (m *GetRequest) XXX_Merge(src proto.Message)
func (*GetRequest) XXX_Size ¶
func (m *GetRequest) XXX_Size() int
func (*GetRequest) XXX_Unmarshal ¶
func (m *GetRequest) XXX_Unmarshal(b []byte) error
type GetResponse ¶
type GetResponse struct {
Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
}
func (*GetResponse) Descriptor ¶
func (*GetResponse) Descriptor() ([]byte, []int)
func (*GetResponse) GetServices ¶
func (m *GetResponse) GetServices() []*Service
func (*GetResponse) Marshal ¶
func (m *GetResponse) Marshal() (dAtA []byte, err error)
func (*GetResponse) MarshalToSizedBuffer ¶
func (m *GetResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*GetResponse) ProtoMessage ¶
func (*GetResponse) ProtoMessage()
func (*GetResponse) Reset ¶
func (m *GetResponse) Reset()
func (*GetResponse) Size ¶
func (m *GetResponse) Size() (n int)
func (*GetResponse) String ¶
func (m *GetResponse) String() string
func (*GetResponse) Unmarshal ¶
func (m *GetResponse) Unmarshal(dAtA []byte) error
func (*GetResponse) XXX_DiscardUnknown ¶
func (m *GetResponse) XXX_DiscardUnknown()
func (*GetResponse) XXX_Marshal ¶
func (m *GetResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*GetResponse) XXX_Merge ¶
func (m *GetResponse) XXX_Merge(src proto.Message)
func (*GetResponse) XXX_Size ¶
func (m *GetResponse) XXX_Size() int
func (*GetResponse) XXX_Unmarshal ¶
func (m *GetResponse) XXX_Unmarshal(b []byte) error
type ListRequest ¶
type ListRequest struct { }
func (*ListRequest) Descriptor ¶
func (*ListRequest) Descriptor() ([]byte, []int)
func (*ListRequest) Marshal ¶
func (m *ListRequest) Marshal() (dAtA []byte, err error)
func (*ListRequest) MarshalToSizedBuffer ¶
func (m *ListRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListRequest) ProtoMessage ¶
func (*ListRequest) ProtoMessage()
func (*ListRequest) Reset ¶
func (m *ListRequest) Reset()
func (*ListRequest) Size ¶
func (m *ListRequest) Size() (n int)
func (*ListRequest) String ¶
func (m *ListRequest) String() string
func (*ListRequest) Unmarshal ¶
func (m *ListRequest) Unmarshal(dAtA []byte) error
func (*ListRequest) XXX_DiscardUnknown ¶
func (m *ListRequest) XXX_DiscardUnknown()
func (*ListRequest) XXX_Marshal ¶
func (m *ListRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListRequest) XXX_Merge ¶
func (m *ListRequest) XXX_Merge(src proto.Message)
func (*ListRequest) XXX_Size ¶
func (m *ListRequest) XXX_Size() int
func (*ListRequest) XXX_Unmarshal ¶
func (m *ListRequest) XXX_Unmarshal(b []byte) error
type ListResponse ¶
type ListResponse struct {
Services []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
}
func (*ListResponse) Descriptor ¶
func (*ListResponse) Descriptor() ([]byte, []int)
func (*ListResponse) GetServices ¶
func (m *ListResponse) GetServices() []*Service
func (*ListResponse) Marshal ¶
func (m *ListResponse) Marshal() (dAtA []byte, err error)
func (*ListResponse) MarshalToSizedBuffer ¶
func (m *ListResponse) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*ListResponse) ProtoMessage ¶
func (*ListResponse) ProtoMessage()
func (*ListResponse) Reset ¶
func (m *ListResponse) Reset()
func (*ListResponse) Size ¶
func (m *ListResponse) Size() (n int)
func (*ListResponse) String ¶
func (m *ListResponse) String() string
func (*ListResponse) Unmarshal ¶
func (m *ListResponse) Unmarshal(dAtA []byte) error
func (*ListResponse) XXX_DiscardUnknown ¶
func (m *ListResponse) XXX_DiscardUnknown()
func (*ListResponse) XXX_Marshal ¶
func (m *ListResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ListResponse) XXX_Merge ¶
func (m *ListResponse) XXX_Merge(src proto.Message)
func (*ListResponse) XXX_Size ¶
func (m *ListResponse) XXX_Size() int
func (*ListResponse) XXX_Unmarshal ¶
func (m *ListResponse) XXX_Unmarshal(b []byte) error
type Node ¶
type Node struct { Id string `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"` Address string `protobuf:"bytes,2,opt,name=address,proto3" json:"address,omitempty"` Port int64 `protobuf:"varint,3,opt,name=port,proto3" json:"port,omitempty"` Metadata map[string]string `` /* 157-byte string literal not displayed */ }
Node represents the node the service is on
func (*Node) Descriptor ¶
func (*Node) GetAddress ¶
func (*Node) GetMetadata ¶
func (*Node) ProtoMessage ¶
func (*Node) ProtoMessage()
func (*Node) XXX_DiscardUnknown ¶
func (m *Node) XXX_DiscardUnknown()
func (*Node) XXX_Unmarshal ¶
type Options ¶
type Options struct {
Ttl int64 `protobuf:"varint,1,opt,name=ttl,proto3" json:"ttl,omitempty"`
}
Options are registry options
func (*Options) Descriptor ¶
func (*Options) MarshalToSizedBuffer ¶
func (*Options) ProtoMessage ¶
func (*Options) ProtoMessage()
func (*Options) XXX_DiscardUnknown ¶
func (m *Options) XXX_DiscardUnknown()
func (*Options) XXX_Marshal ¶
func (*Options) XXX_Unmarshal ¶
type RegistryClient ¶
type RegistryClient interface { GetService(ctx context.Context, in *GetRequest, opts ...grpc.CallOption) (*GetResponse, error) Register(ctx context.Context, in *Service, opts ...grpc.CallOption) (*EmptyResponse, error) Deregister(ctx context.Context, in *Service, opts ...grpc.CallOption) (*EmptyResponse, error) ListServices(ctx context.Context, in *ListRequest, opts ...grpc.CallOption) (*ListResponse, error) Watch(ctx context.Context, in *WatchRequest, opts ...grpc.CallOption) (Registry_WatchClient, error) }
RegistryClient is the client API for Registry service.
For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.
func NewRegistryClient ¶
func NewRegistryClient(cc *grpc.ClientConn) RegistryClient
type RegistryHandler ¶
type RegistryHandler interface { GetService(context.Context, *GetRequest, *GetResponse) error Register(context.Context, *Service, *EmptyResponse) error Deregister(context.Context, *Service, *EmptyResponse) error ListServices(context.Context, *ListRequest, *ListResponse) error Watch(context.Context, *WatchRequest, Registry_WatchStream) error }
Server API for Registry service
type RegistryServer ¶
type RegistryServer interface { GetService(context.Context, *GetRequest) (*GetResponse, error) Register(context.Context, *Service) (*EmptyResponse, error) Deregister(context.Context, *Service) (*EmptyResponse, error) ListServices(context.Context, *ListRequest) (*ListResponse, error) Watch(*WatchRequest, Registry_WatchServer) error }
RegistryServer is the server API for Registry service.
type RegistryService ¶
type RegistryService interface { GetService(ctx context.Context, in *GetRequest, opts ...client.CallOption) (*GetResponse, error) Register(ctx context.Context, in *Service, opts ...client.CallOption) (*EmptyResponse, error) Deregister(ctx context.Context, in *Service, opts ...client.CallOption) (*EmptyResponse, error) ListServices(ctx context.Context, in *ListRequest, opts ...client.CallOption) (*ListResponse, error) Watch(ctx context.Context, in *WatchRequest, opts ...client.CallOption) (Registry_WatchService, error) }
Client API for Registry service
func NewRegistryService ¶
func NewRegistryService(name string, c client.Client) RegistryService
type Registry_WatchClient ¶
type Registry_WatchClient interface { Recv() (*Result, error) grpc.ClientStream }
type Registry_WatchServer ¶
type Registry_WatchServer interface { Send(*Result) error grpc.ServerStream }
type Registry_WatchService ¶
type Registry_WatchStream ¶
type Result ¶
type Result struct { Action string `protobuf:"bytes,1,opt,name=action,proto3" json:"action,omitempty"` Service *Service `protobuf:"bytes,2,opt,name=service,proto3" json:"service,omitempty"` Timestamp int64 `protobuf:"varint,3,opt,name=timestamp,proto3" json:"timestamp,omitempty"` }
Result is returns by the watcher
func (*Result) Descriptor ¶
func (*Result) GetService ¶
func (*Result) GetTimestamp ¶
func (*Result) MarshalToSizedBuffer ¶
func (*Result) ProtoMessage ¶
func (*Result) ProtoMessage()
func (*Result) XXX_DiscardUnknown ¶
func (m *Result) XXX_DiscardUnknown()
func (*Result) XXX_Marshal ¶
func (*Result) XXX_Unmarshal ¶
type Service ¶
type Service struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Version string `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"` Metadata map[string]string `` /* 157-byte string literal not displayed */ Endpoints []*Endpoint `protobuf:"bytes,4,rep,name=endpoints,proto3" json:"endpoints,omitempty"` Nodes []*Node `protobuf:"bytes,5,rep,name=nodes,proto3" json:"nodes,omitempty"` Options *Options `protobuf:"bytes,6,opt,name=options,proto3" json:"options,omitempty"` }
Service represents a vine service
func (*Service) Descriptor ¶
func (*Service) GetEndpoints ¶
func (*Service) GetMetadata ¶
func (*Service) GetOptions ¶
func (*Service) GetVersion ¶
func (*Service) MarshalToSizedBuffer ¶
func (*Service) ProtoMessage ¶
func (*Service) ProtoMessage()
func (*Service) XXX_DiscardUnknown ¶
func (m *Service) XXX_DiscardUnknown()
func (*Service) XXX_Marshal ¶
func (*Service) XXX_Unmarshal ¶
type UnimplementedRegistryServer ¶
type UnimplementedRegistryServer struct { }
UnimplementedRegistryServer can be embedded to have forward compatible implementations.
func (*UnimplementedRegistryServer) Deregister ¶
func (*UnimplementedRegistryServer) Deregister(ctx context.Context, req *Service) (*EmptyResponse, error)
func (*UnimplementedRegistryServer) GetService ¶
func (*UnimplementedRegistryServer) GetService(ctx context.Context, req *GetRequest) (*GetResponse, error)
func (*UnimplementedRegistryServer) ListServices ¶
func (*UnimplementedRegistryServer) ListServices(ctx context.Context, req *ListRequest) (*ListResponse, error)
func (*UnimplementedRegistryServer) Register ¶
func (*UnimplementedRegistryServer) Register(ctx context.Context, req *Service) (*EmptyResponse, error)
func (*UnimplementedRegistryServer) Watch ¶
func (*UnimplementedRegistryServer) Watch(req *WatchRequest, srv Registry_WatchServer) error
type Value ¶
type Value struct { Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"` Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"` Values []*Value `protobuf:"bytes,3,rep,name=values,proto3" json:"values,omitempty"` }
Value is an opaque value for a request or response
func (*Value) Descriptor ¶
func (*Value) ProtoMessage ¶
func (*Value) ProtoMessage()
func (*Value) XXX_DiscardUnknown ¶
func (m *Value) XXX_DiscardUnknown()
func (*Value) XXX_Marshal ¶
func (*Value) XXX_Unmarshal ¶
type WatchRequest ¶
type WatchRequest struct { // service is optional Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"` }
func (*WatchRequest) Descriptor ¶
func (*WatchRequest) Descriptor() ([]byte, []int)
func (*WatchRequest) GetService ¶
func (m *WatchRequest) GetService() string
func (*WatchRequest) Marshal ¶
func (m *WatchRequest) Marshal() (dAtA []byte, err error)
func (*WatchRequest) MarshalToSizedBuffer ¶
func (m *WatchRequest) MarshalToSizedBuffer(dAtA []byte) (int, error)
func (*WatchRequest) ProtoMessage ¶
func (*WatchRequest) ProtoMessage()
func (*WatchRequest) Reset ¶
func (m *WatchRequest) Reset()
func (*WatchRequest) Size ¶
func (m *WatchRequest) Size() (n int)
func (*WatchRequest) String ¶
func (m *WatchRequest) String() string
func (*WatchRequest) Unmarshal ¶
func (m *WatchRequest) Unmarshal(dAtA []byte) error
func (*WatchRequest) XXX_DiscardUnknown ¶
func (m *WatchRequest) XXX_DiscardUnknown()
func (*WatchRequest) XXX_Marshal ¶
func (m *WatchRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*WatchRequest) XXX_Merge ¶
func (m *WatchRequest) XXX_Merge(src proto.Message)
func (*WatchRequest) XXX_Size ¶
func (m *WatchRequest) XXX_Size() int
func (*WatchRequest) XXX_Unmarshal ¶
func (m *WatchRequest) XXX_Unmarshal(b []byte) error