protos

package
v0.3.1 Latest Latest
Warning

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

 Go to latest Published: Feb 8, 2024 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	SampleType_name = map[int32]string{
		0: "UNKNOWN",
		1: "RAW",
		2: "STRUCT_DIGEST",
		3: "EVENT",
	}
	SampleType_value = map[string]int32{
		"UNKNOWN":       0,
		"RAW":           1,
		"STRUCT_DIGEST": 2,
		"EVENT":         3,
	}
)

Enum value maps for SampleType.

View Source 
var (
	Status_Type_name = map[int32]string{
		0: "UNKNOWN",
		1: "OK",
		2: "BAD_REQUEST",
	}
	Status_Type_value = map[string]int32{
		"UNKNOWN":     0,
		"OK":          1,
		"BAD_REQUEST": 2,
	}
)

Enum value maps for Status_Type.

View Source 
var (
	Rule_Language_name = map[int32]string{
		0: "UNKNOWN",
		1: "CEL",
	}
	Rule_Language_value = map[string]int32{
		"UNKNOWN": 0,
		"CEL":     1,
	}
)

Enum value maps for Rule_Language.

View Source 
var (
	Digest_Location_name = map[int32]string{
		0: "UNKNOWN",
		1: "SAMPLER",
		2: "COLLECTOR",
	}
	Digest_Location_value = map[string]int32{
		"UNKNOWN":   0,
		"SAMPLER":   1,
		"COLLECTOR": 2,
	}
)

Enum value maps for Digest_Location.

View Source 
var (
	Schema_Type_name = map[int32]string{
		0: "SCHEMALESS",
		1: "NATIVE",
		2: "PROTOBUF",
	}
	Schema_Type_value = map[string]int32{
		"SCHEMALESS": 0,
		"NATIVE":     1,
		"PROTOBUF":   2,
	}
)

Enum value maps for Schema_Type.

View Source 
var (
	ClientStreamUpdate_Op_name = map[int32]string{
		0: "UNKNOWN",
		1: "UPSERT",
		2: "DELETE",
	}
	ClientStreamUpdate_Op_value = map[string]int32{
		"UNKNOWN": 0,
		"UPSERT":  1,
		"DELETE":  2,
	}
)

Enum value maps for ClientStreamUpdate_Op.

View Source 
var (
	ClientDigestUpdate_Op_name = map[int32]string{
		0: "UNKNOWN",
		1: "UPSERT",
		2: "DELETE",
	}
	ClientDigestUpdate_Op_value = map[string]int32{
		"UNKNOWN": 0,
		"UPSERT":  1,
		"DELETE":  2,
	}
)

Enum value maps for ClientDigestUpdate_Op.

View Source 
var (
	ClientEventUpdate_Op_name = map[int32]string{
		0: "UNKNOWN",
		1: "UPSERT",
		2: "DELETE",
	}
	ClientEventUpdate_Op_value = map[string]int32{
		"UNKNOWN": 0,
		"UPSERT":  1,
		"DELETE":  2,
	}
)

Enum value maps for ClientEventUpdate_Op.

View Source 
var ControlPlane_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "ControlPlane",
	HandlerType: (*ControlPlaneServer)(nil),
	Methods:     []grpc.MethodDesc{},
	Streams: []grpc.StreamDesc{
		{
			StreamName:    "SamplerConn",
			Handler:       _ControlPlane_SamplerConn_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
		{
			StreamName:    "ClientConn",
			Handler:       _ControlPlane_ClientConn_Handler,
			ServerStreams: true,
			ClientStreams: true,
		},
	},
	Metadata: "protos/controlplane.proto",
}

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

View Source 
var File_protos_controlplane_proto protoreflect.FileDescriptor

Functions

func RegisterControlPlaneServer 

func RegisterControlPlaneServer(s grpc.ServiceRegistrar, srv ControlPlaneServer)

Types

type ClientDigestUpdate added in v0.1.0 

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
}

func (*ClientDigestUpdate) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ClientDigestUpdate.ProtoReflect.Descriptor instead.

func (*ClientDigestUpdate) GetDigest added in v0.1.0 

func (x *ClientDigestUpdate) GetDigest() *Digest

func (*ClientDigestUpdate) GetOp added in v0.1.0 

func (x *ClientDigestUpdate) GetOp() ClientDigestUpdate_Op

func (*ClientDigestUpdate) ProtoMessage added in v0.1.0 

func (*ClientDigestUpdate) ProtoMessage()

func (*ClientDigestUpdate) ProtoReflect added in v0.1.0 

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

func (*ClientDigestUpdate) Reset added in v0.1.0 

func (x *ClientDigestUpdate) Reset()

func (*ClientDigestUpdate) String added in v0.1.0 

func (x *ClientDigestUpdate) String() string

type ClientDigestUpdate_Op added in v0.1.0 

type ClientDigestUpdate_Op int32
const (
	ClientDigestUpdate_UNKNOWN ClientDigestUpdate_Op = 0
	ClientDigestUpdate_UPSERT  ClientDigestUpdate_Op = 1
	ClientDigestUpdate_DELETE  ClientDigestUpdate_Op = 2
)

func (ClientDigestUpdate_Op) Descriptor added in v0.1.0 

func (ClientDigestUpdate_Op) Descriptor() protoreflect.EnumDescriptor

func (ClientDigestUpdate_Op) Enum added in v0.1.0 

func (x ClientDigestUpdate_Op) Enum() *ClientDigestUpdate_Op

func (ClientDigestUpdate_Op) EnumDescriptor deprecated added in v0.1.0 

func (ClientDigestUpdate_Op) EnumDescriptor() ([]byte, []int)

Deprecated: Use ClientDigestUpdate_Op.Descriptor instead.

func (ClientDigestUpdate_Op) Number added in v0.1.0 

func (x ClientDigestUpdate_Op) Number() protoreflect.EnumNumber

func (ClientDigestUpdate_Op) String added in v0.1.0 

func (x ClientDigestUpdate_Op) String() string

func (ClientDigestUpdate_Op) Type added in v0.1.0 

func (ClientDigestUpdate_Op) Type() protoreflect.EnumType

type ClientEventUpdate added in v0.1.0 

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
}

func (*ClientEventUpdate) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ClientEventUpdate.ProtoReflect.Descriptor instead.

func (*ClientEventUpdate) GetEvent added in v0.1.0 

func (x *ClientEventUpdate) GetEvent() *Event

func (*ClientEventUpdate) GetOp added in v0.1.0 

func (x *ClientEventUpdate) GetOp() ClientEventUpdate_Op

func (*ClientEventUpdate) ProtoMessage added in v0.1.0 

func (*ClientEventUpdate) ProtoMessage()

func (*ClientEventUpdate) ProtoReflect added in v0.1.0 

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

func (*ClientEventUpdate) Reset added in v0.1.0 

func (x *ClientEventUpdate) Reset()

func (*ClientEventUpdate) String added in v0.1.0 

func (x *ClientEventUpdate) String() string

type ClientEventUpdate_Op added in v0.1.0 

type ClientEventUpdate_Op int32
const (
	ClientEventUpdate_UNKNOWN ClientEventUpdate_Op = 0
	ClientEventUpdate_UPSERT  ClientEventUpdate_Op = 1
	ClientEventUpdate_DELETE  ClientEventUpdate_Op = 2
)

func (ClientEventUpdate_Op) Descriptor added in v0.1.0 

func (ClientEventUpdate_Op) Descriptor() protoreflect.EnumDescriptor

func (ClientEventUpdate_Op) Enum added in v0.1.0 

func (x ClientEventUpdate_Op) Enum() *ClientEventUpdate_Op

func (ClientEventUpdate_Op) EnumDescriptor deprecated added in v0.1.0 

func (ClientEventUpdate_Op) EnumDescriptor() ([]byte, []int)

Deprecated: Use ClientEventUpdate_Op.Descriptor instead.

func (ClientEventUpdate_Op) Number added in v0.1.0 

func (x ClientEventUpdate_Op) Number() protoreflect.EnumNumber

func (ClientEventUpdate_Op) String added in v0.1.0 

func (x ClientEventUpdate_Op) String() string

func (ClientEventUpdate_Op) Type added in v0.1.0 

func (ClientEventUpdate_Op) Type() protoreflect.EnumType

type ClientListSamplersReq 

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

func (*ClientListSamplersReq) Descriptor deprecated 

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

Deprecated: Use ClientListSamplersReq.ProtoReflect.Descriptor instead.

func (*ClientListSamplersReq) ProtoMessage 

func (*ClientListSamplersReq) ProtoMessage()

func (*ClientListSamplersReq) ProtoReflect 

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

func (*ClientListSamplersReq) Reset 

func (x *ClientListSamplersReq) Reset()

func (*ClientListSamplersReq) String 

func (x *ClientListSamplersReq) String() string

type ClientListSamplersRes 

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
}

func (*ClientListSamplersRes) Descriptor deprecated 

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

Deprecated: Use ClientListSamplersRes.ProtoReflect.Descriptor instead.

func (*ClientListSamplersRes) GetSamplers 

func (x *ClientListSamplersRes) GetSamplers() []*Sampler

func (*ClientListSamplersRes) GetStatus 

func (x *ClientListSamplersRes) GetStatus() *Status

func (*ClientListSamplersRes) ProtoMessage 

func (*ClientListSamplersRes) ProtoMessage()

func (*ClientListSamplersRes) ProtoReflect 

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

func (*ClientListSamplersRes) Reset 

func (x *ClientListSamplersRes) Reset()

func (*ClientListSamplersRes) String 

func (x *ClientListSamplersRes) String() string

type ClientRegisterReq 

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

func (*ClientRegisterReq) Descriptor deprecated 

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

Deprecated: Use ClientRegisterReq.ProtoReflect.Descriptor instead.

func (*ClientRegisterReq) GetTags 

func (x *ClientRegisterReq) GetTags() map[string]string

func (*ClientRegisterReq) ProtoMessage 

func (*ClientRegisterReq) ProtoMessage()

func (*ClientRegisterReq) ProtoReflect 

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

func (*ClientRegisterReq) Reset 

func (x *ClientRegisterReq) Reset()

func (*ClientRegisterReq) String 

func (x *ClientRegisterReq) String() string

type ClientRegisterRes 

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

func (*ClientRegisterRes) Descriptor deprecated 

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

Deprecated: Use ClientRegisterRes.ProtoReflect.Descriptor instead.

func (*ClientRegisterRes) GetStatus 

func (x *ClientRegisterRes) GetStatus() *Status

func (*ClientRegisterRes) ProtoMessage 

func (*ClientRegisterRes) ProtoMessage()

func (*ClientRegisterRes) ProtoReflect 

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

func (*ClientRegisterRes) Reset 

func (x *ClientRegisterRes) Reset()

func (*ClientRegisterRes) String 

func (x *ClientRegisterRes) String() string

type ClientSamplerConfReq 

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
}

func (*ClientSamplerConfReq) Descriptor deprecated 

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

Deprecated: Use ClientSamplerConfReq.ProtoReflect.Descriptor instead.

func (*ClientSamplerConfReq) GetSamplerConfigUpdate 

func (x *ClientSamplerConfReq) GetSamplerConfigUpdate() *ClientSamplerConfigUpdate

func (*ClientSamplerConfReq) GetSamplerName 

func (x *ClientSamplerConfReq) GetSamplerName() string

func (*ClientSamplerConfReq) GetSamplerResource 

func (x *ClientSamplerConfReq) GetSamplerResource() string

func (*ClientSamplerConfReq) ProtoMessage 

func (*ClientSamplerConfReq) ProtoMessage()

func (*ClientSamplerConfReq) ProtoReflect 

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

func (*ClientSamplerConfReq) Reset 

func (x *ClientSamplerConfReq) Reset()

func (*ClientSamplerConfReq) String 

func (x *ClientSamplerConfReq) String() string

type ClientSamplerConfRes 

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

func (*ClientSamplerConfRes) Descriptor deprecated 

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

Deprecated: Use ClientSamplerConfRes.ProtoReflect.Descriptor instead.

func (*ClientSamplerConfRes) GetStatus 

func (x *ClientSamplerConfRes) GetStatus() *Status

func (*ClientSamplerConfRes) ProtoMessage 

func (*ClientSamplerConfRes) ProtoMessage()

func (*ClientSamplerConfRes) ProtoReflect 

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

func (*ClientSamplerConfRes) Reset 

func (x *ClientSamplerConfRes) Reset()

func (*ClientSamplerConfRes) String 

func (x *ClientSamplerConfRes) String() string

type ClientSamplerConfigUpdate 

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
}

func (*ClientSamplerConfigUpdate) Descriptor deprecated 

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

Deprecated: Use ClientSamplerConfigUpdate.ProtoReflect.Descriptor instead.

func (*ClientSamplerConfigUpdate) GetDigestUpdates added in v0.1.0 

func (x *ClientSamplerConfigUpdate) GetDigestUpdates() []*ClientDigestUpdate

func (*ClientSamplerConfigUpdate) GetEventUpdates added in v0.1.0 

func (x *ClientSamplerConfigUpdate) GetEventUpdates() []*ClientEventUpdate

func (*ClientSamplerConfigUpdate) GetLimiterIn added in v0.1.0 

func (x *ClientSamplerConfigUpdate) GetLimiterIn() *Limiter

func (*ClientSamplerConfigUpdate) GetLimiterOut added in v0.1.0 

func (x *ClientSamplerConfigUpdate) GetLimiterOut() *Limiter

func (*ClientSamplerConfigUpdate) GetReset_ added in v0.1.0 

func (x *ClientSamplerConfigUpdate) GetReset_() *ClientSamplerConfigUpdate_Reset

func (*ClientSamplerConfigUpdate) GetSamplingIn added in v0.1.0 

func (x *ClientSamplerConfigUpdate) GetSamplingIn() *Sampling

func (*ClientSamplerConfigUpdate) GetStreamUpdates added in v0.1.0 

func (x *ClientSamplerConfigUpdate) GetStreamUpdates() []*ClientStreamUpdate

func (*ClientSamplerConfigUpdate) ProtoMessage 

func (*ClientSamplerConfigUpdate) ProtoMessage()

func (*ClientSamplerConfigUpdate) ProtoReflect 

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

func (*ClientSamplerConfigUpdate) Reset 

func (x *ClientSamplerConfigUpdate) Reset()

func (*ClientSamplerConfigUpdate) String 

func (x *ClientSamplerConfigUpdate) String() string

type ClientSamplerConfigUpdate_Reset added in v0.1.0 

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
}

If a field is set to true, it means that the field is reset to its default. If a configuration option is reset and set in the same request, it will be first resetted and then set to its new value.

func (*ClientSamplerConfigUpdate_Reset) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ClientSamplerConfigUpdate_Reset.ProtoReflect.Descriptor instead.

func (*ClientSamplerConfigUpdate_Reset) GetDigests added in v0.1.0 

func (x *ClientSamplerConfigUpdate_Reset) GetDigests() bool

func (*ClientSamplerConfigUpdate_Reset) GetEvents added in v0.1.0 

func (x *ClientSamplerConfigUpdate_Reset) GetEvents() bool

func (*ClientSamplerConfigUpdate_Reset) GetLimiterIn added in v0.1.0 

func (x *ClientSamplerConfigUpdate_Reset) GetLimiterIn() bool

func (*ClientSamplerConfigUpdate_Reset) GetLimiterOut added in v0.1.0 

func (x *ClientSamplerConfigUpdate_Reset) GetLimiterOut() bool

func (*ClientSamplerConfigUpdate_Reset) GetSamplingIn added in v0.1.0 

func (x *ClientSamplerConfigUpdate_Reset) GetSamplingIn() bool

func (*ClientSamplerConfigUpdate_Reset) GetStreams added in v0.1.0 

func (x *ClientSamplerConfigUpdate_Reset) GetStreams() bool

func (*ClientSamplerConfigUpdate_Reset) ProtoMessage added in v0.1.0 

func (*ClientSamplerConfigUpdate_Reset) ProtoMessage()

func (*ClientSamplerConfigUpdate_Reset) ProtoReflect added in v0.1.0 

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

func (*ClientSamplerConfigUpdate_Reset) Reset added in v0.1.0 

func (x *ClientSamplerConfigUpdate_Reset) Reset()

func (*ClientSamplerConfigUpdate_Reset) String added in v0.1.0 

func (x *ClientSamplerConfigUpdate_Reset) String() string

type ClientSamplerStats 

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
}

func (*ClientSamplerStats) Descriptor deprecated 

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

Deprecated: Use ClientSamplerStats.ProtoReflect.Descriptor instead.

func (*ClientSamplerStats) GetSamplerUid 

func (x *ClientSamplerStats) GetSamplerUid() string

func (*ClientSamplerStats) GetSamplingStats 

func (x *ClientSamplerStats) GetSamplingStats() *SamplerSamplingStats

func (*ClientSamplerStats) ProtoMessage 

func (*ClientSamplerStats) ProtoMessage()

func (*ClientSamplerStats) ProtoReflect 

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

func (*ClientSamplerStats) Reset 

func (x *ClientSamplerStats) Reset()

func (*ClientSamplerStats) String 

func (x *ClientSamplerStats) String() string

type ClientSamplerStatsMsg 

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

func (*ClientSamplerStatsMsg) Descriptor deprecated 

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

Deprecated: Use ClientSamplerStatsMsg.ProtoReflect.Descriptor instead.

func (*ClientSamplerStatsMsg) GetSamplerStats 

func (x *ClientSamplerStatsMsg) GetSamplerStats() []*ClientSamplerStats

func (*ClientSamplerStatsMsg) ProtoMessage 

func (*ClientSamplerStatsMsg) ProtoMessage()

func (*ClientSamplerStatsMsg) ProtoReflect 

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

func (*ClientSamplerStatsMsg) Reset 

func (x *ClientSamplerStatsMsg) Reset()

func (*ClientSamplerStatsMsg) String 

func (x *ClientSamplerStatsMsg) String() string

type ClientStreamUpdate added in v0.1.0 

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
}

func (*ClientStreamUpdate) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ClientStreamUpdate.ProtoReflect.Descriptor instead.

func (*ClientStreamUpdate) GetOp added in v0.1.0 

func (x *ClientStreamUpdate) GetOp() ClientStreamUpdate_Op

func (*ClientStreamUpdate) GetStream added in v0.1.0 

func (x *ClientStreamUpdate) GetStream() *Stream

func (*ClientStreamUpdate) ProtoMessage added in v0.1.0 

func (*ClientStreamUpdate) ProtoMessage()

func (*ClientStreamUpdate) ProtoReflect added in v0.1.0 

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

func (*ClientStreamUpdate) Reset added in v0.1.0 

func (x *ClientStreamUpdate) Reset()

func (*ClientStreamUpdate) String added in v0.1.0 

func (x *ClientStreamUpdate) String() string

type ClientStreamUpdate_Op added in v0.1.0 

type ClientStreamUpdate_Op int32
const (
	ClientStreamUpdate_UNKNOWN ClientStreamUpdate_Op = 0
	ClientStreamUpdate_UPSERT  ClientStreamUpdate_Op = 1
	ClientStreamUpdate_DELETE  ClientStreamUpdate_Op = 2
)

func (ClientStreamUpdate_Op) Descriptor added in v0.1.0 

func (ClientStreamUpdate_Op) Descriptor() protoreflect.EnumDescriptor

func (ClientStreamUpdate_Op) Enum added in v0.1.0 

func (x ClientStreamUpdate_Op) Enum() *ClientStreamUpdate_Op

func (ClientStreamUpdate_Op) EnumDescriptor deprecated added in v0.1.0 

func (ClientStreamUpdate_Op) EnumDescriptor() ([]byte, []int)

Deprecated: Use ClientStreamUpdate_Op.Descriptor instead.

func (ClientStreamUpdate_Op) Number added in v0.1.0 

func (x ClientStreamUpdate_Op) Number() protoreflect.EnumNumber

func (ClientStreamUpdate_Op) String added in v0.1.0 

func (x ClientStreamUpdate_Op) String() string

func (ClientStreamUpdate_Op) Type added in v0.1.0 

func (ClientStreamUpdate_Op) Type() protoreflect.EnumType

type ClientToServer 

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
}

func (*ClientToServer) Descriptor deprecated 

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

Deprecated: Use ClientToServer.ProtoReflect.Descriptor instead.

func (*ClientToServer) GetClientUid 

func (x *ClientToServer) GetClientUid() string

func (*ClientToServer) GetListSamplersReq 

func (x *ClientToServer) GetListSamplersReq() *ClientListSamplersReq

func (*ClientToServer) GetMessage 

func (m *ClientToServer) GetMessage() isClientToServer_Message

func (*ClientToServer) GetRegisterReq 

func (x *ClientToServer) GetRegisterReq() *ClientRegisterReq

func (*ClientToServer) GetSamplerConfReq 

func (x *ClientToServer) GetSamplerConfReq() *ClientSamplerConfReq

func (*ClientToServer) GetTimestamp 

func (x *ClientToServer) GetTimestamp() *timestamppb.Timestamp

func (*ClientToServer) ProtoMessage 

func (*ClientToServer) ProtoMessage()

func (*ClientToServer) ProtoReflect 

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

func (*ClientToServer) Reset 

func (x *ClientToServer) Reset()

func (*ClientToServer) String 

func (x *ClientToServer) String() string

type ClientToServer_ListSamplersReq 

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

type ClientToServer_RegisterReq 

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

type ClientToServer_SamplerConfReq 

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

type ControlPlaneClient 

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

ControlPlaneClient is the client API for ControlPlane 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 NewControlPlaneClient 

func NewControlPlaneClient(cc grpc.ClientConnInterface) ControlPlaneClient

type ControlPlaneServer 

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

ControlPlaneServer is the server API for ControlPlane service. All implementations must embed UnimplementedControlPlaneServer for forward compatibility

type ControlPlane_ClientConnClient 

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

type ControlPlane_ClientConnServer 

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

type ControlPlane_SamplerConnClient 

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

type ControlPlane_SamplerConnServer 

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

type DeterministicSampling added in v0.1.0 

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
}

func (*DeterministicSampling) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use DeterministicSampling.ProtoReflect.Descriptor instead.

func (*DeterministicSampling) GetSampleEmptyDeterminant added in v0.1.0 

func (x *DeterministicSampling) GetSampleEmptyDeterminant() bool

func (*DeterministicSampling) GetSampleRate added in v0.1.0 

func (x *DeterministicSampling) GetSampleRate() int32

func (*DeterministicSampling) ProtoMessage added in v0.1.0 

func (*DeterministicSampling) ProtoMessage()

func (*DeterministicSampling) ProtoReflect added in v0.1.0 

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

func (*DeterministicSampling) Reset added in v0.1.0 

func (x *DeterministicSampling) Reset()

func (*DeterministicSampling) String added in v0.1.0 

func (x *DeterministicSampling) String() string

type Digest added in v0.1.0 

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
}

func (*Digest) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use Digest.ProtoReflect.Descriptor instead.

func (*Digest) GetBufferSize added in v0.1.0 

func (x *Digest) GetBufferSize() int32

func (*Digest) GetComputationLocation added in v0.1.0 

func (x *Digest) GetComputationLocation() Digest_Location

func (*Digest) GetFlushPeriod added in v0.1.0 

func (x *Digest) GetFlushPeriod() *durationpb.Duration

func (*Digest) GetName added in v0.1.0 

func (x *Digest) GetName() string

func (*Digest) GetSt added in v0.1.0 

func (x *Digest) GetSt() *Digest_St

func (*Digest) GetStreamUid added in v0.1.0 

func (x *Digest) GetStreamUid() string

func (*Digest) GetType added in v0.1.0 

func (m *Digest) GetType() isDigest_Type

func (*Digest) GetUid added in v0.1.0 

func (x *Digest) GetUid() string

func (*Digest) GetValue added in v0.1.0 

func (x *Digest) GetValue() *Digest_Value

func (*Digest) ProtoMessage added in v0.1.0 

func (*Digest) ProtoMessage()

func (*Digest) ProtoReflect added in v0.1.0 

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

func (*Digest) Reset added in v0.1.0 

func (x *Digest) Reset()

func (*Digest) String added in v0.1.0 

func (x *Digest) String() string

type Digest_Location added in v0.1.0 

type Digest_Location int32
const (
	Digest_UNKNOWN   Digest_Location = 0
	Digest_SAMPLER   Digest_Location = 1
	Digest_COLLECTOR Digest_Location = 2
)

func (Digest_Location) Descriptor added in v0.1.0 

func (Digest_Location) Descriptor() protoreflect.EnumDescriptor

func (Digest_Location) Enum added in v0.1.0 

func (x Digest_Location) Enum() *Digest_Location

func (Digest_Location) EnumDescriptor deprecated added in v0.1.0 

func (Digest_Location) EnumDescriptor() ([]byte, []int)

Deprecated: Use Digest_Location.Descriptor instead.

func (Digest_Location) Number added in v0.1.0 

func (x Digest_Location) Number() protoreflect.EnumNumber

func (Digest_Location) String added in v0.1.0 

func (x Digest_Location) String() string

func (Digest_Location) Type added in v0.1.0 

func (Digest_Location) Type() protoreflect.EnumType

type Digest_St added in v0.1.0 

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
}

func (*Digest_St) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use Digest_St.ProtoReflect.Descriptor instead.

func (*Digest_St) GetMaxProcessedFields added in v0.1.0 

func (x *Digest_St) GetMaxProcessedFields() int32

func (*Digest_St) ProtoMessage added in v0.1.0 

func (*Digest_St) ProtoMessage()

func (*Digest_St) ProtoReflect added in v0.1.0 

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

func (*Digest_St) Reset added in v0.1.0 

func (x *Digest_St) Reset()

func (*Digest_St) String added in v0.1.0 

func (x *Digest_St) String() string

type Digest_St_ added in v0.1.0 

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

type Digest_Value added in v0.1.0 

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
}

func (*Digest_Value) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use Digest_Value.ProtoReflect.Descriptor instead.

func (*Digest_Value) GetMaxProcessedFields added in v0.1.0 

func (x *Digest_Value) GetMaxProcessedFields() int32

func (*Digest_Value) ProtoMessage added in v0.1.0 

func (*Digest_Value) ProtoMessage()

func (*Digest_Value) ProtoReflect added in v0.1.0 

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

func (*Digest_Value) Reset added in v0.1.0 

func (x *Digest_Value) Reset()

func (*Digest_Value) String added in v0.1.0 

func (x *Digest_Value) String() string

type Digest_Value_ added in v0.1.0 

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

type Event added in v0.1.0 

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
}

func (*Event) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use Event.ProtoReflect.Descriptor instead.

func (*Event) GetExportTemplate added in v0.3.0 

func (x *Event) GetExportTemplate() string

func (*Event) GetLimiter added in v0.1.0 

func (x *Event) GetLimiter() *Limiter

func (*Event) GetName added in v0.1.0 

func (x *Event) GetName() string

func (*Event) GetRule added in v0.1.0 

func (x *Event) GetRule() *Rule

func (*Event) GetSampleType added in v0.1.0 

func (x *Event) GetSampleType() SampleType

func (*Event) GetStreamUid added in v0.1.0 

func (x *Event) GetStreamUid() string

func (*Event) GetUid added in v0.1.0 

func (x *Event) GetUid() string

func (*Event) ProtoMessage added in v0.1.0 

func (*Event) ProtoMessage()

func (*Event) ProtoReflect added in v0.1.0 

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

func (*Event) Reset added in v0.1.0 

func (x *Event) Reset()

func (*Event) String added in v0.1.0 

func (x *Event) String() string

type Limiter added in v0.1.0 

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
}

func (*Limiter) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use Limiter.ProtoReflect.Descriptor instead.

func (*Limiter) GetLimit added in v0.1.0 

func (x *Limiter) GetLimit() int32

func (*Limiter) ProtoMessage added in v0.1.0 

func (*Limiter) ProtoMessage()

func (*Limiter) ProtoReflect added in v0.1.0 

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

func (*Limiter) Reset added in v0.1.0 

func (x *Limiter) Reset()

func (*Limiter) String added in v0.1.0 

func (x *Limiter) String() string

type Rule added in v0.1.0 

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
}

func (*Rule) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use Rule.ProtoReflect.Descriptor instead.

func (*Rule) GetExpression added in v0.1.0 

func (x *Rule) GetExpression() string

func (*Rule) GetLanguage added in v0.1.0 

func (x *Rule) GetLanguage() Rule_Language

func (*Rule) ProtoMessage added in v0.1.0 

func (*Rule) ProtoMessage()

func (*Rule) ProtoReflect added in v0.1.0 

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

func (*Rule) Reset added in v0.1.0 

func (x *Rule) Reset()

func (*Rule) String added in v0.1.0 

func (x *Rule) String() string

type Rule_Language added in v0.1.0 

type Rule_Language int32
const (
	Rule_UNKNOWN Rule_Language = 0
	Rule_CEL     Rule_Language = 1
)

func (Rule_Language) Descriptor added in v0.1.0 

func (Rule_Language) Descriptor() protoreflect.EnumDescriptor

func (Rule_Language) Enum added in v0.1.0 

func (x Rule_Language) Enum() *Rule_Language

func (Rule_Language) EnumDescriptor deprecated added in v0.1.0 

func (Rule_Language) EnumDescriptor() ([]byte, []int)

Deprecated: Use Rule_Language.Descriptor instead.

func (Rule_Language) Number added in v0.1.0 

func (x Rule_Language) Number() protoreflect.EnumNumber

func (Rule_Language) String added in v0.1.0 

func (x Rule_Language) String() string

func (Rule_Language) Type added in v0.1.0 

func (Rule_Language) Type() protoreflect.EnumType

type SampleType added in v0.1.0 

type SampleType int32
const (
	SampleType_UNKNOWN       SampleType = 0
	SampleType_RAW           SampleType = 1
	SampleType_STRUCT_DIGEST SampleType = 2
	SampleType_EVENT         SampleType = 3
)

func (SampleType) Descriptor added in v0.1.0 

func (SampleType) Descriptor() protoreflect.EnumDescriptor

func (SampleType) Enum added in v0.1.0 

func (x SampleType) Enum() *SampleType

func (SampleType) EnumDescriptor deprecated added in v0.1.0 

func (SampleType) EnumDescriptor() ([]byte, []int)

Deprecated: Use SampleType.Descriptor instead.

func (SampleType) Number added in v0.1.0 

func (x SampleType) Number() protoreflect.EnumNumber

func (SampleType) String added in v0.1.0 

func (x SampleType) String() string

func (SampleType) Type added in v0.1.0 

func (SampleType) Type() protoreflect.EnumType

type Sampler 

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
}

func (*Sampler) Descriptor deprecated 

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

Deprecated: Use Sampler.ProtoReflect.Descriptor instead.

func (*Sampler) GetConfig 

func (x *Sampler) GetConfig() *SamplerConfig

func (*Sampler) GetName 

func (x *Sampler) GetName() string

func (*Sampler) GetResource 

func (x *Sampler) GetResource() string

func (*Sampler) GetSamplingStats 

func (x *Sampler) GetSamplingStats() *SamplerSamplingStats

func (*Sampler) GetSchema 

func (x *Sampler) GetSchema() *Schema

func (*Sampler) GetTags added in v0.3.0 

func (x *Sampler) GetTags() []*Sampler_Tag

func (*Sampler) GetUid 

func (x *Sampler) GetUid() string

func (*Sampler) ProtoMessage 

func (*Sampler) ProtoMessage()

func (*Sampler) ProtoReflect 

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

func (*Sampler) Reset 

func (x *Sampler) Reset()

func (*Sampler) String 

func (x *Sampler) String() string

type SamplerConfig 

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
}

Used to get and update the sampler configuration.

When sent by the server to update a sampler, only the fields that are present are updated. If a field is present, the previous value is replaced with the new one.

If the configuration option is configured from the client the process is as follows:

  • Add new option to SamplerConfig
  • Update platform/controlplane/data package to include new option to the internal controlplane structs
  • Make sure new option can be set with the ClientSamplerConfigUpdate message
  • Update at package platform/controlplane/server/internal/registry the method Client.UpdateSamplerConfig so the new option gets set in the server registry
  • Update neblictl if the option can be configured using the CLI

func (*SamplerConfig) Descriptor deprecated 

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

Deprecated: Use SamplerConfig.ProtoReflect.Descriptor instead.

func (*SamplerConfig) GetDigests added in v0.1.0 

func (x *SamplerConfig) GetDigests() []*Digest

func (*SamplerConfig) GetEvents added in v0.1.0 

func (x *SamplerConfig) GetEvents() []*Event

func (*SamplerConfig) GetLimiterIn added in v0.1.0 

func (x *SamplerConfig) GetLimiterIn() *Limiter

func (*SamplerConfig) GetLimiterOut added in v0.1.0 

func (x *SamplerConfig) GetLimiterOut() *Limiter

func (*SamplerConfig) GetSamplingIn added in v0.1.0 

func (x *SamplerConfig) GetSamplingIn() *Sampling

func (*SamplerConfig) GetStreams added in v0.1.0 

func (x *SamplerConfig) GetStreams() []*Stream

func (*SamplerConfig) ProtoMessage 

func (*SamplerConfig) ProtoMessage()

func (*SamplerConfig) ProtoReflect 

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

func (*SamplerConfig) Reset 

func (x *SamplerConfig) Reset()

func (*SamplerConfig) String 

func (x *SamplerConfig) String() string

type SamplerRegisterReq 

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
}

func (*SamplerRegisterReq) Descriptor deprecated 

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

Deprecated: Use SamplerRegisterReq.ProtoReflect.Descriptor instead.

func (*SamplerRegisterReq) GetInitialConfig added in v0.3.0 

func (x *SamplerRegisterReq) GetInitialConfig() *ClientSamplerConfigUpdate

func (*SamplerRegisterReq) GetTags 

func (x *SamplerRegisterReq) GetTags() []*Sampler_Tag

func (*SamplerRegisterReq) ProtoMessage 

func (*SamplerRegisterReq) ProtoMessage()

func (*SamplerRegisterReq) ProtoReflect 

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

func (*SamplerRegisterReq) Reset 

func (x *SamplerRegisterReq) Reset()

func (*SamplerRegisterReq) String 

func (x *SamplerRegisterReq) String() string

type SamplerRegisterRes 

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

func (*SamplerRegisterRes) Descriptor deprecated 

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

Deprecated: Use SamplerRegisterRes.ProtoReflect.Descriptor instead.

func (*SamplerRegisterRes) GetStatus 

func (x *SamplerRegisterRes) GetStatus() *Status

func (*SamplerRegisterRes) ProtoMessage 

func (*SamplerRegisterRes) ProtoMessage()

func (*SamplerRegisterRes) ProtoReflect 

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

func (*SamplerRegisterRes) Reset 

func (x *SamplerRegisterRes) Reset()

func (*SamplerRegisterRes) String 

func (x *SamplerRegisterRes) String() string

type SamplerSamplingStats 

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
}

func (*SamplerSamplingStats) Descriptor deprecated 

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

Deprecated: Use SamplerSamplingStats.ProtoReflect.Descriptor instead.

func (*SamplerSamplingStats) GetSamplesDigested added in v0.1.0 

func (x *SamplerSamplingStats) GetSamplesDigested() uint64

func (*SamplerSamplingStats) GetSamplesEvaluated 

func (x *SamplerSamplingStats) GetSamplesEvaluated() uint64

func (*SamplerSamplingStats) GetSamplesExported 

func (x *SamplerSamplingStats) GetSamplesExported() uint64

func (*SamplerSamplingStats) ProtoMessage 

func (*SamplerSamplingStats) ProtoMessage()

func (*SamplerSamplingStats) ProtoReflect 

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

func (*SamplerSamplingStats) Reset 

func (x *SamplerSamplingStats) Reset()

func (*SamplerSamplingStats) String 

func (x *SamplerSamplingStats) String() string

type SamplerStatsMsg 

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

func (*SamplerStatsMsg) Descriptor deprecated 

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

Deprecated: Use SamplerStatsMsg.ProtoReflect.Descriptor instead.

func (*SamplerStatsMsg) GetSamplingStats 

func (x *SamplerStatsMsg) GetSamplingStats() *SamplerSamplingStats

func (*SamplerStatsMsg) ProtoMessage 

func (*SamplerStatsMsg) ProtoMessage()

func (*SamplerStatsMsg) ProtoReflect 

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

func (*SamplerStatsMsg) Reset 

func (x *SamplerStatsMsg) Reset()

func (*SamplerStatsMsg) String 

func (x *SamplerStatsMsg) String() string

type SamplerToServer 

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
}

func (*SamplerToServer) Descriptor deprecated 

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

Deprecated: Use SamplerToServer.ProtoReflect.Descriptor instead.

func (*SamplerToServer) GetConfRes 

func (x *SamplerToServer) GetConfRes() *ServerSamplerConfRes

func (*SamplerToServer) GetMessage 

func (m *SamplerToServer) GetMessage() isSamplerToServer_Message

func (*SamplerToServer) GetName added in v0.1.0 

func (x *SamplerToServer) GetName() string

func (*SamplerToServer) GetRegisterReq 

func (x *SamplerToServer) GetRegisterReq() *SamplerRegisterReq

func (*SamplerToServer) GetResouce added in v0.1.0 

func (x *SamplerToServer) GetResouce() string

func (*SamplerToServer) GetSamplerStatsMsg 

func (x *SamplerToServer) GetSamplerStatsMsg() *SamplerStatsMsg

func (*SamplerToServer) GetSamplerUid 

func (x *SamplerToServer) GetSamplerUid() string

func (*SamplerToServer) GetTimestamp 

func (x *SamplerToServer) GetTimestamp() *timestamppb.Timestamp

func (*SamplerToServer) ProtoMessage 

func (*SamplerToServer) ProtoMessage()

func (*SamplerToServer) ProtoReflect 

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

func (*SamplerToServer) Reset 

func (x *SamplerToServer) Reset()

func (*SamplerToServer) String 

func (x *SamplerToServer) String() string

type SamplerToServer_ConfRes 

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

type SamplerToServer_RegisterReq 

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

type SamplerToServer_SamplerStatsMsg 

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

type Sampler_Tag added in v0.3.0 

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
}

func (*Sampler_Tag) Descriptor deprecated added in v0.3.0 

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

Deprecated: Use Sampler_Tag.ProtoReflect.Descriptor instead.

func (*Sampler_Tag) GetAttrs added in v0.3.0 

func (x *Sampler_Tag) GetAttrs() map[string]string

func (*Sampler_Tag) GetName added in v0.3.0 

func (x *Sampler_Tag) GetName() string

func (*Sampler_Tag) ProtoMessage added in v0.3.0 

func (*Sampler_Tag) ProtoMessage()

func (*Sampler_Tag) ProtoReflect added in v0.3.0 

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

func (*Sampler_Tag) Reset added in v0.3.0 

func (x *Sampler_Tag) Reset()

func (*Sampler_Tag) String added in v0.3.0 

func (x *Sampler_Tag) String() string

type Sampling added in v0.1.0 

type Sampling struct {

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

func (*Sampling) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use Sampling.ProtoReflect.Descriptor instead.

func (*Sampling) GetDeterministicSampling added in v0.1.0 

func (x *Sampling) GetDeterministicSampling() *DeterministicSampling

func (*Sampling) GetSampling added in v0.1.0 

func (m *Sampling) GetSampling() isSampling_Sampling

func (*Sampling) ProtoMessage added in v0.1.0 

func (*Sampling) ProtoMessage()

func (*Sampling) ProtoReflect added in v0.1.0 

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

func (*Sampling) Reset added in v0.1.0 

func (x *Sampling) Reset()

func (*Sampling) String added in v0.1.0 

func (x *Sampling) String() string

type Sampling_DeterministicSampling added in v0.1.0 

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

type Schema 

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
}

func (*Schema) Descriptor deprecated 

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

Deprecated: Use Schema.ProtoReflect.Descriptor instead.

func (*Schema) GetSchema 

func (x *Schema) GetSchema() *anypb.Any

func (*Schema) GetType 

func (x *Schema) GetType() Schema_Type

func (*Schema) ProtoMessage 

func (*Schema) ProtoMessage()

func (*Schema) ProtoReflect 

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

func (*Schema) Reset 

func (x *Schema) Reset()

func (*Schema) String 

func (x *Schema) String() string

type Schema_Type 

type Schema_Type int32
const (
	Schema_SCHEMALESS Schema_Type = 0
	Schema_NATIVE     Schema_Type = 1
	Schema_PROTOBUF   Schema_Type = 2
)

func (Schema_Type) Descriptor 

func (Schema_Type) Descriptor() protoreflect.EnumDescriptor

func (Schema_Type) Enum 

func (x Schema_Type) Enum() *Schema_Type

func (Schema_Type) EnumDescriptor deprecated 

func (Schema_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Schema_Type.Descriptor instead.

func (Schema_Type) Number 

func (x Schema_Type) Number() protoreflect.EnumNumber

func (Schema_Type) String 

func (x Schema_Type) String() string

func (Schema_Type) Type 

func (Schema_Type) Type() protoreflect.EnumType

type ServerSamplerConfReq added in v0.1.0 

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
}

func (*ServerSamplerConfReq) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ServerSamplerConfReq.ProtoReflect.Descriptor instead.

func (*ServerSamplerConfReq) GetSamplerConfig added in v0.1.0 

func (x *ServerSamplerConfReq) GetSamplerConfig() *SamplerConfig

func (*ServerSamplerConfReq) ProtoMessage added in v0.1.0 

func (*ServerSamplerConfReq) ProtoMessage()

func (*ServerSamplerConfReq) ProtoReflect added in v0.1.0 

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

func (*ServerSamplerConfReq) Reset added in v0.1.0 

func (x *ServerSamplerConfReq) Reset()

func (*ServerSamplerConfReq) String added in v0.1.0 

func (x *ServerSamplerConfReq) String() string

type ServerSamplerConfRes added in v0.1.0 

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

func (*ServerSamplerConfRes) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use ServerSamplerConfRes.ProtoReflect.Descriptor instead.

func (*ServerSamplerConfRes) GetStatus added in v0.1.0 

func (x *ServerSamplerConfRes) GetStatus() *Status

func (*ServerSamplerConfRes) ProtoMessage added in v0.1.0 

func (*ServerSamplerConfRes) ProtoMessage()

func (*ServerSamplerConfRes) ProtoReflect added in v0.1.0 

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

func (*ServerSamplerConfRes) Reset added in v0.1.0 

func (x *ServerSamplerConfRes) Reset()

func (*ServerSamplerConfRes) String added in v0.1.0 

func (x *ServerSamplerConfRes) String() string

type ServerToClient 

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
}

func (*ServerToClient) Descriptor deprecated 

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

Deprecated: Use ServerToClient.ProtoReflect.Descriptor instead.

func (*ServerToClient) GetListSamplersRes 

func (x *ServerToClient) GetListSamplersRes() *ClientListSamplersRes

func (*ServerToClient) GetMessage 

func (m *ServerToClient) GetMessage() isServerToClient_Message

func (*ServerToClient) GetRegisterRes 

func (x *ServerToClient) GetRegisterRes() *ClientRegisterRes

func (*ServerToClient) GetSamplerConfRes 

func (x *ServerToClient) GetSamplerConfRes() *ClientSamplerConfRes

func (*ServerToClient) GetSamplerStatsMsg 

func (x *ServerToClient) GetSamplerStatsMsg() *ClientSamplerStatsMsg

func (*ServerToClient) GetServerUid 

func (x *ServerToClient) GetServerUid() string

func (*ServerToClient) GetTimestamp 

func (x *ServerToClient) GetTimestamp() *timestamppb.Timestamp

func (*ServerToClient) ProtoMessage 

func (*ServerToClient) ProtoMessage()

func (*ServerToClient) ProtoReflect 

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

func (*ServerToClient) Reset 

func (x *ServerToClient) Reset()

func (*ServerToClient) String 

func (x *ServerToClient) String() string

type ServerToClient_ListSamplersRes 

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

type ServerToClient_RegisterRes 

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

type ServerToClient_SamplerConfRes 

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

type ServerToClient_SamplerStatsMsg 

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

type ServerToSampler 

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
}

func (*ServerToSampler) Descriptor deprecated 

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

Deprecated: Use ServerToSampler.ProtoReflect.Descriptor instead.

func (*ServerToSampler) GetConfReq 

func (x *ServerToSampler) GetConfReq() *ServerSamplerConfReq

func (*ServerToSampler) GetMessage 

func (m *ServerToSampler) GetMessage() isServerToSampler_Message

func (*ServerToSampler) GetRegisterRes 

func (x *ServerToSampler) GetRegisterRes() *SamplerRegisterRes

func (*ServerToSampler) GetServerUid 

func (x *ServerToSampler) GetServerUid() string

func (*ServerToSampler) GetTimestamp 

func (x *ServerToSampler) GetTimestamp() *timestamppb.Timestamp

func (*ServerToSampler) ProtoMessage 

func (*ServerToSampler) ProtoMessage()

func (*ServerToSampler) ProtoReflect 

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

func (*ServerToSampler) Reset 

func (x *ServerToSampler) Reset()

func (*ServerToSampler) String 

func (x *ServerToSampler) String() string

type ServerToSampler_ConfReq 

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

type ServerToSampler_RegisterRes 

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

type Status 

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
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetErrorMessage 

func (x *Status) GetErrorMessage() string

func (*Status) GetType 

func (x *Status) GetType() Status_Type

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type Status_Type 

type Status_Type int32
const (
	Status_UNKNOWN     Status_Type = 0
	Status_OK          Status_Type = 1
	Status_BAD_REQUEST Status_Type = 2
)

func (Status_Type) Descriptor 

func (Status_Type) Descriptor() protoreflect.EnumDescriptor

func (Status_Type) Enum 

func (x Status_Type) Enum() *Status_Type

func (Status_Type) EnumDescriptor deprecated 

func (Status_Type) EnumDescriptor() ([]byte, []int)

Deprecated: Use Status_Type.Descriptor instead.

func (Status_Type) Number 

func (x Status_Type) Number() protoreflect.EnumNumber

func (Status_Type) String 

func (x Status_Type) String() string

func (Status_Type) Type 

func (Status_Type) Type() protoreflect.EnumType

type Stream added in v0.1.0 

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
}

func (*Stream) Descriptor deprecated added in v0.1.0 

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

Deprecated: Use Stream.ProtoReflect.Descriptor instead.

func (*Stream) GetExportRawSamples added in v0.1.0 

func (x *Stream) GetExportRawSamples() bool

func (*Stream) GetName added in v0.1.0 

func (x *Stream) GetName() string

func (*Stream) GetRule added in v0.1.0 

func (x *Stream) GetRule() *Rule

func (*Stream) GetUid added in v0.1.0 

func (x *Stream) GetUid() string

func (*Stream) ProtoMessage added in v0.1.0 

func (*Stream) ProtoMessage()

func (*Stream) ProtoReflect added in v0.1.0 

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

func (*Stream) Reset added in v0.1.0 

func (x *Stream) Reset()

func (*Stream) String added in v0.1.0 

func (x *Stream) String() string

type UnimplementedControlPlaneServer 

type UnimplementedControlPlaneServer struct {
}

UnimplementedControlPlaneServer must be embedded to have forward compatible implementations.

func (UnimplementedControlPlaneServer) ClientConn 

func (UnimplementedControlPlaneServer) ClientConn(ControlPlane_ClientConnServer) error

func (UnimplementedControlPlaneServer) SamplerConn 

func (UnimplementedControlPlaneServer) SamplerConn(ControlPlane_SamplerConnServer) error

type UnsafeControlPlaneServer 

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

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

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.