v3

Documentation

Index

• Variables
• func RegisterConfigurationDiscoveryServiceServer(s grpc.ServiceRegistrar, srv ConfigurationDiscoveryServiceServer)
• type ConfigurationDiscoveryServiceClient
  • func NewConfigurationDiscoveryServiceClient(cc grpc.ClientConnInterface) ConfigurationDiscoveryServiceClient
• type ConfigurationDiscoveryServiceServer
• type ConfigurationSyncRequest
  • func (*ConfigurationSyncRequest) Descriptor() ([]byte, []int)
  • func (x *ConfigurationSyncRequest) GetService() string
  • func (x *ConfigurationSyncRequest) GetUuid() string
  • func (*ConfigurationSyncRequest) ProtoMessage()
  • func (x *ConfigurationSyncRequest) ProtoReflect() protoreflect.Message
  • func (x *ConfigurationSyncRequest) Reset()
  • func (x *ConfigurationSyncRequest) String() string
• type UnimplementedConfigurationDiscoveryServiceServer
  • func (UnimplementedConfigurationDiscoveryServiceServer) FetchConfigurations(context.Context, *ConfigurationSyncRequest) (*v3.Commands, error)
• type UnsafeConfigurationDiscoveryServiceServer

Variables

var ConfigurationDiscoveryService_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "skywalking.v3.ConfigurationDiscoveryService",
	HandlerType: (*ConfigurationDiscoveryServiceServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "fetchConfigurations",
			Handler:    _ConfigurationDiscoveryService_FetchConfigurations_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "language-agent/ConfigurationDiscoveryService.proto",
}

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

var File_language_agent_ConfigurationDiscoveryService_proto protoreflect.FileDescriptor

Functions

func RegisterConfigurationDiscoveryServiceServer

func RegisterConfigurationDiscoveryServiceServer(s grpc.ServiceRegistrar, srv ConfigurationDiscoveryServiceServer)

Types

type ConfigurationDiscoveryServiceClient

type ConfigurationDiscoveryServiceClient interface {
	// fetchConfigurations service requests the latest configuration.
	// Expect command of Commands is:
	//
	//	command: CDS # meaning ConfigurationDiscoveryService's response
	//	args: Include string key and string value pair.
	//	      The key depends on the agent implementation.
	//	      The value is the latest value in String value. The watcher of key owner takes the responsibility to convert it to the correct type or format.
	//	      One reserved key is `UUID`. The value would help reducing the traffic load between agent and OAP if there is no change.
	//
	// Commands could be empty if no change detected based on ConfigurationSyncRequest.
	FetchConfigurations(ctx context.Context, in *ConfigurationSyncRequest, opts ...grpc.CallOption) (*v3.Commands, error)
}

ConfigurationDiscoveryServiceClient is the client API for ConfigurationDiscoveryService 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 NewConfigurationDiscoveryServiceClient

func NewConfigurationDiscoveryServiceClient(cc grpc.ClientConnInterface) ConfigurationDiscoveryServiceClient

type ConfigurationDiscoveryServiceServer

type ConfigurationDiscoveryServiceServer interface {
	// fetchConfigurations service requests the latest configuration.
	// Expect command of Commands is:
	//
	//	command: CDS # meaning ConfigurationDiscoveryService's response
	//	args: Include string key and string value pair.
	//	      The key depends on the agent implementation.
	//	      The value is the latest value in String value. The watcher of key owner takes the responsibility to convert it to the correct type or format.
	//	      One reserved key is `UUID`. The value would help reducing the traffic load between agent and OAP if there is no change.
	//
	// Commands could be empty if no change detected based on ConfigurationSyncRequest.
	FetchConfigurations(context.Context, *ConfigurationSyncRequest) (*v3.Commands, error)
	// contains filtered or unexported methods
}

ConfigurationDiscoveryServiceServer is the server API for ConfigurationDiscoveryService service. All implementations must embed UnimplementedConfigurationDiscoveryServiceServer for forward compatibility

type ConfigurationSyncRequest

type ConfigurationSyncRequest struct {

	// Current agent service name.
	Service string `protobuf:"bytes,1,opt,name=service,proto3" json:"service,omitempty"`
	// [Optional]
	// UUID is the unique id to represent the signature of the latest configuration.
	// The agent usually uses its bootstrap configuration running in default, and this id could be empty when doing the 1st round sync.
	// The agent could/is recommended to cache the UUID from the last command, and put it as the next round UUID parameter,
	// then the OAP only returns the empty Commands if no configuration change happenned.
	Uuid string `protobuf:"bytes,2,opt,name=uuid,proto3" json:"uuid,omitempty"`
	// contains filtered or unexported fields
}

func (*ConfigurationSyncRequest) Descriptor

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

Deprecated: Use ConfigurationSyncRequest.ProtoReflect.Descriptor instead.

func (*ConfigurationSyncRequest) GetService

func (x *ConfigurationSyncRequest) GetService() string

func (*ConfigurationSyncRequest) GetUuid

func (x *ConfigurationSyncRequest) GetUuid() string

func (*ConfigurationSyncRequest) ProtoMessage

func (*ConfigurationSyncRequest) ProtoMessage()

func (*ConfigurationSyncRequest) ProtoReflect

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

func (*ConfigurationSyncRequest) Reset

func (x *ConfigurationSyncRequest) Reset()

func (*ConfigurationSyncRequest) String

func (x *ConfigurationSyncRequest) String() string

type UnimplementedConfigurationDiscoveryServiceServer

type UnimplementedConfigurationDiscoveryServiceServer struct {
}

UnimplementedConfigurationDiscoveryServiceServer must be embedded to have forward compatible implementations.

func (UnimplementedConfigurationDiscoveryServiceServer) FetchConfigurations

func (UnimplementedConfigurationDiscoveryServiceServer) FetchConfigurations(context.Context, *ConfigurationSyncRequest) (*v3.Commands, error)

type UnsafeConfigurationDiscoveryServiceServer

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

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