register

package
v0.3.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 14, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func RegisterRegisterServer 

func RegisterRegisterServer(s *grpc.Server, srv RegisterServer)

func RegisterServiceInstancePingServer 

func RegisterServiceInstancePingServer(s *grpc.Server, srv ServiceInstancePingServer)

Types

type Endpoint 

type Endpoint struct {
	ServiceId    int32                        `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	EndpointName string                       `protobuf:"bytes,2,opt,name=endpointName,proto3" json:"endpointName,omitempty"`
	Tags         []*common.KeyStringValuePair `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Properties   []*common.KeyStringValuePair `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	// For endpoint
	// from DetectPoint is either `client` or `server`. No chance to be `proxy`.
	From                 common.DetectPoint `protobuf:"varint,5,opt,name=from,proto3,enum=DetectPoint" json:"from,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*Endpoint) Descriptor 

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

func (*Endpoint) GetEndpointName 

func (m *Endpoint) GetEndpointName() string

func (*Endpoint) GetFrom 

func (m *Endpoint) GetFrom() common.DetectPoint

func (*Endpoint) GetProperties 

func (m *Endpoint) GetProperties() []*common.KeyStringValuePair

func (*Endpoint) GetServiceId 

func (m *Endpoint) GetServiceId() int32

func (*Endpoint) GetTags 

func (m *Endpoint) GetTags() []*common.KeyStringValuePair

func (*Endpoint) ProtoMessage 

func (*Endpoint) ProtoMessage()

func (*Endpoint) Reset 

func (m *Endpoint) Reset()

func (*Endpoint) String 

func (m *Endpoint) String() string

func (*Endpoint) XXX_DiscardUnknown 

func (m *Endpoint) XXX_DiscardUnknown()

func (*Endpoint) XXX_Marshal 

func (m *Endpoint) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Endpoint) XXX_Merge 

func (m *Endpoint) XXX_Merge(src proto.Message)

func (*Endpoint) XXX_Size 

func (m *Endpoint) XXX_Size() int

func (*Endpoint) XXX_Unmarshal 

func (m *Endpoint) XXX_Unmarshal(b []byte) error

type EndpointMapping 

type EndpointMapping struct {
	Elements             []*EndpointMappingElement `protobuf:"bytes,1,rep,name=elements,proto3" json:"elements,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*EndpointMapping) Descriptor 

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

func (*EndpointMapping) GetElements 

func (m *EndpointMapping) GetElements() []*EndpointMappingElement

func (*EndpointMapping) ProtoMessage 

func (*EndpointMapping) ProtoMessage()

func (*EndpointMapping) Reset 

func (m *EndpointMapping) Reset()

func (*EndpointMapping) String 

func (m *EndpointMapping) String() string

func (*EndpointMapping) XXX_DiscardUnknown 

func (m *EndpointMapping) XXX_DiscardUnknown()

func (*EndpointMapping) XXX_Marshal 

func (m *EndpointMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointMapping) XXX_Merge 

func (m *EndpointMapping) XXX_Merge(src proto.Message)

func (*EndpointMapping) XXX_Size 

func (m *EndpointMapping) XXX_Size() int

func (*EndpointMapping) XXX_Unmarshal 

func (m *EndpointMapping) XXX_Unmarshal(b []byte) error

type EndpointMappingElement 

type EndpointMappingElement struct {
	ServiceId            int32              `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	EndpointName         string             `protobuf:"bytes,2,opt,name=endpointName,proto3" json:"endpointName,omitempty"`
	EndpointId           int32              `protobuf:"varint,3,opt,name=endpointId,proto3" json:"endpointId,omitempty"`
	From                 common.DetectPoint `protobuf:"varint,4,opt,name=from,proto3,enum=DetectPoint" json:"from,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

func (*EndpointMappingElement) Descriptor 

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

func (*EndpointMappingElement) GetEndpointId 

func (m *EndpointMappingElement) GetEndpointId() int32

func (*EndpointMappingElement) GetEndpointName 

func (m *EndpointMappingElement) GetEndpointName() string

func (*EndpointMappingElement) GetFrom 

func (m *EndpointMappingElement) GetFrom() common.DetectPoint

func (*EndpointMappingElement) GetServiceId 

func (m *EndpointMappingElement) GetServiceId() int32

func (*EndpointMappingElement) ProtoMessage 

func (*EndpointMappingElement) ProtoMessage()

func (*EndpointMappingElement) Reset 

func (m *EndpointMappingElement) Reset()

func (*EndpointMappingElement) String 

func (m *EndpointMappingElement) String() string

func (*EndpointMappingElement) XXX_DiscardUnknown 

func (m *EndpointMappingElement) XXX_DiscardUnknown()

func (*EndpointMappingElement) XXX_Marshal 

func (m *EndpointMappingElement) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*EndpointMappingElement) XXX_Merge 

func (m *EndpointMappingElement) XXX_Merge(src proto.Message)

func (*EndpointMappingElement) XXX_Size 

func (m *EndpointMappingElement) XXX_Size() int

func (*EndpointMappingElement) XXX_Unmarshal 

func (m *EndpointMappingElement) XXX_Unmarshal(b []byte) error

type Endpoints added in v0.3.0 

type Endpoints struct {
	Endpoints            []*Endpoint `protobuf:"bytes,1,rep,name=endpoints,proto3" json:"endpoints,omitempty"`
	XXX_NoUnkeyedLiteral struct{}    `json:"-"`
	XXX_unrecognized     []byte      `json:"-"`
	XXX_sizecache        int32       `json:"-"`
}

Endpint register

func (*Endpoints) Descriptor added in v0.3.0 

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

func (*Endpoints) GetEndpoints added in v0.3.0 

func (m *Endpoints) GetEndpoints() []*Endpoint

func (*Endpoints) ProtoMessage added in v0.3.0 

func (*Endpoints) ProtoMessage()

func (*Endpoints) Reset added in v0.3.0 

func (m *Endpoints) Reset()

func (*Endpoints) String added in v0.3.0 

func (m *Endpoints) String() string

func (*Endpoints) XXX_DiscardUnknown added in v0.3.0 

func (m *Endpoints) XXX_DiscardUnknown()

func (*Endpoints) XXX_Marshal added in v0.3.0 

func (m *Endpoints) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Endpoints) XXX_Merge added in v0.3.0 

func (m *Endpoints) XXX_Merge(src proto.Message)

func (*Endpoints) XXX_Size added in v0.3.0 

func (m *Endpoints) XXX_Size() int

func (*Endpoints) XXX_Unmarshal added in v0.3.0 

func (m *Endpoints) XXX_Unmarshal(b []byte) error

type NetAddressMapping 

type NetAddressMapping struct {
	AddressIds           []*common.KeyIntValuePair `protobuf:"bytes,1,rep,name=addressIds,proto3" json:"addressIds,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*NetAddressMapping) Descriptor 

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

func (*NetAddressMapping) GetAddressIds 

func (m *NetAddressMapping) GetAddressIds() []*common.KeyIntValuePair

func (*NetAddressMapping) ProtoMessage 

func (*NetAddressMapping) ProtoMessage()

func (*NetAddressMapping) Reset 

func (m *NetAddressMapping) Reset()

func (*NetAddressMapping) String 

func (m *NetAddressMapping) String() string

func (*NetAddressMapping) XXX_DiscardUnknown 

func (m *NetAddressMapping) XXX_DiscardUnknown()

func (*NetAddressMapping) XXX_Marshal 

func (m *NetAddressMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetAddressMapping) XXX_Merge 

func (m *NetAddressMapping) XXX_Merge(src proto.Message)

func (*NetAddressMapping) XXX_Size 

func (m *NetAddressMapping) XXX_Size() int

func (*NetAddressMapping) XXX_Unmarshal 

func (m *NetAddressMapping) XXX_Unmarshal(b []byte) error

type NetAddresses 

type NetAddresses struct {
	Addresses            []string `protobuf:"bytes,1,rep,name=addresses,proto3" json:"addresses,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

Only known use case is the language agent. Network address represents the ip/hostname:port, which is usually used at client side of RPC.

func (*NetAddresses) Descriptor 

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

func (*NetAddresses) GetAddresses 

func (m *NetAddresses) GetAddresses() []string

func (*NetAddresses) ProtoMessage 

func (*NetAddresses) ProtoMessage()

func (*NetAddresses) Reset 

func (m *NetAddresses) Reset()

func (*NetAddresses) String 

func (m *NetAddresses) String() string

func (*NetAddresses) XXX_DiscardUnknown 

func (m *NetAddresses) XXX_DiscardUnknown()

func (*NetAddresses) XXX_Marshal 

func (m *NetAddresses) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*NetAddresses) XXX_Merge 

func (m *NetAddresses) XXX_Merge(src proto.Message)

func (*NetAddresses) XXX_Size 

func (m *NetAddresses) XXX_Size() int

func (*NetAddresses) XXX_Unmarshal 

func (m *NetAddresses) XXX_Unmarshal(b []byte) error

type RegisterClient 

type RegisterClient interface {
	DoServiceRegister(ctx context.Context, in *Services, opts ...grpc.CallOption) (*ServiceRegisterMapping, error)
	DoServiceInstanceRegister(ctx context.Context, in *ServiceInstances, opts ...grpc.CallOption) (*ServiceInstanceRegisterMapping, error)
	DoEndpointRegister(ctx context.Context, in *Endpoints, opts ...grpc.CallOption) (*EndpointMapping, error)
	DoNetworkAddressRegister(ctx context.Context, in *NetAddresses, opts ...grpc.CallOption) (*NetAddressMapping, error)
	DoServiceAndNetworkAddressMappingRegister(ctx context.Context, in *ServiceAndNetworkAddressMappings, opts ...grpc.CallOption) (*common.Commands, error)
}

RegisterClient is the client API for Register service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewRegisterClient 

func NewRegisterClient(cc grpc.ClientConnInterface) RegisterClient

type RegisterServer 

type RegisterServer interface {
	DoServiceRegister(context.Context, *Services) (*ServiceRegisterMapping, error)
	DoServiceInstanceRegister(context.Context, *ServiceInstances) (*ServiceInstanceRegisterMapping, error)
	DoEndpointRegister(context.Context, *Endpoints) (*EndpointMapping, error)
	DoNetworkAddressRegister(context.Context, *NetAddresses) (*NetAddressMapping, error)
	DoServiceAndNetworkAddressMappingRegister(context.Context, *ServiceAndNetworkAddressMappings) (*common.Commands, error)
}

RegisterServer is the server API for Register service.

type Service 

type Service struct {
	ServiceName          string                       `protobuf:"bytes,1,opt,name=serviceName,proto3" json:"serviceName,omitempty"`
	Tags                 []*common.KeyStringValuePair `protobuf:"bytes,3,rep,name=tags,proto3" json:"tags,omitempty"`
	Properties           []*common.KeyStringValuePair `protobuf:"bytes,4,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*Service) Descriptor 

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

func (*Service) GetProperties 

func (m *Service) GetProperties() []*common.KeyStringValuePair

func (*Service) GetServiceName 

func (m *Service) GetServiceName() string

func (*Service) GetTags 

func (m *Service) GetTags() []*common.KeyStringValuePair

func (*Service) ProtoMessage 

func (*Service) ProtoMessage()

func (*Service) Reset 

func (m *Service) Reset()

func (*Service) String 

func (m *Service) String() string

func (*Service) XXX_DiscardUnknown 

func (m *Service) XXX_DiscardUnknown()

func (*Service) XXX_Marshal 

func (m *Service) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Service) XXX_Merge 

func (m *Service) XXX_Merge(src proto.Message)

func (*Service) XXX_Size 

func (m *Service) XXX_Size() int

func (*Service) XXX_Unmarshal 

func (m *Service) XXX_Unmarshal(b []byte) error

type ServiceAndNetworkAddressMapping 

type ServiceAndNetworkAddressMapping struct {
	ServiceId            int32    `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	ServiceInstanceId    int32    `protobuf:"varint,2,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
	NetworkAddress       string   `protobuf:"bytes,3,opt,name=networkAddress,proto3" json:"networkAddress,omitempty"`
	NetworkAddressId     int32    `protobuf:"varint,4,opt,name=networkAddressId,proto3" json:"networkAddressId,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceAndNetworkAddressMapping) Descriptor 

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

func (*ServiceAndNetworkAddressMapping) GetNetworkAddress 

func (m *ServiceAndNetworkAddressMapping) GetNetworkAddress() string

func (*ServiceAndNetworkAddressMapping) GetNetworkAddressId 

func (m *ServiceAndNetworkAddressMapping) GetNetworkAddressId() int32

func (*ServiceAndNetworkAddressMapping) GetServiceId 

func (m *ServiceAndNetworkAddressMapping) GetServiceId() int32

func (*ServiceAndNetworkAddressMapping) GetServiceInstanceId 

func (m *ServiceAndNetworkAddressMapping) GetServiceInstanceId() int32

func (*ServiceAndNetworkAddressMapping) ProtoMessage 

func (*ServiceAndNetworkAddressMapping) ProtoMessage()

func (*ServiceAndNetworkAddressMapping) Reset 

func (m *ServiceAndNetworkAddressMapping) Reset()

func (*ServiceAndNetworkAddressMapping) String 

func (m *ServiceAndNetworkAddressMapping) String() string

func (*ServiceAndNetworkAddressMapping) XXX_DiscardUnknown 

func (m *ServiceAndNetworkAddressMapping) XXX_DiscardUnknown()

func (*ServiceAndNetworkAddressMapping) XXX_Marshal 

func (m *ServiceAndNetworkAddressMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceAndNetworkAddressMapping) XXX_Merge 

func (m *ServiceAndNetworkAddressMapping) XXX_Merge(src proto.Message)

func (*ServiceAndNetworkAddressMapping) XXX_Size 

func (m *ServiceAndNetworkAddressMapping) XXX_Size() int

func (*ServiceAndNetworkAddressMapping) XXX_Unmarshal 

func (m *ServiceAndNetworkAddressMapping) XXX_Unmarshal(b []byte) error

type ServiceAndNetworkAddressMappings 

type ServiceAndNetworkAddressMappings struct {
	Mappings             []*ServiceAndNetworkAddressMapping `protobuf:"bytes,1,rep,name=mappings,proto3" json:"mappings,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                           `json:"-"`
	XXX_unrecognized     []byte                             `json:"-"`
	XXX_sizecache        int32                              `json:"-"`
}

func (*ServiceAndNetworkAddressMappings) Descriptor 

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

func (*ServiceAndNetworkAddressMappings) GetMappings 

func (m *ServiceAndNetworkAddressMappings) GetMappings() []*ServiceAndNetworkAddressMapping

func (*ServiceAndNetworkAddressMappings) ProtoMessage 

func (*ServiceAndNetworkAddressMappings) ProtoMessage()

func (*ServiceAndNetworkAddressMappings) Reset 

func (m *ServiceAndNetworkAddressMappings) Reset()

func (*ServiceAndNetworkAddressMappings) String 

func (m *ServiceAndNetworkAddressMappings) String() string

func (*ServiceAndNetworkAddressMappings) XXX_DiscardUnknown 

func (m *ServiceAndNetworkAddressMappings) XXX_DiscardUnknown()

func (*ServiceAndNetworkAddressMappings) XXX_Marshal 

func (m *ServiceAndNetworkAddressMappings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceAndNetworkAddressMappings) XXX_Merge 

func (m *ServiceAndNetworkAddressMappings) XXX_Merge(src proto.Message)

func (*ServiceAndNetworkAddressMappings) XXX_Size 

func (m *ServiceAndNetworkAddressMappings) XXX_Size() int

func (*ServiceAndNetworkAddressMappings) XXX_Unmarshal 

func (m *ServiceAndNetworkAddressMappings) XXX_Unmarshal(b []byte) error

type ServiceInstance 

type ServiceInstance struct {
	ServiceId            int32                        `protobuf:"varint,1,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	InstanceUUID         string                       `protobuf:"bytes,2,opt,name=instanceUUID,proto3" json:"instanceUUID,omitempty"`
	Time                 int64                        `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
	Tags                 []*common.KeyStringValuePair `protobuf:"bytes,4,rep,name=tags,proto3" json:"tags,omitempty"`
	Properties           []*common.KeyStringValuePair `protobuf:"bytes,5,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*ServiceInstance) Descriptor 

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

func (*ServiceInstance) GetInstanceUUID 

func (m *ServiceInstance) GetInstanceUUID() string

func (*ServiceInstance) GetProperties 

func (m *ServiceInstance) GetProperties() []*common.KeyStringValuePair

func (*ServiceInstance) GetServiceId 

func (m *ServiceInstance) GetServiceId() int32

func (*ServiceInstance) GetTags 

func (m *ServiceInstance) GetTags() []*common.KeyStringValuePair

func (*ServiceInstance) GetTime 

func (m *ServiceInstance) GetTime() int64

func (*ServiceInstance) ProtoMessage 

func (*ServiceInstance) ProtoMessage()

func (*ServiceInstance) Reset 

func (m *ServiceInstance) Reset()

func (*ServiceInstance) String 

func (m *ServiceInstance) String() string

func (*ServiceInstance) XXX_DiscardUnknown 

func (m *ServiceInstance) XXX_DiscardUnknown()

func (*ServiceInstance) XXX_Marshal 

func (m *ServiceInstance) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceInstance) XXX_Merge 

func (m *ServiceInstance) XXX_Merge(src proto.Message)

func (*ServiceInstance) XXX_Size 

func (m *ServiceInstance) XXX_Size() int

func (*ServiceInstance) XXX_Unmarshal 

func (m *ServiceInstance) XXX_Unmarshal(b []byte) error

type ServiceInstancePingClient 

type ServiceInstancePingClient interface {
	DoPing(ctx context.Context, in *ServiceInstancePingPkg, opts ...grpc.CallOption) (*common.Commands, error)
}

ServiceInstancePingClient is the client API for ServiceInstancePing service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewServiceInstancePingClient 

func NewServiceInstancePingClient(cc grpc.ClientConnInterface) ServiceInstancePingClient

type ServiceInstancePingPkg 

type ServiceInstancePingPkg struct {
	ServiceInstanceId    int32    `protobuf:"varint,1,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
	Time                 int64    `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	ServiceInstanceUUID  string   `protobuf:"bytes,3,opt,name=serviceInstanceUUID,proto3" json:"serviceInstanceUUID,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*ServiceInstancePingPkg) Descriptor 

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

func (*ServiceInstancePingPkg) GetServiceInstanceId 

func (m *ServiceInstancePingPkg) GetServiceInstanceId() int32

func (*ServiceInstancePingPkg) GetServiceInstanceUUID 

func (m *ServiceInstancePingPkg) GetServiceInstanceUUID() string

func (*ServiceInstancePingPkg) GetTime 

func (m *ServiceInstancePingPkg) GetTime() int64

func (*ServiceInstancePingPkg) ProtoMessage 

func (*ServiceInstancePingPkg) ProtoMessage()

func (*ServiceInstancePingPkg) Reset 

func (m *ServiceInstancePingPkg) Reset()

func (*ServiceInstancePingPkg) String 

func (m *ServiceInstancePingPkg) String() string

func (*ServiceInstancePingPkg) XXX_DiscardUnknown 

func (m *ServiceInstancePingPkg) XXX_DiscardUnknown()

func (*ServiceInstancePingPkg) XXX_Marshal 

func (m *ServiceInstancePingPkg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceInstancePingPkg) XXX_Merge 

func (m *ServiceInstancePingPkg) XXX_Merge(src proto.Message)

func (*ServiceInstancePingPkg) XXX_Size 

func (m *ServiceInstancePingPkg) XXX_Size() int

func (*ServiceInstancePingPkg) XXX_Unmarshal 

func (m *ServiceInstancePingPkg) XXX_Unmarshal(b []byte) error

type ServiceInstancePingServer 

type ServiceInstancePingServer interface {
	DoPing(context.Context, *ServiceInstancePingPkg) (*common.Commands, error)
}

ServiceInstancePingServer is the server API for ServiceInstancePing service.

type ServiceInstanceRegisterMapping 

type ServiceInstanceRegisterMapping struct {
	ServiceInstances     []*common.KeyIntValuePair `protobuf:"bytes,1,rep,name=serviceInstances,proto3" json:"serviceInstances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ServiceInstanceRegisterMapping) Descriptor 

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

func (*ServiceInstanceRegisterMapping) GetServiceInstances 

func (m *ServiceInstanceRegisterMapping) GetServiceInstances() []*common.KeyIntValuePair

func (*ServiceInstanceRegisterMapping) ProtoMessage 

func (*ServiceInstanceRegisterMapping) ProtoMessage()

func (*ServiceInstanceRegisterMapping) Reset 

func (m *ServiceInstanceRegisterMapping) Reset()

func (*ServiceInstanceRegisterMapping) String 

func (m *ServiceInstanceRegisterMapping) String() string

func (*ServiceInstanceRegisterMapping) XXX_DiscardUnknown 

func (m *ServiceInstanceRegisterMapping) XXX_DiscardUnknown()

func (*ServiceInstanceRegisterMapping) XXX_Marshal 

func (m *ServiceInstanceRegisterMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceInstanceRegisterMapping) XXX_Merge 

func (m *ServiceInstanceRegisterMapping) XXX_Merge(src proto.Message)

func (*ServiceInstanceRegisterMapping) XXX_Size 

func (m *ServiceInstanceRegisterMapping) XXX_Size() int

func (*ServiceInstanceRegisterMapping) XXX_Unmarshal 

func (m *ServiceInstanceRegisterMapping) XXX_Unmarshal(b []byte) error

type ServiceInstances 

type ServiceInstances struct {
	Instances            []*ServiceInstance `protobuf:"bytes,1,rep,name=instances,proto3" json:"instances,omitempty"`
	XXX_NoUnkeyedLiteral struct{}           `json:"-"`
	XXX_unrecognized     []byte             `json:"-"`
	XXX_sizecache        int32              `json:"-"`
}

Service Instance register

func (*ServiceInstances) Descriptor 

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

func (*ServiceInstances) GetInstances 

func (m *ServiceInstances) GetInstances() []*ServiceInstance

func (*ServiceInstances) ProtoMessage 

func (*ServiceInstances) ProtoMessage()

func (*ServiceInstances) Reset 

func (m *ServiceInstances) Reset()

func (*ServiceInstances) String 

func (m *ServiceInstances) String() string

func (*ServiceInstances) XXX_DiscardUnknown 

func (m *ServiceInstances) XXX_DiscardUnknown()

func (*ServiceInstances) XXX_Marshal 

func (m *ServiceInstances) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceInstances) XXX_Merge 

func (m *ServiceInstances) XXX_Merge(src proto.Message)

func (*ServiceInstances) XXX_Size 

func (m *ServiceInstances) XXX_Size() int

func (*ServiceInstances) XXX_Unmarshal 

func (m *ServiceInstances) XXX_Unmarshal(b []byte) error

type ServiceRegisterMapping 

type ServiceRegisterMapping struct {
	Services             []*common.KeyIntValuePair `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                  `json:"-"`
	XXX_unrecognized     []byte                    `json:"-"`
	XXX_sizecache        int32                     `json:"-"`
}

func (*ServiceRegisterMapping) Descriptor 

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

func (*ServiceRegisterMapping) GetServices 

func (m *ServiceRegisterMapping) GetServices() []*common.KeyIntValuePair

func (*ServiceRegisterMapping) ProtoMessage 

func (*ServiceRegisterMapping) ProtoMessage()

func (*ServiceRegisterMapping) Reset 

func (m *ServiceRegisterMapping) Reset()

func (*ServiceRegisterMapping) String 

func (m *ServiceRegisterMapping) String() string

func (*ServiceRegisterMapping) XXX_DiscardUnknown 

func (m *ServiceRegisterMapping) XXX_DiscardUnknown()

func (*ServiceRegisterMapping) XXX_Marshal 

func (m *ServiceRegisterMapping) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*ServiceRegisterMapping) XXX_Merge 

func (m *ServiceRegisterMapping) XXX_Merge(src proto.Message)

func (*ServiceRegisterMapping) XXX_Size 

func (m *ServiceRegisterMapping) XXX_Size() int

func (*ServiceRegisterMapping) XXX_Unmarshal 

func (m *ServiceRegisterMapping) XXX_Unmarshal(b []byte) error

type Services 

type Services struct {
	Services             []*Service `protobuf:"bytes,1,rep,name=services,proto3" json:"services,omitempty"`
	XXX_NoUnkeyedLiteral struct{}   `json:"-"`
	XXX_unrecognized     []byte     `json:"-"`
	XXX_sizecache        int32      `json:"-"`
}

Service register

func (*Services) Descriptor 

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

func (*Services) GetServices 

func (m *Services) GetServices() []*Service

func (*Services) ProtoMessage 

func (*Services) ProtoMessage()

func (*Services) Reset 

func (m *Services) Reset()

func (*Services) String 

func (m *Services) String() string

func (*Services) XXX_DiscardUnknown 

func (m *Services) XXX_DiscardUnknown()

func (*Services) XXX_Marshal 

func (m *Services) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*Services) XXX_Merge 

func (m *Services) XXX_Merge(src proto.Message)

func (*Services) XXX_Size 

func (m *Services) XXX_Size() int

func (*Services) XXX_Unmarshal 

func (m *Services) XXX_Unmarshal(b []byte) error

type UnimplementedRegisterServer 

type UnimplementedRegisterServer struct {
}

UnimplementedRegisterServer can be embedded to have forward compatible implementations.

func (*UnimplementedRegisterServer) DoEndpointRegister 

func (*UnimplementedRegisterServer) DoEndpointRegister(ctx context.Context, req *Endpoints) (*EndpointMapping, error)

func (*UnimplementedRegisterServer) DoNetworkAddressRegister 

func (*UnimplementedRegisterServer) DoNetworkAddressRegister(ctx context.Context, req *NetAddresses) (*NetAddressMapping, error)

func (*UnimplementedRegisterServer) DoServiceAndNetworkAddressMappingRegister 

func (*UnimplementedRegisterServer) DoServiceAndNetworkAddressMappingRegister(ctx context.Context, req *ServiceAndNetworkAddressMappings) (*common.Commands, error)

func (*UnimplementedRegisterServer) DoServiceInstanceRegister 

func (*UnimplementedRegisterServer) DoServiceInstanceRegister(ctx context.Context, req *ServiceInstances) (*ServiceInstanceRegisterMapping, error)

func (*UnimplementedRegisterServer) DoServiceRegister 

func (*UnimplementedRegisterServer) DoServiceRegister(ctx context.Context, req *Services) (*ServiceRegisterMapping, error)

type UnimplementedServiceInstancePingServer 

type UnimplementedServiceInstancePingServer struct {
}

UnimplementedServiceInstancePingServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceInstancePingServer) DoPing 

func (*UnimplementedServiceInstancePingServer) DoPing(ctx context.Context, req *ServiceInstancePingPkg) (*common.Commands, error)

Source Files

View all Source files

Directories

Path Synopsis
Package mock_register is a generated GoMock package.
 Package mock_register is a generated GoMock package.

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.