messagespb

package
v0.0.0-...-3c9c4bd Latest Latest
Warning

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

 Go to latest Published: Jan 6, 2025 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthMessages        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowMessages          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupMessages = fmt.Errorf("proto: unexpected end of group")
)

Functions

This section is empty.

Types

type AgentDataInfo 

type AgentDataInfo struct {
	MetadataInfo *distributedpb.MetadataInfo `protobuf:"bytes,1,opt,name=metadata_info,json=metadataInfo,proto3" json:"metadata_info,omitempty"`
}

func (*AgentDataInfo) Descriptor 

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

func (*AgentDataInfo) Equal 

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

func (*AgentDataInfo) GetMetadataInfo 

func (m *AgentDataInfo) GetMetadataInfo() *distributedpb.MetadataInfo

func (*AgentDataInfo) GoString 

func (this *AgentDataInfo) GoString() string

func (*AgentDataInfo) Marshal 

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

func (*AgentDataInfo) MarshalTo 

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

func (*AgentDataInfo) MarshalToSizedBuffer 

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

func (*AgentDataInfo) ProtoMessage 

func (*AgentDataInfo) ProtoMessage()

func (*AgentDataInfo) Reset 

func (m *AgentDataInfo) Reset()

func (*AgentDataInfo) Size 

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

func (*AgentDataInfo) String 

func (this *AgentDataInfo) String() string

func (*AgentDataInfo) Unmarshal 

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

func (*AgentDataInfo) XXX_DiscardUnknown 

func (m *AgentDataInfo) XXX_DiscardUnknown()

func (*AgentDataInfo) XXX_Marshal 

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

func (*AgentDataInfo) XXX_Merge 

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

func (*AgentDataInfo) XXX_Size 

func (m *AgentDataInfo) XXX_Size() int

func (*AgentDataInfo) XXX_Unmarshal 

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

type AgentUpdateInfo 

type AgentUpdateInfo struct {
	Schema            []*storepb.TableInfo            `protobuf:"bytes,2,rep,name=schema,proto3" json:"schema,omitempty"`
	ProcessCreated    []*metadatapb.ProcessCreated    `protobuf:"bytes,4,rep,name=process_created,json=processCreated,proto3" json:"process_created,omitempty"`
	ProcessTerminated []*metadatapb.ProcessTerminated `protobuf:"bytes,5,rep,name=process_terminated,json=processTerminated,proto3" json:"process_terminated,omitempty"`
	DoesUpdateSchema  bool                            `protobuf:"varint,6,opt,name=does_update_schema,json=doesUpdateSchema,proto3" json:"does_update_schema,omitempty"`
	Data              *AgentDataInfo                  `protobuf:"bytes,7,opt,name=data,proto3" json:"data,omitempty"`
}

func (*AgentUpdateInfo) Descriptor 

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

func (*AgentUpdateInfo) Equal 

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

func (*AgentUpdateInfo) GetData 

func (m *AgentUpdateInfo) GetData() *AgentDataInfo

func (*AgentUpdateInfo) GetDoesUpdateSchema 

func (m *AgentUpdateInfo) GetDoesUpdateSchema() bool

func (*AgentUpdateInfo) GetProcessCreated 

func (m *AgentUpdateInfo) GetProcessCreated() []*metadatapb.ProcessCreated

func (*AgentUpdateInfo) GetProcessTerminated 

func (m *AgentUpdateInfo) GetProcessTerminated() []*metadatapb.ProcessTerminated

func (*AgentUpdateInfo) GetSchema 

func (m *AgentUpdateInfo) GetSchema() []*storepb.TableInfo

func (*AgentUpdateInfo) GoString 

func (this *AgentUpdateInfo) GoString() string

func (*AgentUpdateInfo) Marshal 

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

func (*AgentUpdateInfo) MarshalTo 

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

func (*AgentUpdateInfo) MarshalToSizedBuffer 

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

func (*AgentUpdateInfo) ProtoMessage 

func (*AgentUpdateInfo) ProtoMessage()

func (*AgentUpdateInfo) Reset 

func (m *AgentUpdateInfo) Reset()

func (*AgentUpdateInfo) Size 

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

func (*AgentUpdateInfo) String 

func (this *AgentUpdateInfo) String() string

func (*AgentUpdateInfo) Unmarshal 

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

func (*AgentUpdateInfo) XXX_DiscardUnknown 

func (m *AgentUpdateInfo) XXX_DiscardUnknown()

func (*AgentUpdateInfo) XXX_Marshal 

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

func (*AgentUpdateInfo) XXX_Merge 

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

func (*AgentUpdateInfo) XXX_Size 

func (m *AgentUpdateInfo) XXX_Size() int

func (*AgentUpdateInfo) XXX_Unmarshal 

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

type ConfigUpdateMessage 

type ConfigUpdateMessage struct {
	// Types that are valid to be assigned to Msg:
	//	*ConfigUpdateMessage_ConfigUpdateRequest
	Msg isConfigUpdateMessage_Msg `protobuf_oneof:"msg"`
}

func (*ConfigUpdateMessage) Descriptor 

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

func (*ConfigUpdateMessage) Equal 

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

func (*ConfigUpdateMessage) GetConfigUpdateRequest 

func (m *ConfigUpdateMessage) GetConfigUpdateRequest() *ConfigUpdateRequest

func (*ConfigUpdateMessage) GetMsg 

func (m *ConfigUpdateMessage) GetMsg() isConfigUpdateMessage_Msg

func (*ConfigUpdateMessage) GoString 

func (this *ConfigUpdateMessage) GoString() string

func (*ConfigUpdateMessage) Marshal 

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

func (*ConfigUpdateMessage) MarshalTo 

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

func (*ConfigUpdateMessage) MarshalToSizedBuffer 

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

func (*ConfigUpdateMessage) ProtoMessage 

func (*ConfigUpdateMessage) ProtoMessage()

func (*ConfigUpdateMessage) Reset 

func (m *ConfigUpdateMessage) Reset()

func (*ConfigUpdateMessage) Size 

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

func (*ConfigUpdateMessage) String 

func (this *ConfigUpdateMessage) String() string

func (*ConfigUpdateMessage) Unmarshal 

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

func (*ConfigUpdateMessage) XXX_DiscardUnknown 

func (m *ConfigUpdateMessage) XXX_DiscardUnknown()

func (*ConfigUpdateMessage) XXX_Marshal 

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

func (*ConfigUpdateMessage) XXX_Merge 

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

func (*ConfigUpdateMessage) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ConfigUpdateMessage) XXX_Size 

func (m *ConfigUpdateMessage) XXX_Size() int

func (*ConfigUpdateMessage) XXX_Unmarshal 

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

type ConfigUpdateMessage_ConfigUpdateRequest 

type ConfigUpdateMessage_ConfigUpdateRequest struct {
	ConfigUpdateRequest *ConfigUpdateRequest `` /* 126-byte string literal not displayed */
}

func (*ConfigUpdateMessage_ConfigUpdateRequest) Equal 

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

func (*ConfigUpdateMessage_ConfigUpdateRequest) GoString 

func (this *ConfigUpdateMessage_ConfigUpdateRequest) GoString() string

func (*ConfigUpdateMessage_ConfigUpdateRequest) MarshalTo 

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

func (*ConfigUpdateMessage_ConfigUpdateRequest) MarshalToSizedBuffer 

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

func (*ConfigUpdateMessage_ConfigUpdateRequest) Size 

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

func (*ConfigUpdateMessage_ConfigUpdateRequest) String 

func (this *ConfigUpdateMessage_ConfigUpdateRequest) String() string

type ConfigUpdateRequest 

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

func (*ConfigUpdateRequest) Descriptor 

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

func (*ConfigUpdateRequest) Equal 

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

func (*ConfigUpdateRequest) GetKey 

func (m *ConfigUpdateRequest) GetKey() string

func (*ConfigUpdateRequest) GetValue 

func (m *ConfigUpdateRequest) GetValue() string

func (*ConfigUpdateRequest) GoString 

func (this *ConfigUpdateRequest) GoString() string

func (*ConfigUpdateRequest) Marshal 

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

func (*ConfigUpdateRequest) MarshalTo 

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

func (*ConfigUpdateRequest) MarshalToSizedBuffer 

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

func (*ConfigUpdateRequest) ProtoMessage 

func (*ConfigUpdateRequest) ProtoMessage()

func (*ConfigUpdateRequest) Reset 

func (m *ConfigUpdateRequest) Reset()

func (*ConfigUpdateRequest) Size 

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

func (*ConfigUpdateRequest) String 

func (this *ConfigUpdateRequest) String() string

func (*ConfigUpdateRequest) Unmarshal 

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

func (*ConfigUpdateRequest) XXX_DiscardUnknown 

func (m *ConfigUpdateRequest) XXX_DiscardUnknown()

func (*ConfigUpdateRequest) XXX_Marshal 

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

func (*ConfigUpdateRequest) XXX_Merge 

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

func (*ConfigUpdateRequest) XXX_Size 

func (m *ConfigUpdateRequest) XXX_Size() int

func (*ConfigUpdateRequest) XXX_Unmarshal 

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

type ExecuteQueryRequest 

type ExecuteQueryRequest struct {
	QueryID *uuidpb.UUID `protobuf:"bytes,1,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	Plan    *planpb.Plan `protobuf:"bytes,3,opt,name=plan,proto3" json:"plan,omitempty"`
	Analyze bool         `protobuf:"varint,4,opt,name=analyze,proto3" json:"analyze,omitempty"`
}

func (*ExecuteQueryRequest) Descriptor 

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

func (*ExecuteQueryRequest) Equal 

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

func (*ExecuteQueryRequest) GetAnalyze 

func (m *ExecuteQueryRequest) GetAnalyze() bool

func (*ExecuteQueryRequest) GetPlan 

func (m *ExecuteQueryRequest) GetPlan() *planpb.Plan

func (*ExecuteQueryRequest) GetQueryID 

func (m *ExecuteQueryRequest) GetQueryID() *uuidpb.UUID

func (*ExecuteQueryRequest) GoString 

func (this *ExecuteQueryRequest) GoString() string

func (*ExecuteQueryRequest) Marshal 

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

func (*ExecuteQueryRequest) MarshalTo 

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

func (*ExecuteQueryRequest) MarshalToSizedBuffer 

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

func (*ExecuteQueryRequest) ProtoMessage 

func (*ExecuteQueryRequest) ProtoMessage()

func (*ExecuteQueryRequest) Reset 

func (m *ExecuteQueryRequest) Reset()

func (*ExecuteQueryRequest) Size 

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

func (*ExecuteQueryRequest) String 

func (this *ExecuteQueryRequest) String() string

func (*ExecuteQueryRequest) Unmarshal 

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

func (*ExecuteQueryRequest) XXX_DiscardUnknown 

func (m *ExecuteQueryRequest) XXX_DiscardUnknown()

func (*ExecuteQueryRequest) XXX_Marshal 

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

func (*ExecuteQueryRequest) XXX_Merge 

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

func (*ExecuteQueryRequest) XXX_Size 

func (m *ExecuteQueryRequest) XXX_Size() int

func (*ExecuteQueryRequest) XXX_Unmarshal 

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

type Heartbeat 

type Heartbeat struct {
	AgentID        *uuidpb.UUID     `protobuf:"bytes,1,opt,name=agent_id,json=agentId,proto3" json:"agent_id,omitempty"`
	Time           int64            `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	UpdateInfo     *AgentUpdateInfo `protobuf:"bytes,3,opt,name=update_info,json=updateInfo,proto3" json:"update_info,omitempty"`
	SequenceNumber int64            `protobuf:"varint,4,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
}

func (*Heartbeat) Descriptor 

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

func (*Heartbeat) Equal 

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

func (*Heartbeat) GetAgentID 

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

func (*Heartbeat) GetSequenceNumber 

func (m *Heartbeat) GetSequenceNumber() int64

func (*Heartbeat) GetTime 

func (m *Heartbeat) GetTime() int64

func (*Heartbeat) GetUpdateInfo 

func (m *Heartbeat) GetUpdateInfo() *AgentUpdateInfo

func (*Heartbeat) GoString 

func (this *Heartbeat) GoString() string

func (*Heartbeat) Marshal 

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

func (*Heartbeat) MarshalTo 

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

func (*Heartbeat) MarshalToSizedBuffer 

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

func (*Heartbeat) ProtoMessage 

func (*Heartbeat) ProtoMessage()

func (*Heartbeat) Reset 

func (m *Heartbeat) Reset()

func (*Heartbeat) Size 

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

func (*Heartbeat) String 

func (this *Heartbeat) String() string

func (*Heartbeat) Unmarshal 

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

func (*Heartbeat) XXX_DiscardUnknown 

func (m *Heartbeat) XXX_DiscardUnknown()

func (*Heartbeat) XXX_Marshal 

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

func (*Heartbeat) XXX_Merge 

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

func (*Heartbeat) XXX_Size 

func (m *Heartbeat) XXX_Size() int

func (*Heartbeat) XXX_Unmarshal 

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

type HeartbeatAck 

type HeartbeatAck struct {
	Time           int64               `protobuf:"varint,1,opt,name=time,proto3" json:"time,omitempty"`
	SequenceNumber int64               `protobuf:"varint,2,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	UpdateInfo     *MetadataUpdateInfo `protobuf:"bytes,3,opt,name=update_info,json=updateInfo,proto3" json:"update_info,omitempty"`
}

func (*HeartbeatAck) Descriptor 

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

func (*HeartbeatAck) Equal 

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

func (*HeartbeatAck) GetSequenceNumber 

func (m *HeartbeatAck) GetSequenceNumber() int64

func (*HeartbeatAck) GetTime 

func (m *HeartbeatAck) GetTime() int64

func (*HeartbeatAck) GetUpdateInfo 

func (m *HeartbeatAck) GetUpdateInfo() *MetadataUpdateInfo

func (*HeartbeatAck) GoString 

func (this *HeartbeatAck) GoString() string

func (*HeartbeatAck) Marshal 

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

func (*HeartbeatAck) MarshalTo 

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

func (*HeartbeatAck) MarshalToSizedBuffer 

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

func (*HeartbeatAck) ProtoMessage 

func (*HeartbeatAck) ProtoMessage()

func (*HeartbeatAck) Reset 

func (m *HeartbeatAck) Reset()

func (*HeartbeatAck) Size 

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

func (*HeartbeatAck) String 

func (this *HeartbeatAck) String() string

func (*HeartbeatAck) Unmarshal 

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

func (*HeartbeatAck) XXX_DiscardUnknown 

func (m *HeartbeatAck) XXX_DiscardUnknown()

func (*HeartbeatAck) XXX_Marshal 

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

func (*HeartbeatAck) XXX_Merge 

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

func (*HeartbeatAck) XXX_Size 

func (m *HeartbeatAck) XXX_Size() int

func (*HeartbeatAck) XXX_Unmarshal 

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

type HeartbeatNack 

type HeartbeatNack struct {
	Reregister bool `protobuf:"varint,1,opt,name=reregister,proto3" json:"reregister,omitempty"`
}

func (*HeartbeatNack) Descriptor 

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

func (*HeartbeatNack) Equal 

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

func (*HeartbeatNack) GetReregister 

func (m *HeartbeatNack) GetReregister() bool

func (*HeartbeatNack) GoString 

func (this *HeartbeatNack) GoString() string

func (*HeartbeatNack) Marshal 

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

func (*HeartbeatNack) MarshalTo 

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

func (*HeartbeatNack) MarshalToSizedBuffer 

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

func (*HeartbeatNack) ProtoMessage 

func (*HeartbeatNack) ProtoMessage()

func (*HeartbeatNack) Reset 

func (m *HeartbeatNack) Reset()

func (*HeartbeatNack) Size 

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

func (*HeartbeatNack) String 

func (this *HeartbeatNack) String() string

func (*HeartbeatNack) Unmarshal 

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

func (*HeartbeatNack) XXX_DiscardUnknown 

func (m *HeartbeatNack) XXX_DiscardUnknown()

func (*HeartbeatNack) XXX_Marshal 

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

func (*HeartbeatNack) XXX_Merge 

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

func (*HeartbeatNack) XXX_Size 

func (m *HeartbeatNack) XXX_Size() int

func (*HeartbeatNack) XXX_Unmarshal 

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

type K8SMetadataMessage 

type K8SMetadataMessage struct {
	// Types that are valid to be assigned to Msg:
	//	*K8SMetadataMessage_K8SMetadataUpdate
	//	*K8SMetadataMessage_MissingK8SMetadataRequest
	//	*K8SMetadataMessage_MissingK8SMetadataResponse
	Msg isK8SMetadataMessage_Msg `protobuf_oneof:"msg"`
}

func (*K8SMetadataMessage) Descriptor 

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

func (*K8SMetadataMessage) Equal 

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

func (*K8SMetadataMessage) GetK8SMetadataUpdate 

func (m *K8SMetadataMessage) GetK8SMetadataUpdate() *metadatapb.ResourceUpdate

func (*K8SMetadataMessage) GetMissingK8SMetadataRequest 

func (m *K8SMetadataMessage) GetMissingK8SMetadataRequest() *metadatapb.MissingK8SMetadataRequest

func (*K8SMetadataMessage) GetMissingK8SMetadataResponse 

func (m *K8SMetadataMessage) GetMissingK8SMetadataResponse() *metadatapb.MissingK8SMetadataResponse

func (*K8SMetadataMessage) GetMsg 

func (m *K8SMetadataMessage) GetMsg() isK8SMetadataMessage_Msg

func (*K8SMetadataMessage) GoString 

func (this *K8SMetadataMessage) GoString() string

func (*K8SMetadataMessage) Marshal 

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

func (*K8SMetadataMessage) MarshalTo 

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

func (*K8SMetadataMessage) MarshalToSizedBuffer 

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

func (*K8SMetadataMessage) ProtoMessage 

func (*K8SMetadataMessage) ProtoMessage()

func (*K8SMetadataMessage) Reset 

func (m *K8SMetadataMessage) Reset()

func (*K8SMetadataMessage) Size 

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

func (*K8SMetadataMessage) String 

func (this *K8SMetadataMessage) String() string

func (*K8SMetadataMessage) Unmarshal 

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

func (*K8SMetadataMessage) XXX_DiscardUnknown 

func (m *K8SMetadataMessage) XXX_DiscardUnknown()

func (*K8SMetadataMessage) XXX_Marshal 

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

func (*K8SMetadataMessage) XXX_Merge 

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

func (*K8SMetadataMessage) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*K8SMetadataMessage) XXX_Size 

func (m *K8SMetadataMessage) XXX_Size() int

func (*K8SMetadataMessage) XXX_Unmarshal 

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

type K8SMetadataMessage_K8SMetadataUpdate 

type K8SMetadataMessage_K8SMetadataUpdate struct {
	K8SMetadataUpdate *metadatapb.ResourceUpdate `protobuf:"bytes,1,opt,name=k8s_metadata_update,json=k8sMetadataUpdate,proto3,oneof" json:"k8s_metadata_update,omitempty"`
}

func (*K8SMetadataMessage_K8SMetadataUpdate) Equal 

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

func (*K8SMetadataMessage_K8SMetadataUpdate) GoString 

func (this *K8SMetadataMessage_K8SMetadataUpdate) GoString() string

func (*K8SMetadataMessage_K8SMetadataUpdate) MarshalTo 

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

func (*K8SMetadataMessage_K8SMetadataUpdate) MarshalToSizedBuffer 

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

func (*K8SMetadataMessage_K8SMetadataUpdate) Size 

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

func (*K8SMetadataMessage_K8SMetadataUpdate) String 

func (this *K8SMetadataMessage_K8SMetadataUpdate) String() string

type K8SMetadataMessage_MissingK8SMetadataRequest 

type K8SMetadataMessage_MissingK8SMetadataRequest struct {
	MissingK8SMetadataRequest *metadatapb.MissingK8SMetadataRequest `` /* 146-byte string literal not displayed */
}

func (*K8SMetadataMessage_MissingK8SMetadataRequest) Equal 

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

func (*K8SMetadataMessage_MissingK8SMetadataRequest) GoString 

func (this *K8SMetadataMessage_MissingK8SMetadataRequest) GoString() string

func (*K8SMetadataMessage_MissingK8SMetadataRequest) MarshalTo 

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

func (*K8SMetadataMessage_MissingK8SMetadataRequest) MarshalToSizedBuffer 

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

func (*K8SMetadataMessage_MissingK8SMetadataRequest) Size 

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

func (*K8SMetadataMessage_MissingK8SMetadataRequest) String 

func (this *K8SMetadataMessage_MissingK8SMetadataRequest) String() string

type K8SMetadataMessage_MissingK8SMetadataResponse 

type K8SMetadataMessage_MissingK8SMetadataResponse struct {
	MissingK8SMetadataResponse *metadatapb.MissingK8SMetadataResponse `` /* 149-byte string literal not displayed */
}

func (*K8SMetadataMessage_MissingK8SMetadataResponse) Equal 

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

func (*K8SMetadataMessage_MissingK8SMetadataResponse) GoString 

func (this *K8SMetadataMessage_MissingK8SMetadataResponse) GoString() string

func (*K8SMetadataMessage_MissingK8SMetadataResponse) MarshalTo 

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

func (*K8SMetadataMessage_MissingK8SMetadataResponse) MarshalToSizedBuffer 

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

func (*K8SMetadataMessage_MissingK8SMetadataResponse) Size 

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

func (*K8SMetadataMessage_MissingK8SMetadataResponse) String 

func (this *K8SMetadataMessage_MissingK8SMetadataResponse) String() string

type MetadataUpdateInfo 

type MetadataUpdateInfo struct {
	ServiceCIDR string   `protobuf:"bytes,2,opt,name=service_cidr,json=serviceCidr,proto3" json:"service_cidr,omitempty"`
	PodCIDRs    []string `protobuf:"bytes,3,rep,name=pod_cidrs,json=podCidrs,proto3" json:"pod_cidrs,omitempty"`
}

func (*MetadataUpdateInfo) Descriptor 

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

func (*MetadataUpdateInfo) Equal 

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

func (*MetadataUpdateInfo) GetPodCIDRs 

func (m *MetadataUpdateInfo) GetPodCIDRs() []string

func (*MetadataUpdateInfo) GetServiceCIDR 

func (m *MetadataUpdateInfo) GetServiceCIDR() string

func (*MetadataUpdateInfo) GoString 

func (this *MetadataUpdateInfo) GoString() string

func (*MetadataUpdateInfo) Marshal 

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

func (*MetadataUpdateInfo) MarshalTo 

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

func (*MetadataUpdateInfo) MarshalToSizedBuffer 

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

func (*MetadataUpdateInfo) ProtoMessage 

func (*MetadataUpdateInfo) ProtoMessage()

func (*MetadataUpdateInfo) Reset 

func (m *MetadataUpdateInfo) Reset()

func (*MetadataUpdateInfo) Size 

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

func (*MetadataUpdateInfo) String 

func (this *MetadataUpdateInfo) String() string

func (*MetadataUpdateInfo) Unmarshal 

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

func (*MetadataUpdateInfo) XXX_DiscardUnknown 

func (m *MetadataUpdateInfo) XXX_DiscardUnknown()

func (*MetadataUpdateInfo) XXX_Marshal 

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

func (*MetadataUpdateInfo) XXX_Merge 

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

func (*MetadataUpdateInfo) XXX_Size 

func (m *MetadataUpdateInfo) XXX_Size() int

func (*MetadataUpdateInfo) XXX_Unmarshal 

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

type MetricsMessage 

type MetricsMessage struct {
	PromMetricsText string `protobuf:"bytes,1,opt,name=prom_metrics_text,json=promMetricsText,proto3" json:"prom_metrics_text,omitempty"`
	PodName         string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
}

func (*MetricsMessage) Descriptor 

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

func (*MetricsMessage) Equal 

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

func (*MetricsMessage) GetPodName 

func (m *MetricsMessage) GetPodName() string

func (*MetricsMessage) GetPromMetricsText 

func (m *MetricsMessage) GetPromMetricsText() string

func (*MetricsMessage) GoString 

func (this *MetricsMessage) GoString() string

func (*MetricsMessage) Marshal 

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

func (*MetricsMessage) MarshalTo 

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

func (*MetricsMessage) MarshalToSizedBuffer 

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

func (*MetricsMessage) ProtoMessage 

func (*MetricsMessage) ProtoMessage()

func (*MetricsMessage) Reset 

func (m *MetricsMessage) Reset()

func (*MetricsMessage) Size 

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

func (*MetricsMessage) String 

func (this *MetricsMessage) String() string

func (*MetricsMessage) Unmarshal 

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

func (*MetricsMessage) XXX_DiscardUnknown 

func (m *MetricsMessage) XXX_DiscardUnknown()

func (*MetricsMessage) XXX_Marshal 

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

func (*MetricsMessage) XXX_Merge 

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

func (*MetricsMessage) XXX_Size 

func (m *MetricsMessage) XXX_Size() int

func (*MetricsMessage) XXX_Unmarshal 

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

type RegisterAgentRequest 

type RegisterAgentRequest struct {
	Info *agentpb.AgentInfo `protobuf:"bytes,1,opt,name=info,proto3" json:"info,omitempty"`
	ASID uint32             `protobuf:"varint,3,opt,name=asid,proto3" json:"asid,omitempty"`
}

func (*RegisterAgentRequest) Descriptor 

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

func (*RegisterAgentRequest) Equal 

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

func (*RegisterAgentRequest) GetASID 

func (m *RegisterAgentRequest) GetASID() uint32

func (*RegisterAgentRequest) GetInfo 

func (m *RegisterAgentRequest) GetInfo() *agentpb.AgentInfo

func (*RegisterAgentRequest) GoString 

func (this *RegisterAgentRequest) GoString() string

func (*RegisterAgentRequest) Marshal 

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

func (*RegisterAgentRequest) MarshalTo 

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

func (*RegisterAgentRequest) MarshalToSizedBuffer 

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

func (*RegisterAgentRequest) ProtoMessage 

func (*RegisterAgentRequest) ProtoMessage()

func (*RegisterAgentRequest) Reset 

func (m *RegisterAgentRequest) Reset()

func (*RegisterAgentRequest) Size 

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

func (*RegisterAgentRequest) String 

func (this *RegisterAgentRequest) String() string

func (*RegisterAgentRequest) Unmarshal 

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

func (*RegisterAgentRequest) XXX_DiscardUnknown 

func (m *RegisterAgentRequest) XXX_DiscardUnknown()

func (*RegisterAgentRequest) XXX_Marshal 

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

func (*RegisterAgentRequest) XXX_Merge 

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

func (*RegisterAgentRequest) XXX_Size 

func (m *RegisterAgentRequest) XXX_Size() int

func (*RegisterAgentRequest) XXX_Unmarshal 

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

type RegisterAgentResponse 

type RegisterAgentResponse struct {
	ASID uint32 `protobuf:"varint,1,opt,name=asid,proto3" json:"asid,omitempty"`
}

func (*RegisterAgentResponse) Descriptor 

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

func (*RegisterAgentResponse) Equal 

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

func (*RegisterAgentResponse) GetASID 

func (m *RegisterAgentResponse) GetASID() uint32

func (*RegisterAgentResponse) GoString 

func (this *RegisterAgentResponse) GoString() string

func (*RegisterAgentResponse) Marshal 

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

func (*RegisterAgentResponse) MarshalTo 

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

func (*RegisterAgentResponse) MarshalToSizedBuffer 

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

func (*RegisterAgentResponse) ProtoMessage 

func (*RegisterAgentResponse) ProtoMessage()

func (*RegisterAgentResponse) Reset 

func (m *RegisterAgentResponse) Reset()

func (*RegisterAgentResponse) Size 

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

func (*RegisterAgentResponse) String 

func (this *RegisterAgentResponse) String() string

func (*RegisterAgentResponse) Unmarshal 

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

func (*RegisterAgentResponse) XXX_DiscardUnknown 

func (m *RegisterAgentResponse) XXX_DiscardUnknown()

func (*RegisterAgentResponse) XXX_Marshal 

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

func (*RegisterAgentResponse) XXX_Merge 

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

func (*RegisterAgentResponse) XXX_Size 

func (m *RegisterAgentResponse) XXX_Size() int

func (*RegisterAgentResponse) XXX_Unmarshal 

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

type RegisterTracepointRequest 

type RegisterTracepointRequest struct {
	TracepointDeployment *logicalpb.TracepointDeployment `protobuf:"bytes,1,opt,name=tracepoint_deployment,json=tracepointDeployment,proto3" json:"tracepoint_deployment,omitempty"`
	ID                   *uuidpb.UUID                    `protobuf:"bytes,2,opt,name=id,proto3" json:"id,omitempty"`
}

func (*RegisterTracepointRequest) Descriptor 

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

func (*RegisterTracepointRequest) Equal 

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

func (*RegisterTracepointRequest) GetID 

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

func (*RegisterTracepointRequest) GetTracepointDeployment 

func (m *RegisterTracepointRequest) GetTracepointDeployment() *logicalpb.TracepointDeployment

func (*RegisterTracepointRequest) GoString 

func (this *RegisterTracepointRequest) GoString() string

func (*RegisterTracepointRequest) Marshal 

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

func (*RegisterTracepointRequest) MarshalTo 

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

func (*RegisterTracepointRequest) MarshalToSizedBuffer 

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

func (*RegisterTracepointRequest) ProtoMessage 

func (*RegisterTracepointRequest) ProtoMessage()

func (*RegisterTracepointRequest) Reset 

func (m *RegisterTracepointRequest) Reset()

func (*RegisterTracepointRequest) Size 

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

func (*RegisterTracepointRequest) String 

func (this *RegisterTracepointRequest) String() string

func (*RegisterTracepointRequest) Unmarshal 

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

func (*RegisterTracepointRequest) XXX_DiscardUnknown 

func (m *RegisterTracepointRequest) XXX_DiscardUnknown()

func (*RegisterTracepointRequest) XXX_Marshal 

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

func (*RegisterTracepointRequest) XXX_Merge 

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

func (*RegisterTracepointRequest) XXX_Size 

func (m *RegisterTracepointRequest) XXX_Size() int

func (*RegisterTracepointRequest) XXX_Unmarshal 

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

type RemoveTracepointRequest 

type RemoveTracepointRequest struct {
	ID *uuidpb.UUID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
}

func (*RemoveTracepointRequest) Descriptor 

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

func (*RemoveTracepointRequest) Equal 

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

func (*RemoveTracepointRequest) GetID 

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

func (*RemoveTracepointRequest) GoString 

func (this *RemoveTracepointRequest) GoString() string

func (*RemoveTracepointRequest) Marshal 

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

func (*RemoveTracepointRequest) MarshalTo 

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

func (*RemoveTracepointRequest) MarshalToSizedBuffer 

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

func (*RemoveTracepointRequest) ProtoMessage 

func (*RemoveTracepointRequest) ProtoMessage()

func (*RemoveTracepointRequest) Reset 

func (m *RemoveTracepointRequest) Reset()

func (*RemoveTracepointRequest) Size 

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

func (*RemoveTracepointRequest) String 

func (this *RemoveTracepointRequest) String() string

func (*RemoveTracepointRequest) Unmarshal 

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

func (*RemoveTracepointRequest) XXX_DiscardUnknown 

func (m *RemoveTracepointRequest) XXX_DiscardUnknown()

func (*RemoveTracepointRequest) XXX_Marshal 

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

func (*RemoveTracepointRequest) XXX_Merge 

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

func (*RemoveTracepointRequest) XXX_Size 

func (m *RemoveTracepointRequest) XXX_Size() int

func (*RemoveTracepointRequest) XXX_Unmarshal 

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

type TracepointInfoUpdate 

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

func (*TracepointInfoUpdate) Descriptor 

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

func (*TracepointInfoUpdate) Equal 

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

func (*TracepointInfoUpdate) GetAgentID 

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

func (*TracepointInfoUpdate) GetID 

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

func (*TracepointInfoUpdate) GetState 

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

func (*TracepointInfoUpdate) GetStatus 

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

func (*TracepointInfoUpdate) GoString 

func (this *TracepointInfoUpdate) GoString() string

func (*TracepointInfoUpdate) Marshal 

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

func (*TracepointInfoUpdate) MarshalTo 

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

func (*TracepointInfoUpdate) MarshalToSizedBuffer 

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

func (*TracepointInfoUpdate) ProtoMessage 

func (*TracepointInfoUpdate) ProtoMessage()

func (*TracepointInfoUpdate) Reset 

func (m *TracepointInfoUpdate) Reset()

func (*TracepointInfoUpdate) Size 

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

func (*TracepointInfoUpdate) String 

func (this *TracepointInfoUpdate) String() string

func (*TracepointInfoUpdate) Unmarshal 

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

func (*TracepointInfoUpdate) XXX_DiscardUnknown 

func (m *TracepointInfoUpdate) XXX_DiscardUnknown()

func (*TracepointInfoUpdate) XXX_Marshal 

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

func (*TracepointInfoUpdate) XXX_Merge 

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

func (*TracepointInfoUpdate) XXX_Size 

func (m *TracepointInfoUpdate) XXX_Size() int

func (*TracepointInfoUpdate) XXX_Unmarshal 

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

type TracepointMessage 

type TracepointMessage struct {
	// Types that are valid to be assigned to Msg:
	//	*TracepointMessage_TracepointInfoUpdate
	//	*TracepointMessage_RemoveTracepointRequest
	//	*TracepointMessage_RegisterTracepointRequest
	Msg isTracepointMessage_Msg `protobuf_oneof:"msg"`
}

func (*TracepointMessage) Descriptor 

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

func (*TracepointMessage) Equal 

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

func (*TracepointMessage) GetMsg 

func (m *TracepointMessage) GetMsg() isTracepointMessage_Msg

func (*TracepointMessage) GetRegisterTracepointRequest 

func (m *TracepointMessage) GetRegisterTracepointRequest() *RegisterTracepointRequest

func (*TracepointMessage) GetRemoveTracepointRequest 

func (m *TracepointMessage) GetRemoveTracepointRequest() *RemoveTracepointRequest

func (*TracepointMessage) GetTracepointInfoUpdate 

func (m *TracepointMessage) GetTracepointInfoUpdate() *TracepointInfoUpdate

func (*TracepointMessage) GoString 

func (this *TracepointMessage) GoString() string

func (*TracepointMessage) Marshal 

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

func (*TracepointMessage) MarshalTo 

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

func (*TracepointMessage) MarshalToSizedBuffer 

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

func (*TracepointMessage) ProtoMessage 

func (*TracepointMessage) ProtoMessage()

func (*TracepointMessage) Reset 

func (m *TracepointMessage) Reset()

func (*TracepointMessage) Size 

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

func (*TracepointMessage) String 

func (this *TracepointMessage) String() string

func (*TracepointMessage) Unmarshal 

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

func (*TracepointMessage) XXX_DiscardUnknown 

func (m *TracepointMessage) XXX_DiscardUnknown()

func (*TracepointMessage) XXX_Marshal 

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

func (*TracepointMessage) XXX_Merge 

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

func (*TracepointMessage) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*TracepointMessage) XXX_Size 

func (m *TracepointMessage) XXX_Size() int

func (*TracepointMessage) XXX_Unmarshal 

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

type TracepointMessage_RegisterTracepointRequest 

type TracepointMessage_RegisterTracepointRequest struct {
	RegisterTracepointRequest *RegisterTracepointRequest `` /* 144-byte string literal not displayed */
}

func (*TracepointMessage_RegisterTracepointRequest) Equal 

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

func (*TracepointMessage_RegisterTracepointRequest) GoString 

func (this *TracepointMessage_RegisterTracepointRequest) GoString() string

func (*TracepointMessage_RegisterTracepointRequest) MarshalTo 

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

func (*TracepointMessage_RegisterTracepointRequest) MarshalToSizedBuffer 

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

func (*TracepointMessage_RegisterTracepointRequest) Size 

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

func (*TracepointMessage_RegisterTracepointRequest) String 

func (this *TracepointMessage_RegisterTracepointRequest) String() string

type TracepointMessage_RemoveTracepointRequest 

type TracepointMessage_RemoveTracepointRequest struct {
	RemoveTracepointRequest *RemoveTracepointRequest `` /* 138-byte string literal not displayed */
}

func (*TracepointMessage_RemoveTracepointRequest) Equal 

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

func (*TracepointMessage_RemoveTracepointRequest) GoString 

func (this *TracepointMessage_RemoveTracepointRequest) GoString() string

func (*TracepointMessage_RemoveTracepointRequest) MarshalTo 

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

func (*TracepointMessage_RemoveTracepointRequest) MarshalToSizedBuffer 

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

func (*TracepointMessage_RemoveTracepointRequest) Size 

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

func (*TracepointMessage_RemoveTracepointRequest) String 

func (this *TracepointMessage_RemoveTracepointRequest) String() string

type TracepointMessage_TracepointInfoUpdate 

type TracepointMessage_TracepointInfoUpdate struct {
	TracepointInfoUpdate *TracepointInfoUpdate `` /* 129-byte string literal not displayed */
}

func (*TracepointMessage_TracepointInfoUpdate) Equal 

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

func (*TracepointMessage_TracepointInfoUpdate) GoString 

func (this *TracepointMessage_TracepointInfoUpdate) GoString() string

func (*TracepointMessage_TracepointInfoUpdate) MarshalTo 

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

func (*TracepointMessage_TracepointInfoUpdate) MarshalToSizedBuffer 

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

func (*TracepointMessage_TracepointInfoUpdate) Size 

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

func (*TracepointMessage_TracepointInfoUpdate) String 

func (this *TracepointMessage_TracepointInfoUpdate) String() string

type VizierMessage 

type VizierMessage struct {
	// Types that are valid to be assigned to Msg:
	//	*VizierMessage_RegisterAgentRequest
	//	*VizierMessage_RegisterAgentResponse
	//	*VizierMessage_Heartbeat
	//	*VizierMessage_HeartbeatAck
	//	*VizierMessage_HeartbeatNack
	//	*VizierMessage_ExecuteQueryRequest
	//	*VizierMessage_TracepointMessage
	//	*VizierMessage_ConfigUpdateMessage
	//	*VizierMessage_K8SMetadataMessage
	Msg isVizierMessage_Msg `protobuf_oneof:"msg"`
}

func (*VizierMessage) Descriptor 

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

func (*VizierMessage) Equal 

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

func (*VizierMessage) GetConfigUpdateMessage 

func (m *VizierMessage) GetConfigUpdateMessage() *ConfigUpdateMessage

func (*VizierMessage) GetExecuteQueryRequest 

func (m *VizierMessage) GetExecuteQueryRequest() *ExecuteQueryRequest

func (*VizierMessage) GetHeartbeat 

func (m *VizierMessage) GetHeartbeat() *Heartbeat

func (*VizierMessage) GetHeartbeatAck 

func (m *VizierMessage) GetHeartbeatAck() *HeartbeatAck

func (*VizierMessage) GetHeartbeatNack 

func (m *VizierMessage) GetHeartbeatNack() *HeartbeatNack

func (*VizierMessage) GetK8SMetadataMessage 

func (m *VizierMessage) GetK8SMetadataMessage() *K8SMetadataMessage

func (*VizierMessage) GetMsg 

func (m *VizierMessage) GetMsg() isVizierMessage_Msg

func (*VizierMessage) GetRegisterAgentRequest 

func (m *VizierMessage) GetRegisterAgentRequest() *RegisterAgentRequest

func (*VizierMessage) GetRegisterAgentResponse 

func (m *VizierMessage) GetRegisterAgentResponse() *RegisterAgentResponse

func (*VizierMessage) GetTracepointMessage 

func (m *VizierMessage) GetTracepointMessage() *TracepointMessage

func (*VizierMessage) GoString 

func (this *VizierMessage) GoString() string

func (*VizierMessage) Marshal 

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

func (*VizierMessage) MarshalTo 

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

func (*VizierMessage) MarshalToSizedBuffer 

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

func (*VizierMessage) ProtoMessage 

func (*VizierMessage) ProtoMessage()

func (*VizierMessage) Reset 

func (m *VizierMessage) Reset()

func (*VizierMessage) Size 

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

func (*VizierMessage) String 

func (this *VizierMessage) String() string

func (*VizierMessage) Unmarshal 

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

func (*VizierMessage) XXX_DiscardUnknown 

func (m *VizierMessage) XXX_DiscardUnknown()

func (*VizierMessage) XXX_Marshal 

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

func (*VizierMessage) XXX_Merge 

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

func (*VizierMessage) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*VizierMessage) XXX_Size 

func (m *VizierMessage) XXX_Size() int

func (*VizierMessage) XXX_Unmarshal 

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

type VizierMessage_ConfigUpdateMessage 

type VizierMessage_ConfigUpdateMessage struct {
	ConfigUpdateMessage *ConfigUpdateMessage `` /* 127-byte string literal not displayed */
}

func (*VizierMessage_ConfigUpdateMessage) Equal 

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

func (*VizierMessage_ConfigUpdateMessage) GoString 

func (this *VizierMessage_ConfigUpdateMessage) GoString() string

func (*VizierMessage_ConfigUpdateMessage) MarshalTo 

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

func (*VizierMessage_ConfigUpdateMessage) MarshalToSizedBuffer 

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

func (*VizierMessage_ConfigUpdateMessage) Size 

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

func (*VizierMessage_ConfigUpdateMessage) String 

func (this *VizierMessage_ConfigUpdateMessage) String() string

type VizierMessage_ExecuteQueryRequest 

type VizierMessage_ExecuteQueryRequest struct {
	ExecuteQueryRequest *ExecuteQueryRequest `` /* 126-byte string literal not displayed */
}

func (*VizierMessage_ExecuteQueryRequest) Equal 

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

func (*VizierMessage_ExecuteQueryRequest) GoString 

func (this *VizierMessage_ExecuteQueryRequest) GoString() string

func (*VizierMessage_ExecuteQueryRequest) MarshalTo 

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

func (*VizierMessage_ExecuteQueryRequest) MarshalToSizedBuffer 

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

func (*VizierMessage_ExecuteQueryRequest) Size 

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

func (*VizierMessage_ExecuteQueryRequest) String 

func (this *VizierMessage_ExecuteQueryRequest) String() string

type VizierMessage_Heartbeat 

type VizierMessage_Heartbeat struct {
	Heartbeat *Heartbeat `protobuf:"bytes,5,opt,name=heartbeat,proto3,oneof" json:"heartbeat,omitempty"`
}

func (*VizierMessage_Heartbeat) Equal 

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

func (*VizierMessage_Heartbeat) GoString 

func (this *VizierMessage_Heartbeat) GoString() string

func (*VizierMessage_Heartbeat) MarshalTo 

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

func (*VizierMessage_Heartbeat) MarshalToSizedBuffer 

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

func (*VizierMessage_Heartbeat) Size 

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

func (*VizierMessage_Heartbeat) String 

func (this *VizierMessage_Heartbeat) String() string

type VizierMessage_HeartbeatAck 

type VizierMessage_HeartbeatAck struct {
	HeartbeatAck *HeartbeatAck `protobuf:"bytes,6,opt,name=heartbeat_ack,json=heartbeatAck,proto3,oneof" json:"heartbeat_ack,omitempty"`
}

func (*VizierMessage_HeartbeatAck) Equal 

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

func (*VizierMessage_HeartbeatAck) GoString 

func (this *VizierMessage_HeartbeatAck) GoString() string

func (*VizierMessage_HeartbeatAck) MarshalTo 

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

func (*VizierMessage_HeartbeatAck) MarshalToSizedBuffer 

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

func (*VizierMessage_HeartbeatAck) Size 

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

func (*VizierMessage_HeartbeatAck) String 

func (this *VizierMessage_HeartbeatAck) String() string

type VizierMessage_HeartbeatNack 

type VizierMessage_HeartbeatNack struct {
	HeartbeatNack *HeartbeatNack `protobuf:"bytes,7,opt,name=heartbeat_nack,json=heartbeatNack,proto3,oneof" json:"heartbeat_nack,omitempty"`
}

func (*VizierMessage_HeartbeatNack) Equal 

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

func (*VizierMessage_HeartbeatNack) GoString 

func (this *VizierMessage_HeartbeatNack) GoString() string

func (*VizierMessage_HeartbeatNack) MarshalTo 

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

func (*VizierMessage_HeartbeatNack) MarshalToSizedBuffer 

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

func (*VizierMessage_HeartbeatNack) Size 

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

func (*VizierMessage_HeartbeatNack) String 

func (this *VizierMessage_HeartbeatNack) String() string

type VizierMessage_K8SMetadataMessage 

type VizierMessage_K8SMetadataMessage struct {
	K8SMetadataMessage *K8SMetadataMessage `protobuf:"bytes,12,opt,name=k8s_metadata_message,json=k8sMetadataMessage,proto3,oneof" json:"k8s_metadata_message,omitempty"`
}

func (*VizierMessage_K8SMetadataMessage) Equal 

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

func (*VizierMessage_K8SMetadataMessage) GoString 

func (this *VizierMessage_K8SMetadataMessage) GoString() string

func (*VizierMessage_K8SMetadataMessage) MarshalTo 

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

func (*VizierMessage_K8SMetadataMessage) MarshalToSizedBuffer 

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

func (*VizierMessage_K8SMetadataMessage) Size 

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

func (*VizierMessage_K8SMetadataMessage) String 

func (this *VizierMessage_K8SMetadataMessage) String() string

type VizierMessage_RegisterAgentRequest 

type VizierMessage_RegisterAgentRequest struct {
	RegisterAgentRequest *RegisterAgentRequest `` /* 129-byte string literal not displayed */
}

func (*VizierMessage_RegisterAgentRequest) Equal 

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

func (*VizierMessage_RegisterAgentRequest) GoString 

func (this *VizierMessage_RegisterAgentRequest) GoString() string

func (*VizierMessage_RegisterAgentRequest) MarshalTo 

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

func (*VizierMessage_RegisterAgentRequest) MarshalToSizedBuffer 

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

func (*VizierMessage_RegisterAgentRequest) Size 

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

func (*VizierMessage_RegisterAgentRequest) String 

func (this *VizierMessage_RegisterAgentRequest) String() string

type VizierMessage_RegisterAgentResponse 

type VizierMessage_RegisterAgentResponse struct {
	RegisterAgentResponse *RegisterAgentResponse `` /* 132-byte string literal not displayed */
}

func (*VizierMessage_RegisterAgentResponse) Equal 

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

func (*VizierMessage_RegisterAgentResponse) GoString 

func (this *VizierMessage_RegisterAgentResponse) GoString() string

func (*VizierMessage_RegisterAgentResponse) MarshalTo 

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

func (*VizierMessage_RegisterAgentResponse) MarshalToSizedBuffer 

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

func (*VizierMessage_RegisterAgentResponse) Size 

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

func (*VizierMessage_RegisterAgentResponse) String 

func (this *VizierMessage_RegisterAgentResponse) String() string

type VizierMessage_TracepointMessage 

type VizierMessage_TracepointMessage struct {
	TracepointMessage *TracepointMessage `protobuf:"bytes,10,opt,name=tracepoint_message,json=tracepointMessage,proto3,oneof" json:"tracepoint_message,omitempty"`
}

func (*VizierMessage_TracepointMessage) Equal 

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

func (*VizierMessage_TracepointMessage) GoString 

func (this *VizierMessage_TracepointMessage) GoString() string

func (*VizierMessage_TracepointMessage) MarshalTo 

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

func (*VizierMessage_TracepointMessage) MarshalToSizedBuffer 

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

func (*VizierMessage_TracepointMessage) Size 

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

func (*VizierMessage_TracepointMessage) String 

func (this *VizierMessage_TracepointMessage) String() string

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.