distributedpb

package
v0.0.0-...-8540621 Latest Latest
Warning

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

 Go to latest Published: Nov 25, 2024 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthDistributedPlan        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowDistributedPlan          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupDistributedPlan = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type CarnotInfo 

type CarnotInfo struct {
	QueryBrokerAddress   string        `protobuf:"bytes,1,opt,name=query_broker_address,json=queryBrokerAddress,proto3" json:"query_broker_address,omitempty"`
	AgentID              *uuidpb.UUID  `protobuf:"bytes,10,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	HasGRPCServer        bool          `protobuf:"varint,2,opt,name=has_grpc_server,json=hasGrpcServer,proto3" json:"has_grpc_server,omitempty"`
	GRPCAddress          string        `protobuf:"bytes,3,opt,name=grpc_address,json=grpcAddress,proto3" json:"grpc_address,omitempty"`
	HasDataStore         bool          `protobuf:"varint,4,opt,name=has_data_store,json=hasDataStore,proto3" json:"has_data_store,omitempty"`
	ProcessesData        bool          `protobuf:"varint,5,opt,name=processes_data,json=processesData,proto3" json:"processes_data,omitempty"`
	AcceptsRemoteSources bool          `protobuf:"varint,6,opt,name=accepts_remote_sources,json=acceptsRemoteSources,proto3" json:"accepts_remote_sources,omitempty"`
	TableInfo            []*TableInfo  `protobuf:"bytes,7,rep,name=table_info,json=tableInfo,proto3" json:"table_info,omitempty"`
	ASID                 uint32        `protobuf:"varint,8,opt,name=asid,proto3" json:"asid,omitempty"`
	MetadataInfo         *MetadataInfo `protobuf:"bytes,9,opt,name=metadata_info,json=metadataInfo,proto3" json:"metadata_info,omitempty"`
	SSLTargetName        string        `protobuf:"bytes,11,opt,name=ssl_targetname,json=sslTargetname,proto3" json:"ssl_targetname,omitempty"`
}

func (*CarnotInfo) Descriptor 

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

func (*CarnotInfo) Equal 

func (this *CarnotInfo) Equal(that interface{}) bool

func (*CarnotInfo) GetASID 

func (m *CarnotInfo) GetASID() uint32

func (*CarnotInfo) GetAcceptsRemoteSources 

func (m *CarnotInfo) GetAcceptsRemoteSources() bool

func (*CarnotInfo) GetAgentID 

func (m *CarnotInfo) GetAgentID() *uuidpb.UUID

func (*CarnotInfo) GetGRPCAddress 

func (m *CarnotInfo) GetGRPCAddress() string

func (*CarnotInfo) GetHasDataStore 

func (m *CarnotInfo) GetHasDataStore() bool

func (*CarnotInfo) GetHasGRPCServer 

func (m *CarnotInfo) GetHasGRPCServer() bool

func (*CarnotInfo) GetMetadataInfo 

func (m *CarnotInfo) GetMetadataInfo() *MetadataInfo

func (*CarnotInfo) GetProcessesData 

func (m *CarnotInfo) GetProcessesData() bool

func (*CarnotInfo) GetQueryBrokerAddress 

func (m *CarnotInfo) GetQueryBrokerAddress() string

func (*CarnotInfo) GetSSLTargetName 

func (m *CarnotInfo) GetSSLTargetName() string

func (*CarnotInfo) GetTableInfo 

func (m *CarnotInfo) GetTableInfo() []*TableInfo

func (*CarnotInfo) GoString 

func (this *CarnotInfo) GoString() string

func (*CarnotInfo) Marshal 

func (m *CarnotInfo) Marshal() (dAtA []byte, err error)

func (*CarnotInfo) MarshalTo 

func (m *CarnotInfo) MarshalTo(dAtA []byte) (int, error)

func (*CarnotInfo) MarshalToSizedBuffer 

func (m *CarnotInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*CarnotInfo) ProtoMessage 

func (*CarnotInfo) ProtoMessage()

func (*CarnotInfo) Reset 

func (m *CarnotInfo) Reset()

func (*CarnotInfo) Size 

func (m *CarnotInfo) Size() (n int)

func (*CarnotInfo) String 

func (this *CarnotInfo) String() string

func (*CarnotInfo) Unmarshal 

func (m *CarnotInfo) Unmarshal(dAtA []byte) error

func (*CarnotInfo) XXX_DiscardUnknown 

func (m *CarnotInfo) XXX_DiscardUnknown()

func (*CarnotInfo) XXX_Marshal 

func (m *CarnotInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*CarnotInfo) XXX_Merge 

func (m *CarnotInfo) XXX_Merge(src proto.Message)

func (*CarnotInfo) XXX_Size 

func (m *CarnotInfo) XXX_Size() int

func (*CarnotInfo) XXX_Unmarshal 

func (m *CarnotInfo) XXX_Unmarshal(b []byte) error

type DebugInfo 

type DebugInfo struct {
	OtelDebugAttributes []*DebugInfo_OTelDebugAttribute `protobuf:"bytes,1,rep,name=otel_debug_attributes,json=otelDebugAttributes,proto3" json:"otel_debug_attributes,omitempty"`
}

func (*DebugInfo) Descriptor 

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

func (*DebugInfo) Equal 

func (this *DebugInfo) Equal(that interface{}) bool

func (*DebugInfo) GetOtelDebugAttributes 

func (m *DebugInfo) GetOtelDebugAttributes() []*DebugInfo_OTelDebugAttribute

func (*DebugInfo) GoString 

func (this *DebugInfo) GoString() string

func (*DebugInfo) Marshal 

func (m *DebugInfo) Marshal() (dAtA []byte, err error)

func (*DebugInfo) MarshalTo 

func (m *DebugInfo) MarshalTo(dAtA []byte) (int, error)

func (*DebugInfo) MarshalToSizedBuffer 

func (m *DebugInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DebugInfo) ProtoMessage 

func (*DebugInfo) ProtoMessage()

func (*DebugInfo) Reset 

func (m *DebugInfo) Reset()

func (*DebugInfo) Size 

func (m *DebugInfo) Size() (n int)

func (*DebugInfo) String 

func (this *DebugInfo) String() string

func (*DebugInfo) Unmarshal 

func (m *DebugInfo) Unmarshal(dAtA []byte) error

func (*DebugInfo) XXX_DiscardUnknown 

func (m *DebugInfo) XXX_DiscardUnknown()

func (*DebugInfo) XXX_Marshal 

func (m *DebugInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DebugInfo) XXX_Merge 

func (m *DebugInfo) XXX_Merge(src proto.Message)

func (*DebugInfo) XXX_Size 

func (m *DebugInfo) XXX_Size() int

func (*DebugInfo) XXX_Unmarshal 

func (m *DebugInfo) XXX_Unmarshal(b []byte) error

type DebugInfo_OTelDebugAttribute 

type DebugInfo_OTelDebugAttribute struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Value string `protobuf:"bytes,2,opt,name=value,proto3" json:"value,omitempty"`
}

func (*DebugInfo_OTelDebugAttribute) Descriptor 

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

func (*DebugInfo_OTelDebugAttribute) Equal 

func (this *DebugInfo_OTelDebugAttribute) Equal(that interface{}) bool

func (*DebugInfo_OTelDebugAttribute) GetName 

func (m *DebugInfo_OTelDebugAttribute) GetName() string

func (*DebugInfo_OTelDebugAttribute) GetValue 

func (m *DebugInfo_OTelDebugAttribute) GetValue() string

func (*DebugInfo_OTelDebugAttribute) GoString 

func (this *DebugInfo_OTelDebugAttribute) GoString() string

func (*DebugInfo_OTelDebugAttribute) Marshal 

func (m *DebugInfo_OTelDebugAttribute) Marshal() (dAtA []byte, err error)

func (*DebugInfo_OTelDebugAttribute) MarshalTo 

func (m *DebugInfo_OTelDebugAttribute) MarshalTo(dAtA []byte) (int, error)

func (*DebugInfo_OTelDebugAttribute) MarshalToSizedBuffer 

func (m *DebugInfo_OTelDebugAttribute) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DebugInfo_OTelDebugAttribute) ProtoMessage 

func (*DebugInfo_OTelDebugAttribute) ProtoMessage()

func (*DebugInfo_OTelDebugAttribute) Reset 

func (m *DebugInfo_OTelDebugAttribute) Reset()

func (*DebugInfo_OTelDebugAttribute) Size 

func (m *DebugInfo_OTelDebugAttribute) Size() (n int)

func (*DebugInfo_OTelDebugAttribute) String 

func (this *DebugInfo_OTelDebugAttribute) String() string

func (*DebugInfo_OTelDebugAttribute) Unmarshal 

func (m *DebugInfo_OTelDebugAttribute) Unmarshal(dAtA []byte) error

func (*DebugInfo_OTelDebugAttribute) XXX_DiscardUnknown 

func (m *DebugInfo_OTelDebugAttribute) XXX_DiscardUnknown()

func (*DebugInfo_OTelDebugAttribute) XXX_Marshal 

func (m *DebugInfo_OTelDebugAttribute) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DebugInfo_OTelDebugAttribute) XXX_Merge 

func (m *DebugInfo_OTelDebugAttribute) XXX_Merge(src proto.Message)

func (*DebugInfo_OTelDebugAttribute) XXX_Size 

func (m *DebugInfo_OTelDebugAttribute) XXX_Size() int

func (*DebugInfo_OTelDebugAttribute) XXX_Unmarshal 

func (m *DebugInfo_OTelDebugAttribute) XXX_Unmarshal(b []byte) error

type DistributedPlan 

type DistributedPlan struct {
	QbAddressToPlan  map[string]*planpb.Plan `` /* 198-byte string literal not displayed */
	QbAddressToDagId map[string]uint64       `` /* 204-byte string literal not displayed */
	Dag              *planpb.DAG             `protobuf:"bytes,3,opt,name=dag,proto3" json:"dag,omitempty"`
}

func (*DistributedPlan) Descriptor 

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

func (*DistributedPlan) Equal 

func (this *DistributedPlan) Equal(that interface{}) bool

func (*DistributedPlan) GetDag 

func (m *DistributedPlan) GetDag() *planpb.DAG

func (*DistributedPlan) GetQbAddressToDagId 

func (m *DistributedPlan) GetQbAddressToDagId() map[string]uint64

func (*DistributedPlan) GetQbAddressToPlan 

func (m *DistributedPlan) GetQbAddressToPlan() map[string]*planpb.Plan

func (*DistributedPlan) GoString 

func (this *DistributedPlan) GoString() string

func (*DistributedPlan) Marshal 

func (m *DistributedPlan) Marshal() (dAtA []byte, err error)

func (*DistributedPlan) MarshalTo 

func (m *DistributedPlan) MarshalTo(dAtA []byte) (int, error)

func (*DistributedPlan) MarshalToSizedBuffer 

func (m *DistributedPlan) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DistributedPlan) ProtoMessage 

func (*DistributedPlan) ProtoMessage()

func (*DistributedPlan) Reset 

func (m *DistributedPlan) Reset()

func (*DistributedPlan) Size 

func (m *DistributedPlan) Size() (n int)

func (*DistributedPlan) String 

func (this *DistributedPlan) String() string

func (*DistributedPlan) Unmarshal 

func (m *DistributedPlan) Unmarshal(dAtA []byte) error

func (*DistributedPlan) XXX_DiscardUnknown 

func (m *DistributedPlan) XXX_DiscardUnknown()

func (*DistributedPlan) XXX_Marshal 

func (m *DistributedPlan) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DistributedPlan) XXX_Merge 

func (m *DistributedPlan) XXX_Merge(src proto.Message)

func (*DistributedPlan) XXX_Size 

func (m *DistributedPlan) XXX_Size() int

func (*DistributedPlan) XXX_Unmarshal 

func (m *DistributedPlan) XXX_Unmarshal(b []byte) error

type DistributedState 

type DistributedState struct {
	CarnotInfo []*CarnotInfo `protobuf:"bytes,1,rep,name=carnot_info,json=carnotInfo,proto3" json:"carnot_info,omitempty"`
	SchemaInfo []*SchemaInfo `protobuf:"bytes,2,rep,name=schema_info,json=schemaInfo,proto3" json:"schema_info,omitempty"`
}

func (*DistributedState) Descriptor 

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

func (*DistributedState) Equal 

func (this *DistributedState) Equal(that interface{}) bool

func (*DistributedState) GetCarnotInfo 

func (m *DistributedState) GetCarnotInfo() []*CarnotInfo

func (*DistributedState) GetSchemaInfo 

func (m *DistributedState) GetSchemaInfo() []*SchemaInfo

func (*DistributedState) GoString 

func (this *DistributedState) GoString() string

func (*DistributedState) Marshal 

func (m *DistributedState) Marshal() (dAtA []byte, err error)

func (*DistributedState) MarshalTo 

func (m *DistributedState) MarshalTo(dAtA []byte) (int, error)

func (*DistributedState) MarshalToSizedBuffer 

func (m *DistributedState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*DistributedState) ProtoMessage 

func (*DistributedState) ProtoMessage()

func (*DistributedState) Reset 

func (m *DistributedState) Reset()

func (*DistributedState) Size 

func (m *DistributedState) Size() (n int)

func (*DistributedState) String 

func (this *DistributedState) String() string

func (*DistributedState) Unmarshal 

func (m *DistributedState) Unmarshal(dAtA []byte) error

func (*DistributedState) XXX_DiscardUnknown 

func (m *DistributedState) XXX_DiscardUnknown()

func (*DistributedState) XXX_Marshal 

func (m *DistributedState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*DistributedState) XXX_Merge 

func (m *DistributedState) XXX_Merge(src proto.Message)

func (*DistributedState) XXX_Size 

func (m *DistributedState) XXX_Size() int

func (*DistributedState) XXX_Unmarshal 

func (m *DistributedState) XXX_Unmarshal(b []byte) error

type LogicalPlannerResult 

type LogicalPlannerResult struct {
	Status *statuspb.Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Plan   *DistributedPlan `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
}

func (*LogicalPlannerResult) Descriptor 

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

func (*LogicalPlannerResult) Equal 

func (this *LogicalPlannerResult) Equal(that interface{}) bool

func (*LogicalPlannerResult) GetPlan 

func (m *LogicalPlannerResult) GetPlan() *DistributedPlan

func (*LogicalPlannerResult) GetStatus 

func (m *LogicalPlannerResult) GetStatus() *statuspb.Status

func (*LogicalPlannerResult) GoString 

func (this *LogicalPlannerResult) GoString() string

func (*LogicalPlannerResult) Marshal 

func (m *LogicalPlannerResult) Marshal() (dAtA []byte, err error)

func (*LogicalPlannerResult) MarshalTo 

func (m *LogicalPlannerResult) MarshalTo(dAtA []byte) (int, error)

func (*LogicalPlannerResult) MarshalToSizedBuffer 

func (m *LogicalPlannerResult) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogicalPlannerResult) ProtoMessage 

func (*LogicalPlannerResult) ProtoMessage()

func (*LogicalPlannerResult) Reset 

func (m *LogicalPlannerResult) Reset()

func (*LogicalPlannerResult) Size 

func (m *LogicalPlannerResult) Size() (n int)

func (*LogicalPlannerResult) String 

func (this *LogicalPlannerResult) String() string

func (*LogicalPlannerResult) Unmarshal 

func (m *LogicalPlannerResult) Unmarshal(dAtA []byte) error

func (*LogicalPlannerResult) XXX_DiscardUnknown 

func (m *LogicalPlannerResult) XXX_DiscardUnknown()

func (*LogicalPlannerResult) XXX_Marshal 

func (m *LogicalPlannerResult) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogicalPlannerResult) XXX_Merge 

func (m *LogicalPlannerResult) XXX_Merge(src proto.Message)

func (*LogicalPlannerResult) XXX_Size 

func (m *LogicalPlannerResult) XXX_Size() int

func (*LogicalPlannerResult) XXX_Unmarshal 

func (m *LogicalPlannerResult) XXX_Unmarshal(b []byte) error

type LogicalPlannerState 

type LogicalPlannerState struct {
	DistributedState    *DistributedState   `protobuf:"bytes,2,opt,name=distributed_state,json=distributedState,proto3" json:"distributed_state,omitempty"`
	PlanOptions         *planpb.PlanOptions `protobuf:"bytes,3,opt,name=plan_options,json=planOptions,proto3" json:"plan_options,omitempty"`
	ResultAddress       string              `protobuf:"bytes,4,opt,name=result_address,json=resultAddress,proto3" json:"result_address,omitempty"`
	ResultSSLTargetName string              `protobuf:"bytes,5,opt,name=result_ssl_targetname,json=resultSslTargetname,proto3" json:"result_ssl_targetname,omitempty"`
	RedactionOptions    *RedactionOptions   `protobuf:"bytes,7,opt,name=redaction_options,json=redactionOptions,proto3" json:"redaction_options,omitempty"`
	OTelEndpointConfig  *OTelEndpointConfig `protobuf:"bytes,8,opt,name=otel_endpoint_config,json=otelEndpointConfig,proto3" json:"otel_endpoint_config,omitempty"`
	PluginConfig        *PluginConfig       `protobuf:"bytes,9,opt,name=plugin_config,json=pluginConfig,proto3" json:"plugin_config,omitempty"`
	DebugInfo           *DebugInfo          `protobuf:"bytes,10,opt,name=debug_info,json=debugInfo,proto3" json:"debug_info,omitempty"`
}

func (*LogicalPlannerState) Descriptor 

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

func (*LogicalPlannerState) Equal 

func (this *LogicalPlannerState) Equal(that interface{}) bool

func (*LogicalPlannerState) GetDebugInfo 

func (m *LogicalPlannerState) GetDebugInfo() *DebugInfo

func (*LogicalPlannerState) GetDistributedState 

func (m *LogicalPlannerState) GetDistributedState() *DistributedState

func (*LogicalPlannerState) GetOTelEndpointConfig 

func (m *LogicalPlannerState) GetOTelEndpointConfig() *OTelEndpointConfig

func (*LogicalPlannerState) GetPlanOptions 

func (m *LogicalPlannerState) GetPlanOptions() *planpb.PlanOptions

func (*LogicalPlannerState) GetPluginConfig 

func (m *LogicalPlannerState) GetPluginConfig() *PluginConfig

func (*LogicalPlannerState) GetRedactionOptions 

func (m *LogicalPlannerState) GetRedactionOptions() *RedactionOptions

func (*LogicalPlannerState) GetResultAddress 

func (m *LogicalPlannerState) GetResultAddress() string

func (*LogicalPlannerState) GetResultSSLTargetName 

func (m *LogicalPlannerState) GetResultSSLTargetName() string

func (*LogicalPlannerState) GoString 

func (this *LogicalPlannerState) GoString() string

func (*LogicalPlannerState) Marshal 

func (m *LogicalPlannerState) Marshal() (dAtA []byte, err error)

func (*LogicalPlannerState) MarshalTo 

func (m *LogicalPlannerState) MarshalTo(dAtA []byte) (int, error)

func (*LogicalPlannerState) MarshalToSizedBuffer 

func (m *LogicalPlannerState) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*LogicalPlannerState) ProtoMessage 

func (*LogicalPlannerState) ProtoMessage()

func (*LogicalPlannerState) Reset 

func (m *LogicalPlannerState) Reset()

func (*LogicalPlannerState) Size 

func (m *LogicalPlannerState) Size() (n int)

func (*LogicalPlannerState) String 

func (this *LogicalPlannerState) String() string

func (*LogicalPlannerState) Unmarshal 

func (m *LogicalPlannerState) Unmarshal(dAtA []byte) error

func (*LogicalPlannerState) XXX_DiscardUnknown 

func (m *LogicalPlannerState) XXX_DiscardUnknown()

func (*LogicalPlannerState) XXX_Marshal 

func (m *LogicalPlannerState) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*LogicalPlannerState) XXX_Merge 

func (m *LogicalPlannerState) XXX_Merge(src proto.Message)

func (*LogicalPlannerState) XXX_Size 

func (m *LogicalPlannerState) XXX_Size() int

func (*LogicalPlannerState) XXX_Unmarshal 

func (m *LogicalPlannerState) XXX_Unmarshal(b []byte) error

type MetadataInfo 

type MetadataInfo struct {
	MetadataFields []metadatapb.MetadataType `` /* 150-byte string literal not displayed */
	// Types that are valid to be assigned to Filter:
	//	*MetadataInfo_XXHash64BloomFilter
	Filter isMetadataInfo_Filter `protobuf_oneof:"filter"`
}

func (*MetadataInfo) Descriptor 

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

func (*MetadataInfo) Equal 

func (this *MetadataInfo) Equal(that interface{}) bool

func (*MetadataInfo) GetFilter 

func (m *MetadataInfo) GetFilter() isMetadataInfo_Filter

func (*MetadataInfo) GetMetadataFields 

func (m *MetadataInfo) GetMetadataFields() []metadatapb.MetadataType

func (*MetadataInfo) GetXXHash64BloomFilter 

func (m *MetadataInfo) GetXXHash64BloomFilter() *bloomfilterpb.XXHash64BloomFilter

func (*MetadataInfo) GoString 

func (this *MetadataInfo) GoString() string

func (*MetadataInfo) Marshal 

func (m *MetadataInfo) Marshal() (dAtA []byte, err error)

func (*MetadataInfo) MarshalTo 

func (m *MetadataInfo) MarshalTo(dAtA []byte) (int, error)

func (*MetadataInfo) MarshalToSizedBuffer 

func (m *MetadataInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetadataInfo) ProtoMessage 

func (*MetadataInfo) ProtoMessage()

func (*MetadataInfo) Reset 

func (m *MetadataInfo) Reset()

func (*MetadataInfo) Size 

func (m *MetadataInfo) Size() (n int)

func (*MetadataInfo) String 

func (this *MetadataInfo) String() string

func (*MetadataInfo) Unmarshal 

func (m *MetadataInfo) Unmarshal(dAtA []byte) error

func (*MetadataInfo) XXX_DiscardUnknown 

func (m *MetadataInfo) XXX_DiscardUnknown()

func (*MetadataInfo) XXX_Marshal 

func (m *MetadataInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*MetadataInfo) XXX_Merge 

func (m *MetadataInfo) XXX_Merge(src proto.Message)

func (*MetadataInfo) XXX_OneofWrappers 

func (*MetadataInfo) XXX_OneofWrappers() []interface{}

XXX_OneofWrappers is for the internal use of the proto package.

func (*MetadataInfo) XXX_Size 

func (m *MetadataInfo) XXX_Size() int

func (*MetadataInfo) XXX_Unmarshal 

func (m *MetadataInfo) XXX_Unmarshal(b []byte) error

type MetadataInfo_XXHash64BloomFilter 

type MetadataInfo_XXHash64BloomFilter struct {
	XXHash64BloomFilter *bloomfilterpb.XXHash64BloomFilter `` /* 126-byte string literal not displayed */
}

func (*MetadataInfo_XXHash64BloomFilter) Equal 

func (this *MetadataInfo_XXHash64BloomFilter) Equal(that interface{}) bool

func (*MetadataInfo_XXHash64BloomFilter) GoString 

func (this *MetadataInfo_XXHash64BloomFilter) GoString() string

func (*MetadataInfo_XXHash64BloomFilter) MarshalTo 

func (m *MetadataInfo_XXHash64BloomFilter) MarshalTo(dAtA []byte) (int, error)

func (*MetadataInfo_XXHash64BloomFilter) MarshalToSizedBuffer 

func (m *MetadataInfo_XXHash64BloomFilter) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*MetadataInfo_XXHash64BloomFilter) Size 

func (m *MetadataInfo_XXHash64BloomFilter) Size() (n int)

func (*MetadataInfo_XXHash64BloomFilter) String 

func (this *MetadataInfo_XXHash64BloomFilter) String() string

type OTelEndpointConfig 

type OTelEndpointConfig struct {
	URL      string            `protobuf:"bytes,1,opt,name=url,proto3" json:"url,omitempty"`
	Headers  map[string]string `` /* 155-byte string literal not displayed */
	Insecure bool              `protobuf:"varint,3,opt,name=insecure,proto3" json:"insecure,omitempty"`
	Timeout  int64             `protobuf:"varint,4,opt,name=timeout,proto3" json:"timeout,omitempty"`
}

func (*OTelEndpointConfig) Descriptor 

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

func (*OTelEndpointConfig) Equal 

func (this *OTelEndpointConfig) Equal(that interface{}) bool

func (*OTelEndpointConfig) GetHeaders 

func (m *OTelEndpointConfig) GetHeaders() map[string]string

func (*OTelEndpointConfig) GetInsecure 

func (m *OTelEndpointConfig) GetInsecure() bool

func (*OTelEndpointConfig) GetTimeout 

func (m *OTelEndpointConfig) GetTimeout() int64

func (*OTelEndpointConfig) GetURL 

func (m *OTelEndpointConfig) GetURL() string

func (*OTelEndpointConfig) GoString 

func (this *OTelEndpointConfig) GoString() string

func (*OTelEndpointConfig) Marshal 

func (m *OTelEndpointConfig) Marshal() (dAtA []byte, err error)

func (*OTelEndpointConfig) MarshalTo 

func (m *OTelEndpointConfig) MarshalTo(dAtA []byte) (int, error)

func (*OTelEndpointConfig) MarshalToSizedBuffer 

func (m *OTelEndpointConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*OTelEndpointConfig) ProtoMessage 

func (*OTelEndpointConfig) ProtoMessage()

func (*OTelEndpointConfig) Reset 

func (m *OTelEndpointConfig) Reset()

func (*OTelEndpointConfig) Size 

func (m *OTelEndpointConfig) Size() (n int)

func (*OTelEndpointConfig) String 

func (this *OTelEndpointConfig) String() string

func (*OTelEndpointConfig) Unmarshal 

func (m *OTelEndpointConfig) Unmarshal(dAtA []byte) error

func (*OTelEndpointConfig) XXX_DiscardUnknown 

func (m *OTelEndpointConfig) XXX_DiscardUnknown()

func (*OTelEndpointConfig) XXX_Marshal 

func (m *OTelEndpointConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*OTelEndpointConfig) XXX_Merge 

func (m *OTelEndpointConfig) XXX_Merge(src proto.Message)

func (*OTelEndpointConfig) XXX_Size 

func (m *OTelEndpointConfig) XXX_Size() int

func (*OTelEndpointConfig) XXX_Unmarshal 

func (m *OTelEndpointConfig) XXX_Unmarshal(b []byte) error

type PluginConfig 

type PluginConfig struct {
	StartTimeNs int64 `protobuf:"varint,1,opt,name=start_time_ns,json=startTimeNs,proto3" json:"start_time_ns,omitempty"`
	EndTimeNs   int64 `protobuf:"varint,2,opt,name=end_time_ns,json=endTimeNs,proto3" json:"end_time_ns,omitempty"`
}

func (*PluginConfig) Descriptor 

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

func (*PluginConfig) Equal 

func (this *PluginConfig) Equal(that interface{}) bool

func (*PluginConfig) GetEndTimeNs 

func (m *PluginConfig) GetEndTimeNs() int64

func (*PluginConfig) GetStartTimeNs 

func (m *PluginConfig) GetStartTimeNs() int64

func (*PluginConfig) GoString 

func (this *PluginConfig) GoString() string

func (*PluginConfig) Marshal 

func (m *PluginConfig) Marshal() (dAtA []byte, err error)

func (*PluginConfig) MarshalTo 

func (m *PluginConfig) MarshalTo(dAtA []byte) (int, error)

func (*PluginConfig) MarshalToSizedBuffer 

func (m *PluginConfig) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*PluginConfig) ProtoMessage 

func (*PluginConfig) ProtoMessage()

func (*PluginConfig) Reset 

func (m *PluginConfig) Reset()

func (*PluginConfig) Size 

func (m *PluginConfig) Size() (n int)

func (*PluginConfig) String 

func (this *PluginConfig) String() string

func (*PluginConfig) Unmarshal 

func (m *PluginConfig) Unmarshal(dAtA []byte) error

func (*PluginConfig) XXX_DiscardUnknown 

func (m *PluginConfig) XXX_DiscardUnknown()

func (*PluginConfig) XXX_Marshal 

func (m *PluginConfig) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*PluginConfig) XXX_Merge 

func (m *PluginConfig) XXX_Merge(src proto.Message)

func (*PluginConfig) XXX_Size 

func (m *PluginConfig) XXX_Size() int

func (*PluginConfig) XXX_Unmarshal 

func (m *PluginConfig) XXX_Unmarshal(b []byte) error

type RedactionOptions 

type RedactionOptions struct {
	UseFullRedaction         bool `protobuf:"varint,1,opt,name=use_full_redaction,json=useFullRedaction,proto3" json:"use_full_redaction,omitempty"`
	UsePxRedactPiiBestEffort bool `` /* 142-byte string literal not displayed */
}

func (*RedactionOptions) Descriptor 

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

func (*RedactionOptions) Equal 

func (this *RedactionOptions) Equal(that interface{}) bool

func (*RedactionOptions) GetUseFullRedaction 

func (m *RedactionOptions) GetUseFullRedaction() bool

func (*RedactionOptions) GetUsePxRedactPiiBestEffort 

func (m *RedactionOptions) GetUsePxRedactPiiBestEffort() bool

func (*RedactionOptions) GoString 

func (this *RedactionOptions) GoString() string

func (*RedactionOptions) Marshal 

func (m *RedactionOptions) Marshal() (dAtA []byte, err error)

func (*RedactionOptions) MarshalTo 

func (m *RedactionOptions) MarshalTo(dAtA []byte) (int, error)

func (*RedactionOptions) MarshalToSizedBuffer 

func (m *RedactionOptions) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*RedactionOptions) ProtoMessage 

func (*RedactionOptions) ProtoMessage()

func (*RedactionOptions) Reset 

func (m *RedactionOptions) Reset()

func (*RedactionOptions) Size 

func (m *RedactionOptions) Size() (n int)

func (*RedactionOptions) String 

func (this *RedactionOptions) String() string

func (*RedactionOptions) Unmarshal 

func (m *RedactionOptions) Unmarshal(dAtA []byte) error

func (*RedactionOptions) XXX_DiscardUnknown 

func (m *RedactionOptions) XXX_DiscardUnknown()

func (*RedactionOptions) XXX_Marshal 

func (m *RedactionOptions) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*RedactionOptions) XXX_Merge 

func (m *RedactionOptions) XXX_Merge(src proto.Message)

func (*RedactionOptions) XXX_Size 

func (m *RedactionOptions) XXX_Size() int

func (*RedactionOptions) XXX_Unmarshal 

func (m *RedactionOptions) XXX_Unmarshal(b []byte) error

type SchemaInfo 

type SchemaInfo struct {
	Name      string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Relation  *schemapb.Relation `protobuf:"bytes,2,opt,name=relation,proto3" json:"relation,omitempty"`
	AgentList []*uuidpb.UUID     `protobuf:"bytes,3,rep,name=agent_list,json=agentList,proto3" json:"agent_list,omitempty"`
}

func (*SchemaInfo) Descriptor 

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

func (*SchemaInfo) Equal 

func (this *SchemaInfo) Equal(that interface{}) bool

func (*SchemaInfo) GetAgentList 

func (m *SchemaInfo) GetAgentList() []*uuidpb.UUID

func (*SchemaInfo) GetName 

func (m *SchemaInfo) GetName() string

func (*SchemaInfo) GetRelation 

func (m *SchemaInfo) GetRelation() *schemapb.Relation

func (*SchemaInfo) GoString 

func (this *SchemaInfo) GoString() string

func (*SchemaInfo) Marshal 

func (m *SchemaInfo) Marshal() (dAtA []byte, err error)

func (*SchemaInfo) MarshalTo 

func (m *SchemaInfo) MarshalTo(dAtA []byte) (int, error)

func (*SchemaInfo) MarshalToSizedBuffer 

func (m *SchemaInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*SchemaInfo) ProtoMessage 

func (*SchemaInfo) ProtoMessage()

func (*SchemaInfo) Reset 

func (m *SchemaInfo) Reset()

func (*SchemaInfo) Size 

func (m *SchemaInfo) Size() (n int)

func (*SchemaInfo) String 

func (this *SchemaInfo) String() string

func (*SchemaInfo) Unmarshal 

func (m *SchemaInfo) Unmarshal(dAtA []byte) error

func (*SchemaInfo) XXX_DiscardUnknown 

func (m *SchemaInfo) XXX_DiscardUnknown()

func (*SchemaInfo) XXX_Marshal 

func (m *SchemaInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*SchemaInfo) XXX_Merge 

func (m *SchemaInfo) XXX_Merge(src proto.Message)

func (*SchemaInfo) XXX_Size 

func (m *SchemaInfo) XXX_Size() int

func (*SchemaInfo) XXX_Unmarshal 

func (m *SchemaInfo) XXX_Unmarshal(b []byte) error

type TableInfo 

type TableInfo struct {
	Table            string   `protobuf:"bytes,1,opt,name=table,proto3" json:"table,omitempty"`
	TabletizationKey string   `protobuf:"bytes,2,opt,name=tabletization_key,json=tabletizationKey,proto3" json:"tabletization_key,omitempty"`
	Tablets          []string `protobuf:"bytes,3,rep,name=tablets,proto3" json:"tablets,omitempty"`
}

func (*TableInfo) Descriptor 

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

func (*TableInfo) Equal 

func (this *TableInfo) Equal(that interface{}) bool

func (*TableInfo) GetTable 

func (m *TableInfo) GetTable() string

func (*TableInfo) GetTabletizationKey 

func (m *TableInfo) GetTabletizationKey() string

func (*TableInfo) GetTablets 

func (m *TableInfo) GetTablets() []string

func (*TableInfo) GoString 

func (this *TableInfo) GoString() string

func (*TableInfo) Marshal 

func (m *TableInfo) Marshal() (dAtA []byte, err error)

func (*TableInfo) MarshalTo 

func (m *TableInfo) MarshalTo(dAtA []byte) (int, error)

func (*TableInfo) MarshalToSizedBuffer 

func (m *TableInfo) MarshalToSizedBuffer(dAtA []byte) (int, error)

func (*TableInfo) ProtoMessage 

func (*TableInfo) ProtoMessage()

func (*TableInfo) Reset 

func (m *TableInfo) Reset()

func (*TableInfo) Size 

func (m *TableInfo) Size() (n int)

func (*TableInfo) String 

func (this *TableInfo) String() string

func (*TableInfo) Unmarshal 

func (m *TableInfo) Unmarshal(dAtA []byte) error

func (*TableInfo) XXX_DiscardUnknown 

func (m *TableInfo) XXX_DiscardUnknown()

func (*TableInfo) XXX_Marshal 

func (m *TableInfo) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)

func (*TableInfo) XXX_Merge 

func (m *TableInfo) XXX_Merge(src proto.Message)

func (*TableInfo) XXX_Size 

func (m *TableInfo) XXX_Size() int

func (*TableInfo) XXX_Unmarshal 

func (m *TableInfo) XXX_Unmarshal(b []byte) error

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.