protos

type ClientDigestUpdate struct {
	Op     ClientDigestUpdate_Op `protobuf:"varint,1,opt,name=op,proto3,enum=ClientDigestUpdate_Op" json:"op,omitempty"`
	Digest *Digest               `protobuf:"bytes,2,opt,name=digest,proto3" json:"digest,omitempty"`
	// contains filtered or unexported fields
}

type ClientDigestUpdate_Op int32

type ClientEventUpdate struct {
	Op    ClientEventUpdate_Op `protobuf:"varint,1,opt,name=op,proto3,enum=ClientEventUpdate_Op" json:"op,omitempty"`
	Event *Event               `protobuf:"bytes,2,opt,name=event,proto3" json:"event,omitempty"`
	// contains filtered or unexported fields
}

type ClientEventUpdate_Op int32

type ClientListSamplersReq struct {
	// contains filtered or unexported fields
}

type ClientListSamplersRes struct {
	Status   *Status    `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Samplers []*Sampler `protobuf:"bytes,2,rep,name=samplers,proto3" json:"samplers,omitempty"`
	// contains filtered or unexported fields
}

type ClientRegisterReq struct {
	Tags map[string]string `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

type ClientRegisterRes struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type ClientSamplerConfReq struct {

	// Name of the Samplers to configure. All samplers with the provided name will
	// receive this configuration. It is a mandatory field.
	SamplerName string `protobuf:"bytes,1,opt,name=sampler_name,json=samplerName,proto3" json:"sampler_name,omitempty"`
	// Name of the resource where the sampler is defined
	SamplerResource string `protobuf:"bytes,2,opt,name=sampler_resource,json=samplerResource,proto3" json:"sampler_resource,omitempty"`
	// Update configuration options. If not set, resets all configuration options
	SamplerConfigUpdate *ClientSamplerConfigUpdate `protobuf:"bytes,3,opt,name=sampler_config_update,json=samplerConfigUpdate,proto3" json:"sampler_config_update,omitempty"`
	// contains filtered or unexported fields
}

type ClientSamplerConfRes struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type ClientSamplerConfigUpdate struct {
	Reset_ *ClientSamplerConfigUpdate_Reset `protobuf:"bytes,1,opt,name=reset,proto3" json:"reset,omitempty"`
	// All fields are optional. If a field is nil, it means that the field will
	// not be updated.
	StreamUpdates []*ClientStreamUpdate `protobuf:"bytes,2,rep,name=stream_updates,json=streamUpdates,proto3" json:"stream_updates,omitempty"`
	LimiterIn     *Limiter              `protobuf:"bytes,3,opt,name=limiter_in,json=limiterIn,proto3" json:"limiter_in,omitempty"`
	SamplingIn    *Sampling             `protobuf:"bytes,4,opt,name=sampling_in,json=samplingIn,proto3" json:"sampling_in,omitempty"`
	LimiterOut    *Limiter              `protobuf:"bytes,5,opt,name=limiter_out,json=limiterOut,proto3" json:"limiter_out,omitempty"`
	DigestUpdates []*ClientDigestUpdate `protobuf:"bytes,6,rep,name=digest_updates,json=digestUpdates,proto3" json:"digest_updates,omitempty"`
	EventUpdates  []*ClientEventUpdate  `protobuf:"bytes,7,rep,name=event_updates,json=eventUpdates,proto3" json:"event_updates,omitempty"`
	// contains filtered or unexported fields
}

type ClientSamplerConfigUpdate_Reset struct {
	Streams    bool `protobuf:"varint,1,opt,name=streams,proto3" json:"streams,omitempty"`
	LimiterIn  bool `protobuf:"varint,2,opt,name=limiter_in,json=limiterIn,proto3" json:"limiter_in,omitempty"`
	SamplingIn bool `protobuf:"varint,3,opt,name=sampling_in,json=samplingIn,proto3" json:"sampling_in,omitempty"`
	LimiterOut bool `protobuf:"varint,4,opt,name=limiter_out,json=limiterOut,proto3" json:"limiter_out,omitempty"`
	Digests    bool `protobuf:"varint,5,opt,name=digests,proto3" json:"digests,omitempty"`
	Events     bool `protobuf:"varint,6,opt,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type ClientSamplerStats struct {
	SamplerUid    string                `protobuf:"bytes,1,opt,name=sampler_uid,json=samplerUid,proto3" json:"sampler_uid,omitempty"`
	SamplingStats *SamplerSamplingStats `protobuf:"bytes,2,opt,name=sampling_stats,json=samplingStats,proto3" json:"sampling_stats,omitempty"`
	// contains filtered or unexported fields
}

type ClientSamplerStatsMsg struct {
	SamplerStats []*ClientSamplerStats `protobuf:"bytes,1,rep,name=sampler_stats,json=samplerStats,proto3" json:"sampler_stats,omitempty"`
	// contains filtered or unexported fields
}

type ClientStreamUpdate struct {
	Op     ClientStreamUpdate_Op `protobuf:"varint,1,opt,name=op,proto3,enum=ClientStreamUpdate_Op" json:"op,omitempty"`
	Stream *Stream               `protobuf:"bytes,2,opt,name=stream,proto3" json:"stream,omitempty"`
	// contains filtered or unexported fields
}

type ClientStreamUpdate_Op int32

type ClientToServer struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ClientUid string                 `protobuf:"bytes,2,opt,name=client_uid,json=clientUid,proto3" json:"client_uid,omitempty"`
	// Types that are assignable to Message:
	//	*ClientToServer_RegisterReq
	//	*ClientToServer_ListSamplersReq
	//	*ClientToServer_SamplerConfReq
	Message isClientToServer_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type ClientToServer_ListSamplersReq struct {
	ListSamplersReq *ClientListSamplersReq `protobuf:"bytes,4,opt,name=list_samplers_req,json=listSamplersReq,proto3,oneof"`
}

type ClientToServer_RegisterReq struct {
	// Requests
	RegisterReq *ClientRegisterReq `protobuf:"bytes,3,opt,name=register_req,json=registerReq,proto3,oneof"`
}

type ClientToServer_SamplerConfReq struct {
	SamplerConfReq *ClientSamplerConfReq `protobuf:"bytes,5,opt,name=sampler_conf_req,json=samplerConfReq,proto3,oneof"`
}

type ControlPlaneClient interface {
	SamplerConn(ctx context.Context, opts ...grpc.CallOption) (ControlPlane_SamplerConnClient, error)
	ClientConn(ctx context.Context, opts ...grpc.CallOption) (ControlPlane_ClientConnClient, error)
}

type ControlPlaneServer interface {
	SamplerConn(ControlPlane_SamplerConnServer) error
	ClientConn(ControlPlane_ClientConnServer) error
	// contains filtered or unexported methods
}

type ControlPlane_ClientConnClient interface {
	Send(*ClientToServer) error
	Recv() (*ServerToClient, error)
	grpc.ClientStream
}

type ControlPlane_ClientConnServer interface {
	Send(*ServerToClient) error
	Recv() (*ClientToServer, error)
	grpc.ServerStream
}

type ControlPlane_SamplerConnClient interface {
	Send(*SamplerToServer) error
	Recv() (*ServerToSampler, error)
	grpc.ClientStream
}

type ControlPlane_SamplerConnServer interface {
	Send(*ServerToSampler) error
	Recv() (*SamplerToServer, error)
	grpc.ServerStream
}

type DeterministicSampling struct {

	// the minimum sample_rate valid value is 1 (all samples)
	SampleRate             int32 `protobuf:"varint,1,opt,name=sample_rate,json=sampleRate,proto3" json:"sample_rate,omitempty"`
	SampleEmptyDeterminant bool  `` /* 130-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Digest struct {
	Uid                 string               `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name                string               `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	StreamUid           string               `protobuf:"bytes,3,opt,name=stream_uid,json=streamUid,proto3" json:"stream_uid,omitempty"`
	FlushPeriod         *durationpb.Duration `protobuf:"bytes,4,opt,name=flush_period,json=flushPeriod,proto3" json:"flush_period,omitempty"`
	BufferSize          int32                `protobuf:"varint,5,opt,name=buffer_size,json=bufferSize,proto3" json:"buffer_size,omitempty"`
	ComputationLocation Digest_Location      `` /* 140-byte string literal not displayed */
	// Types that are assignable to Type:
	//	*Digest_St_
	//	*Digest_Value_
	Type isDigest_Type `protobuf_oneof:"Type"`
	// contains filtered or unexported fields
}

type Digest_Location int32

type Digest_St struct {
	MaxProcessedFields int32 `protobuf:"varint,1,opt,name=max_processed_fields,json=maxProcessedFields,proto3" json:"max_processed_fields,omitempty"`
	// contains filtered or unexported fields
}

type Digest_St_ struct {
	St *Digest_St `protobuf:"bytes,7,opt,name=st,proto3,oneof"`
}

type Digest_Value struct {

	// Maximum number of fields to process when processing a sample
	MaxProcessedFields int32 `protobuf:"varint,1,opt,name=max_processed_fields,json=maxProcessedFields,proto3" json:"max_processed_fields,omitempty"`
	// contains filtered or unexported fields
}

type Digest_Value_ struct {
	Value *Digest_Value `protobuf:"bytes,8,opt,name=value,proto3,oneof"`
}

type Event struct {
	Uid            string     `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name           string     `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	StreamUid      string     `protobuf:"bytes,3,opt,name=stream_uid,json=streamUid,proto3" json:"stream_uid,omitempty"`
	SampleType     SampleType `protobuf:"varint,4,opt,name=sample_type,json=sampleType,proto3,enum=SampleType" json:"sample_type,omitempty"`
	Rule           *Rule      `protobuf:"bytes,5,opt,name=rule,proto3" json:"rule,omitempty"`
	Limiter        *Limiter   `protobuf:"bytes,6,opt,name=limiter,proto3" json:"limiter,omitempty"`
	ExportTemplate string     `protobuf:"bytes,7,opt,name=export_template,json=exportTemplate,proto3" json:"export_template,omitempty"`
	// contains filtered or unexported fields
}

type Limiter struct {

	// limit determines the maximum number of exported samples per second.
	// -1 means no exported samples limit
	// 0 means no samples will be exported
	Limit int32 `protobuf:"varint,1,opt,name=limit,proto3" json:"limit,omitempty"`
	// contains filtered or unexported fields
}

type Rule struct {
	Language   Rule_Language `protobuf:"varint,1,opt,name=language,proto3,enum=Rule_Language" json:"language,omitempty"`
	Expression string        `protobuf:"bytes,2,opt,name=expression,proto3" json:"expression,omitempty"`
	// contains filtered or unexported fields
}

type Rule_Language int32

type SampleType int32

type Sampler struct {

	// Identifies a single Sampler
	Uid string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	// User-friendly and user-defined name to identify a Sampler.
	Name string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	// Defines the Sampler resource where it has been defined.
	// Multiple samplers can have the same name and resource but will hav
	// edifferent uids. e.g. multiple replicas of the same service will define
	// multiple times the same sampler with different uids.
	Resource string `protobuf:"bytes,3,opt,name=resource,proto3" json:"resource,omitempty"`
	// User-defined tags to identify a Sampler.
	// There are known tags that can be used to identify the Sampler type
	// and may be used by the platform to provide additional functionality.
	Tags []*Sampler_Tag `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
	// Sampler schema information.
	Schema *Schema `protobuf:"bytes,4,opt,name=schema,proto3" json:"schema,omitempty"`
	// The Sampler configuration,
	Config *SamplerConfig `protobuf:"bytes,5,opt,name=config,proto3" json:"config,omitempty"`
	// Statistics related to the Sampler sampling.
	SamplingStats *SamplerSamplingStats `protobuf:"bytes,6,opt,name=sampling_stats,json=samplingStats,proto3" json:"sampling_stats,omitempty"`
	// contains filtered or unexported fields
}

type SamplerConfig struct {

	// Configures the sampler streams.
	Streams []*Stream `protobuf:"bytes,1,rep,name=streams,proto3" json:"streams,omitempty"`
	// Sets an upper bound to the amount of samples that will be processed by the
	// sampler. It protects the application from an excessive CPU usage due to the
	// sampler processing a large amount of samples.
	LimiterIn *Limiter `protobuf:"bytes,2,opt,name=limiter_in,json=limiterIn,proto3" json:"limiter_in,omitempty"`
	// Defines the sampling strategy to apply when a sample is received and before
	// processing it in any way (e.g. before determining if a sample belongs to a
	// stream which would require parsing it and evaluating the stream rules).
	// Sampling is performed after limiter_in has been applied.
	SamplingIn *Sampling `protobuf:"bytes,3,opt,name=sampling_in,json=samplingIn,proto3" json:"sampling_in,omitempty"`
	// Sets an upper bound to the amount of samples that will be exported by the
	// sampler. It protects the application from overloading the network due to
	// the sampler exporting a large amount of samples.
	LimiterOut *Limiter `protobuf:"bytes,4,opt,name=limiter_out,json=limiterOut,proto3" json:"limiter_out,omitempty"`
	// Configure the sampler digests.
	Digests []*Digest `protobuf:"bytes,5,rep,name=digests,proto3" json:"digests,omitempty"`
	// Configure the sampler events.
	Events []*Event `protobuf:"bytes,6,rep,name=events,proto3" json:"events,omitempty"`
	// contains filtered or unexported fields
}

type SamplerRegisterReq struct {
	InitialConfig *ClientSamplerConfigUpdate `protobuf:"bytes,1,opt,name=initial_config,json=initialConfig,proto3" json:"initial_config,omitempty"`
	Tags          []*Sampler_Tag             `protobuf:"bytes,2,rep,name=tags,proto3" json:"tags,omitempty"`
	// contains filtered or unexported fields
}

type SamplerRegisterRes struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type SamplerSamplingStats struct {
	SamplesEvaluated uint64 `protobuf:"varint,1,opt,name=samples_evaluated,json=samplesEvaluated,proto3" json:"samples_evaluated,omitempty"`
	SamplesExported  uint64 `protobuf:"varint,2,opt,name=samples_exported,json=samplesExported,proto3" json:"samples_exported,omitempty"`
	SamplesDigested  uint64 `protobuf:"varint,3,opt,name=samples_digested,json=samplesDigested,proto3" json:"samples_digested,omitempty"`
	// contains filtered or unexported fields
}

type SamplerStatsMsg struct {
	SamplingStats *SamplerSamplingStats `protobuf:"bytes,2,opt,name=sampling_stats,json=samplingStats,proto3" json:"sampling_stats,omitempty"`
	// contains filtered or unexported fields
}

type SamplerToServer struct {
	Timestamp  *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Name       string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Resouce    string                 `protobuf:"bytes,3,opt,name=resouce,proto3" json:"resouce,omitempty"`
	SamplerUid string                 `protobuf:"bytes,4,opt,name=sampler_uid,json=samplerUid,proto3" json:"sampler_uid,omitempty"`
	// Types that are assignable to Message:
	//	*SamplerToServer_SamplerStatsMsg
	//	*SamplerToServer_RegisterReq
	//	*SamplerToServer_ConfRes
	Message isSamplerToServer_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type SamplerToServer_ConfRes struct {
	// Responses
	ConfRes *ServerSamplerConfRes `protobuf:"bytes,7,opt,name=conf_res,json=confRes,proto3,oneof"`
}

type SamplerToServer_RegisterReq struct {
	// Requests
	RegisterReq *SamplerRegisterReq `protobuf:"bytes,6,opt,name=register_req,json=registerReq,proto3,oneof"`
}

type SamplerToServer_SamplerStatsMsg struct {
	// Messages
	SamplerStatsMsg *SamplerStatsMsg `protobuf:"bytes,5,opt,name=sampler_stats_msg,json=samplerStatsMsg,proto3,oneof"`
}

type Sampler_Tag struct {
	Name  string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Attrs map[string]string `` /* 151-byte string literal not displayed */
	// contains filtered or unexported fields
}

type Sampling struct {

	// Types that are assignable to Sampling:
	//	*Sampling_DeterministicSampling
	Sampling isSampling_Sampling `protobuf_oneof:"Sampling"`
	// contains filtered or unexported fields
}

type Sampling_DeterministicSampling struct {
	DeterministicSampling *DeterministicSampling `protobuf:"bytes,1,opt,name=deterministic_sampling,json=deterministicSampling,proto3,oneof"`
}

type Schema struct {
	Type   Schema_Type `protobuf:"varint,1,opt,name=type,proto3,enum=Schema_Type" json:"type,omitempty"`
	Schema *anypb.Any  `protobuf:"bytes,2,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

type Schema_Type int32

type ServerSamplerConfReq struct {

	// The Sampler configuration.
	SamplerConfig *SamplerConfig `protobuf:"bytes,1,opt,name=sampler_config,json=samplerConfig,proto3" json:"sampler_config,omitempty"`
	// contains filtered or unexported fields
}

type ServerSamplerConfRes struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

type ServerToClient struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ServerUid string                 `protobuf:"bytes,2,opt,name=server_uid,json=serverUid,proto3" json:"server_uid,omitempty"`
	// Types that are assignable to Message:
	//	*ServerToClient_SamplerStatsMsg
	//	*ServerToClient_RegisterRes
	//	*ServerToClient_ListSamplersRes
	//	*ServerToClient_SamplerConfRes
	Message isServerToClient_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type ServerToClient_ListSamplersRes struct {
	ListSamplersRes *ClientListSamplersRes `protobuf:"bytes,5,opt,name=list_samplers_res,json=listSamplersRes,proto3,oneof"`
}

type ServerToClient_RegisterRes struct {
	// Responses
	RegisterRes *ClientRegisterRes `protobuf:"bytes,4,opt,name=register_res,json=registerRes,proto3,oneof"`
}

type ServerToClient_SamplerConfRes struct {
	SamplerConfRes *ClientSamplerConfRes `protobuf:"bytes,6,opt,name=sampler_conf_res,json=samplerConfRes,proto3,oneof"`
}

type ServerToClient_SamplerStatsMsg struct {
	// Messages
	SamplerStatsMsg *ClientSamplerStatsMsg `protobuf:"bytes,3,opt,name=sampler_stats_msg,json=samplerStatsMsg,proto3,oneof"`
}

type ServerToSampler struct {
	Timestamp *timestamppb.Timestamp `protobuf:"bytes,1,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	ServerUid string                 `protobuf:"bytes,2,opt,name=server_uid,json=serverUid,proto3" json:"server_uid,omitempty"`
	// Types that are assignable to Message:
	//	*ServerToSampler_RegisterRes
	//	*ServerToSampler_ConfReq
	Message isServerToSampler_Message `protobuf_oneof:"Message"`
	// contains filtered or unexported fields
}

type ServerToSampler_ConfReq struct {
	// Requests
	ConfReq *ServerSamplerConfReq `protobuf:"bytes,4,opt,name=conf_req,json=confReq,proto3,oneof"`
}

type ServerToSampler_RegisterRes struct {
	// Responses
	RegisterRes *SamplerRegisterRes `protobuf:"bytes,3,opt,name=register_res,json=registerRes,proto3,oneof"`
}

type Status struct {
	Type         Status_Type `protobuf:"varint,1,opt,name=type,proto3,enum=Status_Type" json:"type,omitempty"`
	ErrorMessage string      `protobuf:"bytes,2,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
	// contains filtered or unexported fields
}

type Status_Type int32

type Stream struct {
	Uid              string `protobuf:"bytes,1,opt,name=uid,proto3" json:"uid,omitempty"`
	Name             string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Rule             *Rule  `protobuf:"bytes,3,opt,name=rule,proto3" json:"rule,omitempty"`
	ExportRawSamples bool   `protobuf:"varint,4,opt,name=export_raw_samples,json=exportRawSamples,proto3" json:"export_raw_samples,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedControlPlaneServer struct {
}

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