v3

Documentation

Index

• Variables
• func RegisterManagementServiceServer(s grpc.ServiceRegistrar, srv ManagementServiceServer)
• type InstancePingPkg
  • func (*InstancePingPkg) Descriptor() ([]byte, []int)
  • 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) 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

var ManagementService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "skywalking.v3.ManagementService",
	HandlerType: (*ManagementServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "reportInstanceProperties",
			Handler:    _ManagementService_ReportInstanceProperties_Handler,
		},
		{
			MethodName: "keepAlive",
			Handler:    _ManagementService_KeepAlive_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "management/Management.proto",
}

ManagementService_ServiceDesc is the grpc.ServiceDesc for ManagementService service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

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"`
	// contains filtered or unexported fields
}

func (*InstancePingPkg) Descriptor

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

Deprecated: Use InstancePingPkg.ProtoReflect.Descriptor instead.

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"`
	// contains filtered or unexported fields
}

func (*InstanceProperties) Descriptor

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

Deprecated: Use InstanceProperties.ProtoReflect.Descriptor instead.

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)
}

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

type UnimplementedManagementServiceServer

type UnimplementedManagementServiceServer struct {
}

UnimplementedManagementServiceServer should 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.