v3

Documentation

Index

• Variables
• func RegisterManagementServiceServer(s grpc.ServiceRegistrar, srv ManagementServiceServer)
• type InstancePingPkg
  • func (*InstancePingPkg) Descriptor() ([]byte, []int)
  • func (x *InstancePingPkg) GetLayer() string
  • func (x *InstancePingPkg) GetService() string
  • func (x *InstancePingPkg) GetServiceInstance() string
  • func (*InstancePingPkg) ProtoMessage()
  • func (x *InstancePingPkg) ProtoReflect() protoreflect.Message
  • func (x *InstancePingPkg) Reset()
  • func (x *InstancePingPkg) String() string
• type InstanceProperties
  • func (*InstanceProperties) Descriptor() ([]byte, []int)
  • func (x *InstanceProperties) GetLayer() string
  • func (x *InstanceProperties) GetProperties() []*v3.KeyStringValuePair
  • func (x *InstanceProperties) GetService() string
  • func (x *InstanceProperties) GetServiceInstance() string
  • func (*InstanceProperties) ProtoMessage()
  • func (x *InstanceProperties) ProtoReflect() protoreflect.Message
  • func (x *InstanceProperties) Reset()
  • func (x *InstanceProperties) String() string
• type ManagementServiceClient
  • func NewManagementServiceClient(cc grpc.ClientConnInterface) ManagementServiceClient
• type ManagementServiceServer
• type UnimplementedManagementServiceServer
  • func (UnimplementedManagementServiceServer) KeepAlive(context.Context, *InstancePingPkg) (*v3.Commands, error)
  • func (UnimplementedManagementServiceServer) ReportInstanceProperties(context.Context, *InstanceProperties) (*v3.Commands, error)
• type UnsafeManagementServiceServer

Variables

var File_management_Management_proto protoreflect.FileDescriptor

Functions

func RegisterManagementServiceServer

func RegisterManagementServiceServer(s grpc.ServiceRegistrar, 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"`
	// Instance belong layer name which define in the backend, general is default.
	Layer string `protobuf:"bytes,3,opt,name=layer,proto3" json:"layer,omitempty"`
	// contains filtered or unexported fields
}

func (*InstancePingPkg) Descriptor

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

Deprecated: Use InstancePingPkg.ProtoReflect.Descriptor instead.

func (*InstancePingPkg) GetLayer

func (x *InstancePingPkg) GetLayer() string

func (*InstancePingPkg) GetService

func (x *InstancePingPkg) GetService() string

func (*InstancePingPkg) GetServiceInstance

func (x *InstancePingPkg) GetServiceInstance() string

func (*InstancePingPkg) ProtoMessage

func (*InstancePingPkg) ProtoMessage()

func (*InstancePingPkg) ProtoReflect

func (x *InstancePingPkg) ProtoReflect() protoreflect.Message

func (*InstancePingPkg) Reset

func (x *InstancePingPkg) Reset()

func (*InstancePingPkg) String

func (x *InstancePingPkg) String() string

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      []*v3.KeyStringValuePair `protobuf:"bytes,3,rep,name=properties,proto3" json:"properties,omitempty"`
	// Instance belong layer name which define in the backend, general is default.
	Layer string `protobuf:"bytes,4,opt,name=layer,proto3" json:"layer,omitempty"`
	// contains filtered or unexported fields
}

func (*InstanceProperties) Descriptor

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

Deprecated: Use InstanceProperties.ProtoReflect.Descriptor instead.

func (*InstanceProperties) GetLayer

func (x *InstanceProperties) GetLayer() string

func (*InstanceProperties) GetProperties

func (x *InstanceProperties) GetProperties() []*v3.KeyStringValuePair

func (*InstanceProperties) GetService

func (x *InstanceProperties) GetService() string

func (*InstanceProperties) GetServiceInstance

func (x *InstanceProperties) GetServiceInstance() string

func (*InstanceProperties) ProtoMessage

func (*InstanceProperties) ProtoMessage()

func (*InstanceProperties) ProtoReflect

func (x *InstanceProperties) ProtoReflect() protoreflect.Message

func (*InstanceProperties) Reset

func (x *InstanceProperties) Reset()

func (*InstanceProperties) String

func (x *InstanceProperties) String() string

type ManagementServiceClient

type ManagementServiceClient interface {
	// Report custom properties of a service instance.
	ReportInstanceProperties(ctx context.Context, in *InstanceProperties, opts ...grpc.CallOption) (*v3.Commands, error)
	// Keep the instance alive in the backend analysis.
	// Only recommend to do separate keepAlive report when no trace and metrics
	// needs to be reported. Otherwise, it is duplicated.
	KeepAlive(ctx context.Context, in *InstancePingPkg, opts ...grpc.CallOption) (*v3.Commands, error)
}

ManagementServiceClient is the client API for ManagementService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewManagementServiceClient

func NewManagementServiceClient(cc grpc.ClientConnInterface) ManagementServiceClient

type ManagementServiceServer

type ManagementServiceServer interface {
	// Report custom properties of a service instance.
	ReportInstanceProperties(context.Context, *InstanceProperties) (*v3.Commands, error)
	// Keep the instance alive in the backend analysis.
	// Only recommend to do separate keepAlive report when no trace and metrics
	// needs to be reported. Otherwise, it is duplicated.
	KeepAlive(context.Context, *InstancePingPkg) (*v3.Commands, error)
	// contains filtered or unexported methods
}

ManagementServiceServer is the server API for ManagementService service. All implementations must embed UnimplementedManagementServiceServer for forward compatibility

type UnimplementedManagementServiceServer

type UnimplementedManagementServiceServer struct {
}

UnimplementedManagementServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedManagementServiceServer) KeepAlive

func (UnimplementedManagementServiceServer) KeepAlive(context.Context, *InstancePingPkg) (*v3.Commands, error)

func (UnimplementedManagementServiceServer) ReportInstanceProperties

func (UnimplementedManagementServiceServer) ReportInstanceProperties(context.Context, *InstanceProperties) (*v3.Commands, error)

type UnsafeManagementServiceServer

type UnsafeManagementServiceServer interface {
	// contains filtered or unexported methods
}

UnsafeManagementServiceServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to ManagementServiceServer will result in compilation errors.