management

Documentation

Index

• func RegisterManagementServiceServer(s *grpc.Server, srv ManagementServiceServer)
• type InstancePingPkg
  • func (*InstancePingPkg) Descriptor() ([]byte, []int)
  • func (m *InstancePingPkg) GetService() string
  • func (m *InstancePingPkg) GetServiceInstance() string
  • func (*InstancePingPkg) ProtoMessage()
  • func (m *InstancePingPkg) Reset()
  • func (m *InstancePingPkg) String() string
  • func (m *InstancePingPkg) XXX_DiscardUnknown()
  • func (m *InstancePingPkg) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *InstancePingPkg) XXX_Merge(src proto.Message)
  • func (m *InstancePingPkg) XXX_Size() int
  • func (m *InstancePingPkg) XXX_Unmarshal(b []byte) error
• type InstanceProperties
  • func (*InstanceProperties) Descriptor() ([]byte, []int)
  • func (m *InstanceProperties) GetProperties() []*common.KeyStringValuePair
  • func (m *InstanceProperties) GetService() string
  • func (m *InstanceProperties) GetServiceInstance() string
  • func (*InstanceProperties) ProtoMessage()
  • func (m *InstanceProperties) Reset()
  • func (m *InstanceProperties) String() string
  • func (m *InstanceProperties) XXX_DiscardUnknown()
  • func (m *InstanceProperties) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
  • func (m *InstanceProperties) XXX_Merge(src proto.Message)
  • func (m *InstanceProperties) XXX_Size() int
  • func (m *InstanceProperties) XXX_Unmarshal(b []byte) error
• type ManagementServiceClient
  • func NewManagementServiceClient(cc *grpc.ClientConn) ManagementServiceClient
• type ManagementServiceServer

Functions

func RegisterManagementServiceServer

func RegisterManagementServiceServer(s *grpc.Server, srv ManagementServiceServer)

Types

type InstancePingPkg

type InstancePingPkg struct {
	Service              string   `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	ServiceInstance      string   `protobuf:"bytes,2,opt,name=serviceInstance,proto3" json:"serviceInstance,omitempty"`
	XXX_NoUnkeyedLiteral struct{} `json:"-"`
	XXX_unrecognized     []byte   `json:"-"`
	XXX_sizecache        int32    `json:"-"`
}

func (*InstancePingPkg) Descriptor

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

func (*InstancePingPkg) GetService

func (m *InstancePingPkg) GetService() string

func (*InstancePingPkg) GetServiceInstance

func (m *InstancePingPkg) GetServiceInstance() string

func (*InstancePingPkg) ProtoMessage

func (*InstancePingPkg) ProtoMessage()

func (*InstancePingPkg) Reset

func (m *InstancePingPkg) Reset()

func (*InstancePingPkg) String

func (m *InstancePingPkg) String() string

func (*InstancePingPkg) XXX_DiscardUnknown

func (m *InstancePingPkg) XXX_DiscardUnknown()

func (*InstancePingPkg) XXX_Marshal

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

func (*InstancePingPkg) XXX_Merge

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

func (*InstancePingPkg) XXX_Size

func (m *InstancePingPkg) XXX_Size() int

func (*InstancePingPkg) XXX_Unmarshal

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

type InstanceProperties

type InstanceProperties struct {
	Service              string                       `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	ServiceInstance      string                       `protobuf:"bytes,2,opt,name=serviceInstance,proto3" json:"serviceInstance,omitempty"`
	Properties           []*common.KeyStringValuePair `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"`
	XXX_NoUnkeyedLiteral struct{}                     `json:"-"`
	XXX_unrecognized     []byte                       `json:"-"`
	XXX_sizecache        int32                        `json:"-"`
}

func (*InstanceProperties) Descriptor

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

func (*InstanceProperties) GetProperties

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

func (*InstanceProperties) GetService

func (m *InstanceProperties) GetService() string

func (*InstanceProperties) GetServiceInstance

func (m *InstanceProperties) GetServiceInstance() string

func (*InstanceProperties) ProtoMessage

func (*InstanceProperties) ProtoMessage()

func (*InstanceProperties) Reset

func (m *InstanceProperties) Reset()

func (*InstanceProperties) String

func (m *InstanceProperties) String() string

func (*InstanceProperties) XXX_DiscardUnknown

func (m *InstanceProperties) XXX_DiscardUnknown()

func (*InstanceProperties) XXX_Marshal

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

func (*InstanceProperties) XXX_Merge

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

func (*InstanceProperties) XXX_Size

func (m *InstanceProperties) XXX_Size() int

func (*InstanceProperties) XXX_Unmarshal

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

type ManagementServiceClient

type ManagementServiceClient interface {
	ReportInstanceProperties(ctx context.Context, in *InstanceProperties, opts ...grpc.CallOption) (*common.Commands, error)
	KeepAlive(ctx context.Context, in *InstancePingPkg, opts ...grpc.CallOption) (*common.Commands, error)
}

ManagementServiceClient is the client API for ManagementService service.

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

func NewManagementServiceClient

func NewManagementServiceClient(cc *grpc.ClientConn) ManagementServiceClient

type ManagementServiceServer

type ManagementServiceServer interface {
	ReportInstanceProperties(context.Context, *InstanceProperties) (*common.Commands, error)
	KeepAlive(context.Context, *InstancePingPkg) (*common.Commands, error)
}

ManagementServiceServer is the server API for ManagementService service.