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 {
	EnvCode      string                       `protobuf:"bytes,1,opt,name=envCode,proto3" json:"envCode,omitempty"`
	ServiceId    int32                        `protobuf:"varint,2,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	EndpointName string                       `protobuf:"bytes,3,opt,name=endpointName,proto3" json:"endpointName,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"`
	// For endpoint
	// from DetectPoint is either `client` or `server`. No chance to be `proxy`.
	From                 common.DetectPoint `protobuf:"varint,6,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) GetEnvCode

func (m *Endpoint) GetEnvCode() 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 {
	EnvCode              string             `protobuf:"bytes,1,opt,name=envCode,proto3" json:"envCode,omitempty"`
	ServiceId            int32              `protobuf:"varint,2,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
	EndpointName         string             `protobuf:"bytes,3,opt,name=endpointName,proto3" json:"endpointName,omitempty"`
	EndpointId           int32              `protobuf:"varint,4,opt,name=endpointId,proto3" json:"endpointId,omitempty"`
	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 (*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) GetEnvCode

func (m *EndpointMappingElement) GetEnvCode() 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 Endpoints

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:"-"`
}

    Endpoints register

    func (*Endpoints) Descriptor

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

    func (*Endpoints) GetEndpoints

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

    func (*Endpoints) ProtoMessage

    func (*Endpoints) ProtoMessage()

    func (*Endpoints) Reset

    func (m *Endpoints) Reset()

    func (*Endpoints) String

    func (m *Endpoints) String() string

    func (*Endpoints) XXX_DiscardUnknown

    func (m *Endpoints) XXX_DiscardUnknown()

    func (*Endpoints) XXX_Marshal

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

    func (*Endpoints) XXX_Merge

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

    func (*Endpoints) XXX_Size

    func (m *Endpoints) XXX_Size() int

    func (*Endpoints) XXX_Unmarshal

    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 {
    	EnvCode              string   `protobuf:"bytes,1,opt,name=envCode,proto3" json:"envCode,omitempty"`
    	Addresses            []string `protobuf:"bytes,2,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) GetEnvCode

      func (m *NetAddresses) GetEnvCode() 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.

        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 {
          	EnvCode              string                       `protobuf:"bytes,1,opt,name=envCode,proto3" json:"envCode,omitempty"`
          	ServiceName          string                       `protobuf:"bytes,2,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) GetEnvCode

          func (m *Service) GetEnvCode() string

          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 {
          	EnvCode              string   `protobuf:"bytes,1,opt,name=envCode,proto3" json:"envCode,omitempty"`
          	ServiceId            int32    `protobuf:"varint,2,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
          	ServiceInstanceId    int32    `protobuf:"varint,3,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
          	NetworkAddress       string   `protobuf:"bytes,4,opt,name=networkAddress,proto3" json:"networkAddress,omitempty"`
          	NetworkAddressId     int32    `protobuf:"varint,5,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) GetEnvCode

          func (m *ServiceAndNetworkAddressMapping) GetEnvCode() string

          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 {
          	EnvCode              string                       `protobuf:"bytes,1,opt,name=envCode,proto3" json:"envCode,omitempty"`
          	ServiceId            int32                        `protobuf:"varint,2,opt,name=serviceId,proto3" json:"serviceId,omitempty"`
          	InstanceUUID         string                       `protobuf:"bytes,3,opt,name=instanceUUID,proto3" json:"instanceUUID,omitempty"`
          	Time                 int64                        `protobuf:"varint,4,opt,name=time,proto3" json:"time,omitempty"`
          	Tags                 []*common.KeyStringValuePair `protobuf:"bytes,5,rep,name=tags,proto3" json:"tags,omitempty"`
          	Properties           []*common.KeyStringValuePair `protobuf:"bytes,6,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) GetEnvCode

          func (m *ServiceInstance) GetEnvCode() string

          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.

            type ServiceInstancePingPkg

            type ServiceInstancePingPkg struct {
            	EnvCode              string   `protobuf:"bytes,1,opt,name=envCode,proto3" json:"envCode,omitempty"`
            	ServiceInstanceId    int32    `protobuf:"varint,2,opt,name=serviceInstanceId,proto3" json:"serviceInstanceId,omitempty"`
            	Time                 int64    `protobuf:"varint,3,opt,name=time,proto3" json:"time,omitempty"`
            	ServiceInstanceUUID  string   `protobuf:"bytes,4,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) GetEnvCode

            func (m *ServiceInstancePingPkg) GetEnvCode() string

            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 *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) 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.