register

package
v0.1.2 Latest Latest
Warning

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

Go to latest
Published: Oct 10, 2019 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 (*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 Enpoints

type Enpoints 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 (*Enpoints) Descriptor

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

func (*Enpoints) GetEndpoints

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

func (*Enpoints) ProtoMessage

func (*Enpoints) ProtoMessage()

func (*Enpoints) Reset

func (m *Enpoints) Reset()

func (*Enpoints) String

func (m *Enpoints) String() string

func (*Enpoints) XXX_DiscardUnknown

func (m *Enpoints) XXX_DiscardUnknown()

func (*Enpoints) XXX_Marshal

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

func (*Enpoints) XXX_Merge

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

func (*Enpoints) XXX_Size

func (m *Enpoints) XXX_Size() int

func (*Enpoints) XXX_Unmarshal

func (m *Enpoints) 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 *Enpoints, 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.ClientConn) RegisterClient

type RegisterServer

type RegisterServer interface {
	DoServiceRegister(context.Context, *Services) (*ServiceRegisterMapping, error)
	DoServiceInstanceRegister(context.Context, *ServiceInstances) (*ServiceInstanceRegisterMapping, error)
	DoEndpointRegister(context.Context, *Enpoints) (*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 (*ServiceAndNetworkAddressMapping) 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 (*ServiceAndNetworkAddressMappings) ProtoMessage

func (*ServiceAndNetworkAddressMappings) ProtoMessage()

func (*ServiceAndNetworkAddressMappings) Reset

func (*ServiceAndNetworkAddressMappings) 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 (*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.ClientConn) 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 (*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 *Enpoints) (*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) DoServiceRegister

type UnimplementedServiceInstancePingServer

type UnimplementedServiceInstancePingServer struct {
}

UnimplementedServiceInstancePingServer can be embedded to have forward compatible implementations.

func (*UnimplementedServiceInstancePingServer) DoPing

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