Versions in this module Expand all Collapse all v0 v0.0.1 Oct 21, 2020 Changes in this version + var EventType_name = map[int32]string + var EventType_value = map[string]int32 + func RegisterRegistryServer(s *grpc.Server, srv RegistryServer) + type Empty struct + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Empty) Descriptor() ([]byte, []int) + func (*Empty) ProtoMessage() + func (m *Empty) Reset() + func (m *Empty) String() string + func (m *Empty) XXX_DiscardUnknown() + func (m *Empty) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Empty) XXX_Merge(src proto.Message) + func (m *Empty) XXX_Size() int + func (m *Empty) XXX_Unmarshal(b []byte) error + type EventType int32 + const EventType_Register + const EventType_Remove + func (EventType) EnumDescriptor() ([]byte, []int) + func (x EventType) String() string + type RegistryClient interface + GetServices func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (Registry_GetServicesClient, error) + RegisterWorkload func(ctx context.Context, in *ServiceWorkload, opts ...grpc.CallOption) (*Empty, error) + RemoveWorkload func(ctx context.Context, in *ServiceWorkload, opts ...grpc.CallOption) (*Empty, error) + func NewRegistryClient(cc *grpc.ClientConn) RegistryClient + type RegistryServer interface + GetServices func(*Empty, Registry_GetServicesServer) error + RegisterWorkload func(context.Context, *ServiceWorkload) (*Empty, error) + RemoveWorkload func(context.Context, *ServiceWorkload) (*Empty, error) + type Registry_GetServicesClient interface + Recv func() (*WorkloadEvent, error) + type Registry_GetServicesServer interface + Send func(*WorkloadEvent) error + type ServiceWorkload struct + ConnectivityDomain string + Ports []int32 + ServiceName string + Workloads []*Workload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*ServiceWorkload) Descriptor() ([]byte, []int) + func (*ServiceWorkload) ProtoMessage() + func (m *ServiceWorkload) GetConnectivityDomain() string + func (m *ServiceWorkload) GetPorts() []int32 + func (m *ServiceWorkload) GetServiceName() string + func (m *ServiceWorkload) GetWorkloads() []*Workload + func (m *ServiceWorkload) Reset() + func (m *ServiceWorkload) String() string + func (m *ServiceWorkload) XXX_DiscardUnknown() + func (m *ServiceWorkload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *ServiceWorkload) XXX_Merge(src proto.Message) + func (m *ServiceWorkload) XXX_Size() int + func (m *ServiceWorkload) XXX_Unmarshal(b []byte) error + func (x *ServiceWorkload) Validate() error + type UnimplementedRegistryServer struct + func (*UnimplementedRegistryServer) GetServices(req *Empty, srv Registry_GetServicesServer) error + func (*UnimplementedRegistryServer) RegisterWorkload(ctx context.Context, req *ServiceWorkload) (*Empty, error) + func (*UnimplementedRegistryServer) RemoveWorkload(ctx context.Context, req *ServiceWorkload) (*Empty, error) + type Workload struct + IPAddress []string + Identifier *WorkloadIdentifier + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*Workload) Descriptor() ([]byte, []int) + func (*Workload) ProtoMessage() + func (m *Workload) GetIPAddress() []string + func (m *Workload) GetIdentifier() *WorkloadIdentifier + func (m *Workload) Reset() + func (m *Workload) String() string + func (m *Workload) Validate() error + func (m *Workload) XXX_DiscardUnknown() + func (m *Workload) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *Workload) XXX_Merge(src proto.Message) + func (m *Workload) XXX_Size() int + func (m *Workload) XXX_Unmarshal(b []byte) error + type WorkloadEvent struct + EventType EventType + ServiceWorkload *ServiceWorkload + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkloadEvent) Descriptor() ([]byte, []int) + func (*WorkloadEvent) ProtoMessage() + func (m *WorkloadEvent) GetEventType() EventType + func (m *WorkloadEvent) GetServiceWorkload() *ServiceWorkload + func (m *WorkloadEvent) Reset() + func (m *WorkloadEvent) String() string + func (m *WorkloadEvent) XXX_DiscardUnknown() + func (m *WorkloadEvent) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkloadEvent) XXX_Merge(src proto.Message) + func (m *WorkloadEvent) XXX_Size() int + func (m *WorkloadEvent) XXX_Unmarshal(b []byte) error + type WorkloadIdentifier struct + Cluster string + Name string + PodName string + XXX_NoUnkeyedLiteral struct{} + XXX_sizecache int32 + XXX_unrecognized []byte + func (*WorkloadIdentifier) Descriptor() ([]byte, []int) + func (*WorkloadIdentifier) ProtoMessage() + func (m *WorkloadIdentifier) GetCluster() string + func (m *WorkloadIdentifier) GetName() string + func (m *WorkloadIdentifier) GetPodName() string + func (m *WorkloadIdentifier) Reset() + func (m *WorkloadIdentifier) String() string + func (m *WorkloadIdentifier) XXX_DiscardUnknown() + func (m *WorkloadIdentifier) XXX_Marshal(b []byte, deterministic bool) ([]byte, error) + func (m *WorkloadIdentifier) XXX_Merge(src proto.Message) + func (m *WorkloadIdentifier) XXX_Size() int + func (m *WorkloadIdentifier) XXX_Unmarshal(b []byte) error + func (x *WorkloadIdentifier) Validate() error