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