v3

package
v0.0.0-...-6cb6b35 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Jun 19, 2023 License: MIT Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
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.

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 deprecated

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

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.

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL