storepb

package
v0.0.0-...-0888c38 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthStore        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowStore          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupStore = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type AgentTracepointStatus 

type AgentTracepointStatus struct {
	State   statuspb.LifeCycleState `protobuf:"varint,1,opt,name=state,proto3,enum=px.statuspb.LifeCycleState" json:"state,omitempty"`
	Status  *statuspb.Status        `protobuf:"bytes,2,opt,name=status,proto3" json:"status,omitempty"`
	ID      *uuidpb.UUID            `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
	AgentID *uuidpb.UUID            `protobuf:"bytes,4,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
}

func (*AgentTracepointStatus) Descriptor 

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

func (*AgentTracepointStatus) Equal 

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

func (*AgentTracepointStatus) GetAgentID 

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

func (*AgentTracepointStatus) GetID 

func (m *AgentTracepointStatus) GetID() *uuidpb.UUID

func (*AgentTracepointStatus) GetState 

func (m *AgentTracepointStatus) GetState() statuspb.LifeCycleState

func (*AgentTracepointStatus) GetStatus 

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

func (*AgentTracepointStatus) GoString 

func (this *AgentTracepointStatus) GoString() string

func (*AgentTracepointStatus) Marshal 

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

func (*AgentTracepointStatus) MarshalTo 

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

func (*AgentTracepointStatus) MarshalToSizedBuffer 

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

func (*AgentTracepointStatus) ProtoMessage 

func (*AgentTracepointStatus) ProtoMessage()

func (*AgentTracepointStatus) Reset 

func (m *AgentTracepointStatus) Reset()

func (*AgentTracepointStatus) Size 

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

func (*AgentTracepointStatus) String 

func (this *AgentTracepointStatus) String() string

func (*AgentTracepointStatus) Unmarshal 

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

func (*AgentTracepointStatus) XXX_DiscardUnknown 

func (m *AgentTracepointStatus) XXX_DiscardUnknown()

func (*AgentTracepointStatus) XXX_Marshal 

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

func (*AgentTracepointStatus) XXX_Merge 

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

func (*AgentTracepointStatus) XXX_Size 

func (m *AgentTracepointStatus) XXX_Size() int

func (*AgentTracepointStatus) XXX_Unmarshal 

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

type ComputedSchema 

type ComputedSchema struct {
	Tables              []*TableInfo                        `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	TableNameToAgentIDs map[string]*ComputedSchema_AgentIDs `` /* 212-byte string literal not displayed */
}

func (*ComputedSchema) Descriptor 

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

func (*ComputedSchema) Equal 

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

func (*ComputedSchema) GetTableNameToAgentIDs 

func (m *ComputedSchema) GetTableNameToAgentIDs() map[string]*ComputedSchema_AgentIDs

func (*ComputedSchema) GetTables 

func (m *ComputedSchema) GetTables() []*TableInfo

func (*ComputedSchema) GoString 

func (this *ComputedSchema) GoString() string

func (*ComputedSchema) Marshal 

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

func (*ComputedSchema) MarshalTo 

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

func (*ComputedSchema) MarshalToSizedBuffer 

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

func (*ComputedSchema) ProtoMessage 

func (*ComputedSchema) ProtoMessage()

func (*ComputedSchema) Reset 

func (m *ComputedSchema) Reset()

func (*ComputedSchema) Size 

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

func (*ComputedSchema) String 

func (this *ComputedSchema) String() string

func (*ComputedSchema) Unmarshal 

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

func (*ComputedSchema) XXX_DiscardUnknown 

func (m *ComputedSchema) XXX_DiscardUnknown()

func (*ComputedSchema) XXX_Marshal 

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

func (*ComputedSchema) XXX_Merge 

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

func (*ComputedSchema) XXX_Size 

func (m *ComputedSchema) XXX_Size() int

func (*ComputedSchema) XXX_Unmarshal 

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

type ComputedSchema_AgentIDs 

type ComputedSchema_AgentIDs struct {
	AgentID []*uuidpb.UUID `protobuf:"bytes,1,rep,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
}

func (*ComputedSchema_AgentIDs) Descriptor 

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

func (*ComputedSchema_AgentIDs) Equal 

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

func (*ComputedSchema_AgentIDs) GetAgentID 

func (m *ComputedSchema_AgentIDs) GetAgentID() []*uuidpb.UUID

func (*ComputedSchema_AgentIDs) GoString 

func (this *ComputedSchema_AgentIDs) GoString() string

func (*ComputedSchema_AgentIDs) Marshal 

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

func (*ComputedSchema_AgentIDs) MarshalTo 

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

func (*ComputedSchema_AgentIDs) MarshalToSizedBuffer 

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

func (*ComputedSchema_AgentIDs) ProtoMessage 

func (*ComputedSchema_AgentIDs) ProtoMessage()

func (*ComputedSchema_AgentIDs) Reset 

func (m *ComputedSchema_AgentIDs) Reset()

func (*ComputedSchema_AgentIDs) Size 

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

func (*ComputedSchema_AgentIDs) String 

func (this *ComputedSchema_AgentIDs) String() string

func (*ComputedSchema_AgentIDs) Unmarshal 

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

func (*ComputedSchema_AgentIDs) XXX_DiscardUnknown 

func (m *ComputedSchema_AgentIDs) XXX_DiscardUnknown()

func (*ComputedSchema_AgentIDs) XXX_Marshal 

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

func (*ComputedSchema_AgentIDs) XXX_Merge 

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

func (*ComputedSchema_AgentIDs) XXX_Size 

func (m *ComputedSchema_AgentIDs) XXX_Size() int

func (*ComputedSchema_AgentIDs) XXX_Unmarshal 

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

type CronScriptResult 

type CronScriptResult struct {
	ScriptID          *uuidpb.UUID     `protobuf:"bytes,1,opt,name=script_id,json=scriptId,proto3" json:"script_id,omitempty"`
	Timestamp         *types.Timestamp `protobuf:"bytes,2,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
	Error             *statuspb.Status `protobuf:"bytes,3,opt,name=error,proto3" json:"error,omitempty"`
	ExecutionTimeNs   int64            `protobuf:"varint,4,opt,name=execution_time_ns,json=executionTimeNs,proto3" json:"execution_time_ns,omitempty"`
	CompilationTimeNs int64            `protobuf:"varint,5,opt,name=compilation_time_ns,json=compilationTimeNs,proto3" json:"compilation_time_ns,omitempty"`
	BytesProcessed    int64            `protobuf:"varint,6,opt,name=bytes_processed,json=bytesProcessed,proto3" json:"bytes_processed,omitempty"`
	RecordsProcessed  int64            `protobuf:"varint,7,opt,name=records_processed,json=recordsProcessed,proto3" json:"records_processed,omitempty"`
}

func (*CronScriptResult) Descriptor 

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

func (*CronScriptResult) Equal 

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

func (*CronScriptResult) GetBytesProcessed 

func (m *CronScriptResult) GetBytesProcessed() int64

func (*CronScriptResult) GetCompilationTimeNs 

func (m *CronScriptResult) GetCompilationTimeNs() int64

func (*CronScriptResult) GetError 

func (m *CronScriptResult) GetError() *statuspb.Status

func (*CronScriptResult) GetExecutionTimeNs 

func (m *CronScriptResult) GetExecutionTimeNs() int64

func (*CronScriptResult) GetRecordsProcessed 

func (m *CronScriptResult) GetRecordsProcessed() int64

func (*CronScriptResult) GetScriptID 

func (m *CronScriptResult) GetScriptID() *uuidpb.UUID

func (*CronScriptResult) GetTimestamp 

func (m *CronScriptResult) GetTimestamp() *types.Timestamp

func (*CronScriptResult) GoString 

func (this *CronScriptResult) GoString() string

func (*CronScriptResult) Marshal 

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

func (*CronScriptResult) MarshalTo 

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

func (*CronScriptResult) MarshalToSizedBuffer 

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

func (*CronScriptResult) ProtoMessage 

func (*CronScriptResult) ProtoMessage()

func (*CronScriptResult) Reset 

func (m *CronScriptResult) Reset()

func (*CronScriptResult) Size 

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

func (*CronScriptResult) String 

func (this *CronScriptResult) String() string

func (*CronScriptResult) Unmarshal 

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

func (*CronScriptResult) XXX_DiscardUnknown 

func (m *CronScriptResult) XXX_DiscardUnknown()

func (*CronScriptResult) XXX_Marshal 

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

func (*CronScriptResult) XXX_Merge 

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

func (*CronScriptResult) XXX_Size 

func (m *CronScriptResult) XXX_Size() int

func (*CronScriptResult) XXX_Unmarshal 

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

type K8SResource 

type K8SResource struct {
	// Types that are valid to be assigned to Resource:
	//	*K8SResource_Pod
	//	*K8SResource_Container
	//	*K8SResource_Service
	//	*K8SResource_Endpoints
	//	*K8SResource_Namespace
	//	*K8SResource_Node
	//	*K8SResource_ReplicaSet
	//	*K8SResource_Deployment
	Resource isK8SResource_Resource `protobuf_oneof:"resource"`
}

func (*K8SResource) Descriptor 

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

func (*K8SResource) Equal 

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

func (*K8SResource) GetContainer 

func (m *K8SResource) GetContainer() *metadatapb.ContainerUpdate

func (*K8SResource) GetDeployment 

func (m *K8SResource) GetDeployment() *metadatapb.Deployment

func (*K8SResource) GetEndpoints 

func (m *K8SResource) GetEndpoints() *metadatapb.Endpoints

func (*K8SResource) GetNamespace 

func (m *K8SResource) GetNamespace() *metadatapb.Namespace

func (*K8SResource) GetNode 

func (m *K8SResource) GetNode() *metadatapb.Node

func (*K8SResource) GetPod 

func (m *K8SResource) GetPod() *metadatapb.Pod

func (*K8SResource) GetReplicaSet 

func (m *K8SResource) GetReplicaSet() *metadatapb.ReplicaSet

func (*K8SResource) GetResource 

func (m *K8SResource) GetResource() isK8SResource_Resource

func (*K8SResource) GetService 

func (m *K8SResource) GetService() *metadatapb.Service

func (*K8SResource) GoString 

func (this *K8SResource) GoString() string

func (*K8SResource) Marshal 

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

func (*K8SResource) MarshalTo 

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

func (*K8SResource) MarshalToSizedBuffer 

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

func (*K8SResource) ProtoMessage 

func (*K8SResource) ProtoMessage()

func (*K8SResource) Reset 

func (m *K8SResource) Reset()

func (*K8SResource) Size 

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

func (*K8SResource) String 

func (this *K8SResource) String() string

func (*K8SResource) Unmarshal 

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

func (*K8SResource) XXX_DiscardUnknown 

func (m *K8SResource) XXX_DiscardUnknown()

func (*K8SResource) XXX_Marshal 

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

func (*K8SResource) XXX_Merge 

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

func (*K8SResource) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*K8SResource) XXX_Size 

func (m *K8SResource) XXX_Size() int

func (*K8SResource) XXX_Unmarshal 

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

type K8SResourceUpdate 

type K8SResourceUpdate struct {
	Update *metadatapb.ResourceUpdate `protobuf:"bytes,1,opt,name=update,proto3" json:"update,omitempty"`
}

func (*K8SResourceUpdate) Descriptor 

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

func (*K8SResourceUpdate) Equal 

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

func (*K8SResourceUpdate) GetUpdate 

func (m *K8SResourceUpdate) GetUpdate() *metadatapb.ResourceUpdate

func (*K8SResourceUpdate) GoString 

func (this *K8SResourceUpdate) GoString() string

func (*K8SResourceUpdate) Marshal 

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

func (*K8SResourceUpdate) MarshalTo 

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

func (*K8SResourceUpdate) MarshalToSizedBuffer 

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

func (*K8SResourceUpdate) ProtoMessage 

func (*K8SResourceUpdate) ProtoMessage()

func (*K8SResourceUpdate) Reset 

func (m *K8SResourceUpdate) Reset()

func (*K8SResourceUpdate) Size 

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

func (*K8SResourceUpdate) String 

func (this *K8SResourceUpdate) String() string

func (*K8SResourceUpdate) Unmarshal 

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

func (*K8SResourceUpdate) XXX_DiscardUnknown 

func (m *K8SResourceUpdate) XXX_DiscardUnknown()

func (*K8SResourceUpdate) XXX_Marshal 

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

func (*K8SResourceUpdate) XXX_Merge 

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

func (*K8SResourceUpdate) XXX_Size 

func (m *K8SResourceUpdate) XXX_Size() int

func (*K8SResourceUpdate) XXX_Unmarshal 

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

type K8SResource_Container 

type K8SResource_Container struct {
	Container *metadatapb.ContainerUpdate `protobuf:"bytes,2,opt,name=container,proto3,oneof" json:"container,omitempty"`
}

func (*K8SResource_Container) Equal 

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

func (*K8SResource_Container) GoString 

func (this *K8SResource_Container) GoString() string

func (*K8SResource_Container) MarshalTo 

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

func (*K8SResource_Container) MarshalToSizedBuffer 

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

func (*K8SResource_Container) Size 

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

func (*K8SResource_Container) String 

func (this *K8SResource_Container) String() string

type K8SResource_Deployment 

type K8SResource_Deployment struct {
	Deployment *metadatapb.Deployment `protobuf:"bytes,8,opt,name=deployment,proto3,oneof" json:"deployment,omitempty"`
}

func (*K8SResource_Deployment) Equal 

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

func (*K8SResource_Deployment) GoString 

func (this *K8SResource_Deployment) GoString() string

func (*K8SResource_Deployment) MarshalTo 

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

func (*K8SResource_Deployment) MarshalToSizedBuffer 

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

func (*K8SResource_Deployment) Size 

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

func (*K8SResource_Deployment) String 

func (this *K8SResource_Deployment) String() string

type K8SResource_Endpoints 

type K8SResource_Endpoints struct {
	Endpoints *metadatapb.Endpoints `protobuf:"bytes,4,opt,name=endpoints,proto3,oneof" json:"endpoints,omitempty"`
}

func (*K8SResource_Endpoints) Equal 

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

func (*K8SResource_Endpoints) GoString 

func (this *K8SResource_Endpoints) GoString() string

func (*K8SResource_Endpoints) MarshalTo 

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

func (*K8SResource_Endpoints) MarshalToSizedBuffer 

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

func (*K8SResource_Endpoints) Size 

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

func (*K8SResource_Endpoints) String 

func (this *K8SResource_Endpoints) String() string

type K8SResource_Namespace 

type K8SResource_Namespace struct {
	Namespace *metadatapb.Namespace `protobuf:"bytes,5,opt,name=namespace,proto3,oneof" json:"namespace,omitempty"`
}

func (*K8SResource_Namespace) Equal 

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

func (*K8SResource_Namespace) GoString 

func (this *K8SResource_Namespace) GoString() string

func (*K8SResource_Namespace) MarshalTo 

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

func (*K8SResource_Namespace) MarshalToSizedBuffer 

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

func (*K8SResource_Namespace) Size 

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

func (*K8SResource_Namespace) String 

func (this *K8SResource_Namespace) String() string

type K8SResource_Node 

type K8SResource_Node struct {
	Node *metadatapb.Node `protobuf:"bytes,6,opt,name=node,proto3,oneof" json:"node,omitempty"`
}

func (*K8SResource_Node) Equal 

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

func (*K8SResource_Node) GoString 

func (this *K8SResource_Node) GoString() string

func (*K8SResource_Node) MarshalTo 

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

func (*K8SResource_Node) MarshalToSizedBuffer 

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

func (*K8SResource_Node) Size 

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

func (*K8SResource_Node) String 

func (this *K8SResource_Node) String() string

type K8SResource_Pod 

type K8SResource_Pod struct {
	Pod *metadatapb.Pod `protobuf:"bytes,1,opt,name=pod,proto3,oneof" json:"pod,omitempty"`
}

func (*K8SResource_Pod) Equal 

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

func (*K8SResource_Pod) GoString 

func (this *K8SResource_Pod) GoString() string

func (*K8SResource_Pod) MarshalTo 

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

func (*K8SResource_Pod) MarshalToSizedBuffer 

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

func (*K8SResource_Pod) Size 

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

func (*K8SResource_Pod) String 

func (this *K8SResource_Pod) String() string

type K8SResource_ReplicaSet 

type K8SResource_ReplicaSet struct {
	ReplicaSet *metadatapb.ReplicaSet `protobuf:"bytes,7,opt,name=replica_set,json=replicaSet,proto3,oneof" json:"replica_set,omitempty"`
}

func (*K8SResource_ReplicaSet) Equal 

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

func (*K8SResource_ReplicaSet) GoString 

func (this *K8SResource_ReplicaSet) GoString() string

func (*K8SResource_ReplicaSet) MarshalTo 

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

func (*K8SResource_ReplicaSet) MarshalToSizedBuffer 

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

func (*K8SResource_ReplicaSet) Size 

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

func (*K8SResource_ReplicaSet) String 

func (this *K8SResource_ReplicaSet) String() string

type K8SResource_Service 

type K8SResource_Service struct {
	Service *metadatapb.Service `protobuf:"bytes,3,opt,name=service,proto3,oneof" json:"service,omitempty"`
}

func (*K8SResource_Service) Equal 

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

func (*K8SResource_Service) GoString 

func (this *K8SResource_Service) GoString() string

func (*K8SResource_Service) MarshalTo 

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

func (*K8SResource_Service) MarshalToSizedBuffer 

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

func (*K8SResource_Service) Size 

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

func (*K8SResource_Service) String 

func (this *K8SResource_Service) String() string

type TableInfo 

type TableInfo struct {
	Name             string                  `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Desc             string                  `protobuf:"bytes,7,opt,name=desc,proto3" json:"desc,omitempty"`
	StartTimestampNS int64                   `protobuf:"varint,2,opt,name=start_timestamp_ns,json=startTimestampNs,proto3" json:"start_timestamp_ns,omitempty"`
	StopTimestampNS  int64                   `protobuf:"varint,3,opt,name=stop_timestamp_ns,json=stopTimestampNs,proto3" json:"stop_timestamp_ns,omitempty"`
	Columns          []*TableInfo_ColumnInfo `protobuf:"bytes,4,rep,name=columns,proto3" json:"columns,omitempty"`
	Tabletized       bool                    `protobuf:"varint,5,opt,name=tabletized,proto3" json:"tabletized,omitempty"`
	TabletizationKey string                  `protobuf:"bytes,6,opt,name=tabletization_key,json=tabletizationKey,proto3" json:"tabletization_key,omitempty"`
}

func (*TableInfo) Descriptor 

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

func (*TableInfo) Equal 

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

func (*TableInfo) GetColumns 

func (m *TableInfo) GetColumns() []*TableInfo_ColumnInfo

func (*TableInfo) GetDesc 

func (m *TableInfo) GetDesc() string

func (*TableInfo) GetName 

func (m *TableInfo) GetName() string

func (*TableInfo) GetStartTimestampNS 

func (m *TableInfo) GetStartTimestampNS() int64

func (*TableInfo) GetStopTimestampNS 

func (m *TableInfo) GetStopTimestampNS() int64

func (*TableInfo) GetTabletizationKey 

func (m *TableInfo) GetTabletizationKey() string

func (*TableInfo) GetTabletized 

func (m *TableInfo) GetTabletized() bool

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

type TableInfo_ColumnInfo 

type TableInfo_ColumnInfo struct {
	Name         string               `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DataType     typespb.DataType     `protobuf:"varint,2,opt,name=data_type,json=dataType,proto3,enum=px.types.DataType" json:"data_type,omitempty"`
	PatternType  typespb.PatternType  `protobuf:"varint,3,opt,name=pattern_type,json=patternType,proto3,enum=px.types.PatternType" json:"pattern_type,omitempty"`
	Desc         string               `protobuf:"bytes,4,opt,name=desc,proto3" json:"desc,omitempty"`
	SemanticType typespb.SemanticType `protobuf:"varint,5,opt,name=semantic_type,json=semanticType,proto3,enum=px.types.SemanticType" json:"semantic_type,omitempty"`
}

func (*TableInfo_ColumnInfo) Descriptor 

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

func (*TableInfo_ColumnInfo) Equal 

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

func (*TableInfo_ColumnInfo) GetDataType 

func (m *TableInfo_ColumnInfo) GetDataType() typespb.DataType

func (*TableInfo_ColumnInfo) GetDesc 

func (m *TableInfo_ColumnInfo) GetDesc() string

func (*TableInfo_ColumnInfo) GetName 

func (m *TableInfo_ColumnInfo) GetName() string

func (*TableInfo_ColumnInfo) GetPatternType 

func (m *TableInfo_ColumnInfo) GetPatternType() typespb.PatternType

func (*TableInfo_ColumnInfo) GetSemanticType 

func (m *TableInfo_ColumnInfo) GetSemanticType() typespb.SemanticType

func (*TableInfo_ColumnInfo) GoString 

func (this *TableInfo_ColumnInfo) GoString() string

func (*TableInfo_ColumnInfo) Marshal 

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

func (*TableInfo_ColumnInfo) MarshalTo 

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

func (*TableInfo_ColumnInfo) MarshalToSizedBuffer 

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

func (*TableInfo_ColumnInfo) ProtoMessage 

func (*TableInfo_ColumnInfo) ProtoMessage()

func (*TableInfo_ColumnInfo) Reset 

func (m *TableInfo_ColumnInfo) Reset()

func (*TableInfo_ColumnInfo) Size 

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

func (*TableInfo_ColumnInfo) String 

func (this *TableInfo_ColumnInfo) String() string

func (*TableInfo_ColumnInfo) Unmarshal 

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

func (*TableInfo_ColumnInfo) XXX_DiscardUnknown 

func (m *TableInfo_ColumnInfo) XXX_DiscardUnknown()

func (*TableInfo_ColumnInfo) XXX_Marshal 

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

func (*TableInfo_ColumnInfo) XXX_Merge 

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

func (*TableInfo_ColumnInfo) XXX_Size 

func (m *TableInfo_ColumnInfo) XXX_Size() int

func (*TableInfo_ColumnInfo) XXX_Unmarshal 

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

type TracepointInfo 

type TracepointInfo struct {
	ID            *uuidpb.UUID                    `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Tracepoint    *logicalpb.TracepointDeployment `protobuf:"bytes,2,opt,name=tracepoint,proto3" json:"tracepoint,omitempty"`
	Name          string                          `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
	ExpectedState statuspb.LifeCycleState         `` /* 133-byte string literal not displayed */
}

func (*TracepointInfo) Descriptor 

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

func (*TracepointInfo) Equal 

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

func (*TracepointInfo) GetExpectedState 

func (m *TracepointInfo) GetExpectedState() statuspb.LifeCycleState

func (*TracepointInfo) GetID 

func (m *TracepointInfo) GetID() *uuidpb.UUID

func (*TracepointInfo) GetName 

func (m *TracepointInfo) GetName() string

func (*TracepointInfo) GetTracepoint 

func (m *TracepointInfo) GetTracepoint() *logicalpb.TracepointDeployment

func (*TracepointInfo) GoString 

func (this *TracepointInfo) GoString() string

func (*TracepointInfo) Marshal 

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

func (*TracepointInfo) MarshalTo 

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

func (*TracepointInfo) MarshalToSizedBuffer 

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

func (*TracepointInfo) ProtoMessage 

func (*TracepointInfo) ProtoMessage()

func (*TracepointInfo) Reset 

func (m *TracepointInfo) Reset()

func (*TracepointInfo) Size 

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

func (*TracepointInfo) String 

func (this *TracepointInfo) String() string

func (*TracepointInfo) Unmarshal 

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

func (*TracepointInfo) XXX_DiscardUnknown 

func (m *TracepointInfo) XXX_DiscardUnknown()

func (*TracepointInfo) XXX_Marshal 

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

func (*TracepointInfo) XXX_Merge 

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

func (*TracepointInfo) XXX_Size 

func (m *TracepointInfo) XXX_Size() int

func (*TracepointInfo) XXX_Unmarshal 

func (m *TracepointInfo) 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.