experimentpb

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: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthExperiment        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowExperiment          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupExperiment = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ActionType_name = map[int32]string{
	0: "START_VIZIER",
	1: "START_WORKLOADS",
	2: "START_METRIC_RECORDERS",
	3: "STOP_VIZIER",
	4: "STOP_WORKLOADS",
	5: "STOP_METRIC_RECORDERS",
	6: "RUN",
	7: "BURNIN",
}
View Source 
var ActionType_value = map[string]int32{
	"START_VIZIER":           0,
	"START_WORKLOADS":        1,
	"START_METRIC_RECORDERS": 2,
	"STOP_VIZIER":            3,
	"STOP_WORKLOADS":         4,
	"STOP_METRIC_RECORDERS":  5,
	"RUN":                    6,
	"BURNIN":                 7,
}

Functions

This section is empty.

Types

type ActionSpec 

type ActionSpec struct {
	Type     ActionType      `protobuf:"varint,1,opt,name=type,proto3,enum=px.perf_tool.ActionType" json:"type,omitempty"`
	Duration *types.Duration `protobuf:"bytes,2,opt,name=duration,proto3" json:"duration,omitempty"`
	Name     string          `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
}

func (*ActionSpec) Descriptor 

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

func (*ActionSpec) Equal 

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

func (*ActionSpec) GetDuration 

func (m *ActionSpec) GetDuration() *types.Duration

func (*ActionSpec) GetName 

func (m *ActionSpec) GetName() string

func (*ActionSpec) GetType 

func (m *ActionSpec) GetType() ActionType

func (*ActionSpec) GoString 

func (this *ActionSpec) GoString() string

func (*ActionSpec) Marshal 

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

func (*ActionSpec) MarshalTo 

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

func (*ActionSpec) MarshalToSizedBuffer 

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

func (*ActionSpec) ProtoMessage 

func (*ActionSpec) ProtoMessage()

func (*ActionSpec) Reset 

func (m *ActionSpec) Reset()

func (*ActionSpec) Size 

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

func (*ActionSpec) String 

func (this *ActionSpec) String() string

func (*ActionSpec) Unmarshal 

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

func (*ActionSpec) XXX_DiscardUnknown 

func (m *ActionSpec) XXX_DiscardUnknown()

func (*ActionSpec) XXX_Marshal 

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

func (*ActionSpec) XXX_Merge 

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

func (*ActionSpec) XXX_Size 

func (m *ActionSpec) XXX_Size() int

func (*ActionSpec) XXX_Unmarshal 

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

type ActionType 

type ActionType int32
const (
	START_VIZIER           ActionType = 0
	START_WORKLOADS        ActionType = 1
	START_METRIC_RECORDERS ActionType = 2
	STOP_VIZIER            ActionType = 3
	STOP_WORKLOADS         ActionType = 4
	STOP_METRIC_RECORDERS  ActionType = 5
	RUN                    ActionType = 6
	BURNIN                 ActionType = 7
)

func (ActionType) EnumDescriptor 

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

func (ActionType) String 

func (x ActionType) String() string

type ClusterSpec 

type ClusterSpec struct {
	NumNodes int32     `protobuf:"varint,1,opt,name=num_nodes,json=numNodes,proto3" json:"num_nodes,omitempty"`
	Node     *NodeSpec `protobuf:"bytes,2,opt,name=node,proto3" json:"node,omitempty"`
}

func (*ClusterSpec) Descriptor 

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

func (*ClusterSpec) Equal 

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

func (*ClusterSpec) GetNode 

func (m *ClusterSpec) GetNode() *NodeSpec

func (*ClusterSpec) GetNumNodes 

func (m *ClusterSpec) GetNumNodes() int32

func (*ClusterSpec) GoString 

func (this *ClusterSpec) GoString() string

func (*ClusterSpec) Marshal 

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

func (*ClusterSpec) MarshalTo 

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

func (*ClusterSpec) MarshalToSizedBuffer 

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

func (*ClusterSpec) ProtoMessage 

func (*ClusterSpec) ProtoMessage()

func (*ClusterSpec) Reset 

func (m *ClusterSpec) Reset()

func (*ClusterSpec) Size 

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

func (*ClusterSpec) String 

func (this *ClusterSpec) String() string

func (*ClusterSpec) Unmarshal 

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

func (*ClusterSpec) XXX_DiscardUnknown 

func (m *ClusterSpec) XXX_DiscardUnknown()

func (*ClusterSpec) XXX_Marshal 

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

func (*ClusterSpec) XXX_Merge 

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

func (*ClusterSpec) XXX_Size 

func (m *ClusterSpec) XXX_Size() int

func (*ClusterSpec) XXX_Unmarshal 

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

type DataLossCounterOutput 

type DataLossCounterOutput struct {
	TimestampCol string          `protobuf:"bytes,1,opt,name=timestamp_col,json=timestampCol,proto3" json:"timestamp_col,omitempty"`
	MetricName   string          `protobuf:"bytes,2,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	SeqIDCol     string          `protobuf:"bytes,3,opt,name=seq_id_col,json=seqIdCol,proto3" json:"seq_id_col,omitempty"`
	OutputPeriod *types.Duration `protobuf:"bytes,4,opt,name=output_period,json=outputPeriod,proto3" json:"output_period,omitempty"`
}

func (*DataLossCounterOutput) Descriptor 

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

func (*DataLossCounterOutput) Equal 

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

func (*DataLossCounterOutput) GetMetricName 

func (m *DataLossCounterOutput) GetMetricName() string

func (*DataLossCounterOutput) GetOutputPeriod 

func (m *DataLossCounterOutput) GetOutputPeriod() *types.Duration

func (*DataLossCounterOutput) GetSeqIDCol 

func (m *DataLossCounterOutput) GetSeqIDCol() string

func (*DataLossCounterOutput) GetTimestampCol 

func (m *DataLossCounterOutput) GetTimestampCol() string

func (*DataLossCounterOutput) GoString 

func (this *DataLossCounterOutput) GoString() string

func (*DataLossCounterOutput) Marshal 

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

func (*DataLossCounterOutput) MarshalTo 

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

func (*DataLossCounterOutput) MarshalToSizedBuffer 

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

func (*DataLossCounterOutput) ProtoMessage 

func (*DataLossCounterOutput) ProtoMessage()

func (*DataLossCounterOutput) Reset 

func (m *DataLossCounterOutput) Reset()

func (*DataLossCounterOutput) Size 

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

func (*DataLossCounterOutput) String 

func (this *DataLossCounterOutput) String() string

func (*DataLossCounterOutput) Unmarshal 

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

func (*DataLossCounterOutput) XXX_DiscardUnknown 

func (m *DataLossCounterOutput) XXX_DiscardUnknown()

func (*DataLossCounterOutput) XXX_Marshal 

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

func (*DataLossCounterOutput) XXX_Merge 

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

func (*DataLossCounterOutput) XXX_Size 

func (m *DataLossCounterOutput) XXX_Size() int

func (*DataLossCounterOutput) XXX_Unmarshal 

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

type DeployStep 

type DeployStep struct {
	// Types that are valid to be assigned to DeployType:
	//
	//	*DeployStep_Prerendered
	//	*DeployStep_Skaffold
	//	*DeployStep_Px
	DeployType isDeployStep_DeployType `protobuf_oneof:"deploy_type"`
}

func (*DeployStep) Descriptor 

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

func (*DeployStep) Equal 

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

func (*DeployStep) GetDeployType 

func (m *DeployStep) GetDeployType() isDeployStep_DeployType

func (*DeployStep) GetPrerendered 

func (m *DeployStep) GetPrerendered() *PrerenderedDeploy

func (*DeployStep) GetPx 

func (m *DeployStep) GetPx() *PxCLIDeploy

func (*DeployStep) GetSkaffold 

func (m *DeployStep) GetSkaffold() *SkaffoldDeploy

func (*DeployStep) GoString 

func (this *DeployStep) GoString() string

func (*DeployStep) Marshal 

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

func (*DeployStep) MarshalTo 

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

func (*DeployStep) MarshalToSizedBuffer 

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

func (*DeployStep) ProtoMessage 

func (*DeployStep) ProtoMessage()

func (*DeployStep) Reset 

func (m *DeployStep) Reset()

func (*DeployStep) Size 

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

func (*DeployStep) String 

func (this *DeployStep) String() string

func (*DeployStep) Unmarshal 

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

func (*DeployStep) XXX_DiscardUnknown 

func (m *DeployStep) XXX_DiscardUnknown()

func (*DeployStep) XXX_Marshal 

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

func (*DeployStep) XXX_Merge 

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

func (*DeployStep) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*DeployStep) XXX_Size 

func (m *DeployStep) XXX_Size() int

func (*DeployStep) XXX_Unmarshal 

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

type DeployStep_Prerendered 

type DeployStep_Prerendered struct {
	Prerendered *PrerenderedDeploy `protobuf:"bytes,1,opt,name=prerendered,proto3,oneof" json:"prerendered,omitempty"`
}

func (*DeployStep_Prerendered) Equal 

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

func (*DeployStep_Prerendered) GoString 

func (this *DeployStep_Prerendered) GoString() string

func (*DeployStep_Prerendered) MarshalTo 

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

func (*DeployStep_Prerendered) MarshalToSizedBuffer 

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

func (*DeployStep_Prerendered) Size 

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

func (*DeployStep_Prerendered) String 

func (this *DeployStep_Prerendered) String() string

type DeployStep_Px 

type DeployStep_Px struct {
	Px *PxCLIDeploy `protobuf:"bytes,3,opt,name=px,proto3,oneof" json:"px,omitempty"`
}

func (*DeployStep_Px) Equal 

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

func (*DeployStep_Px) GoString 

func (this *DeployStep_Px) GoString() string

func (*DeployStep_Px) MarshalTo 

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

func (*DeployStep_Px) MarshalToSizedBuffer 

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

func (*DeployStep_Px) Size 

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

func (*DeployStep_Px) String 

func (this *DeployStep_Px) String() string

type DeployStep_Skaffold 

type DeployStep_Skaffold struct {
	Skaffold *SkaffoldDeploy `protobuf:"bytes,2,opt,name=skaffold,proto3,oneof" json:"skaffold,omitempty"`
}

func (*DeployStep_Skaffold) Equal 

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

func (*DeployStep_Skaffold) GoString 

func (this *DeployStep_Skaffold) GoString() string

func (*DeployStep_Skaffold) MarshalTo 

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

func (*DeployStep_Skaffold) MarshalToSizedBuffer 

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

func (*DeployStep_Skaffold) Size 

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

func (*DeployStep_Skaffold) String 

func (this *DeployStep_Skaffold) String() string

type ExperimentSpec 

type ExperimentSpec struct {
	VizierSpec    *WorkloadSpec   `protobuf:"bytes,1,opt,name=vizier_spec,json=vizierSpec,proto3" json:"vizier_spec,omitempty"`
	WorkloadSpecs []*WorkloadSpec `protobuf:"bytes,2,rep,name=workload_specs,json=workloadSpecs,proto3" json:"workload_specs,omitempty"`
	MetricSpecs   []*MetricSpec   `protobuf:"bytes,3,rep,name=metric_specs,json=metricSpecs,proto3" json:"metric_specs,omitempty"`
	ClusterSpec   *ClusterSpec    `protobuf:"bytes,4,opt,name=cluster_spec,json=clusterSpec,proto3" json:"cluster_spec,omitempty"`
	RunSpec       *RunSpec        `protobuf:"bytes,5,opt,name=run_spec,json=runSpec,proto3" json:"run_spec,omitempty"`
	CommitSHA     string          `protobuf:"bytes,6,opt,name=commit_sha,json=commitSha,proto3" json:"commit_sha,omitempty"`
	Tags          []string        `protobuf:"bytes,7,rep,name=tags,proto3" json:"tags,omitempty"`
}

func (*ExperimentSpec) Descriptor 

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

func (*ExperimentSpec) Equal 

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

func (*ExperimentSpec) GetClusterSpec 

func (m *ExperimentSpec) GetClusterSpec() *ClusterSpec

func (*ExperimentSpec) GetCommitSHA 

func (m *ExperimentSpec) GetCommitSHA() string

func (*ExperimentSpec) GetMetricSpecs 

func (m *ExperimentSpec) GetMetricSpecs() []*MetricSpec

func (*ExperimentSpec) GetRunSpec 

func (m *ExperimentSpec) GetRunSpec() *RunSpec

func (*ExperimentSpec) GetTags 

func (m *ExperimentSpec) GetTags() []string

func (*ExperimentSpec) GetVizierSpec 

func (m *ExperimentSpec) GetVizierSpec() *WorkloadSpec

func (*ExperimentSpec) GetWorkloadSpecs 

func (m *ExperimentSpec) GetWorkloadSpecs() []*WorkloadSpec

func (*ExperimentSpec) GoString 

func (this *ExperimentSpec) GoString() string

func (*ExperimentSpec) Marshal 

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

func (*ExperimentSpec) MarshalTo 

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

func (*ExperimentSpec) MarshalToSizedBuffer 

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

func (*ExperimentSpec) ProtoMessage 

func (*ExperimentSpec) ProtoMessage()

func (*ExperimentSpec) Reset 

func (m *ExperimentSpec) Reset()

func (*ExperimentSpec) Size 

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

func (*ExperimentSpec) String 

func (this *ExperimentSpec) String() string

func (*ExperimentSpec) Unmarshal 

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

func (*ExperimentSpec) XXX_DiscardUnknown 

func (m *ExperimentSpec) XXX_DiscardUnknown()

func (*ExperimentSpec) XXX_Marshal 

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

func (*ExperimentSpec) XXX_Merge 

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

func (*ExperimentSpec) XXX_Size 

func (m *ExperimentSpec) XXX_Size() int

func (*ExperimentSpec) XXX_Unmarshal 

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

type HealthCheck 

type HealthCheck struct {
	// Types that are valid to be assigned to CheckType:
	//
	//	*HealthCheck_K8S
	//	*HealthCheck_PxL
	CheckType isHealthCheck_CheckType `protobuf_oneof:"check_type"`
}

func (*HealthCheck) Descriptor 

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

func (*HealthCheck) Equal 

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

func (*HealthCheck) GetCheckType 

func (m *HealthCheck) GetCheckType() isHealthCheck_CheckType

func (*HealthCheck) GetK8S 

func (m *HealthCheck) GetK8S() *K8SPodsReadyCheck

func (*HealthCheck) GetPxL 

func (m *HealthCheck) GetPxL() *PxLHealthCheck

func (*HealthCheck) GoString 

func (this *HealthCheck) GoString() string

func (*HealthCheck) Marshal 

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

func (*HealthCheck) MarshalTo 

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

func (*HealthCheck) MarshalToSizedBuffer 

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

func (*HealthCheck) ProtoMessage 

func (*HealthCheck) ProtoMessage()

func (*HealthCheck) Reset 

func (m *HealthCheck) Reset()

func (*HealthCheck) Size 

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

func (*HealthCheck) String 

func (this *HealthCheck) String() string

func (*HealthCheck) Unmarshal 

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

func (*HealthCheck) XXX_DiscardUnknown 

func (m *HealthCheck) XXX_DiscardUnknown()

func (*HealthCheck) XXX_Marshal 

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

func (*HealthCheck) XXX_Merge 

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

func (*HealthCheck) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*HealthCheck) XXX_Size 

func (m *HealthCheck) XXX_Size() int

func (*HealthCheck) XXX_Unmarshal 

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

type HealthCheck_K8S 

type HealthCheck_K8S struct {
	K8S *K8SPodsReadyCheck `protobuf:"bytes,1,opt,name=k8s,proto3,oneof" json:"k8s,omitempty"`
}

func (*HealthCheck_K8S) Equal 

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

func (*HealthCheck_K8S) GoString 

func (this *HealthCheck_K8S) GoString() string

func (*HealthCheck_K8S) MarshalTo 

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

func (*HealthCheck_K8S) MarshalToSizedBuffer 

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

func (*HealthCheck_K8S) Size 

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

func (*HealthCheck_K8S) String 

func (this *HealthCheck_K8S) String() string

type HealthCheck_PxL 

type HealthCheck_PxL struct {
	PxL *PxLHealthCheck `protobuf:"bytes,2,opt,name=pxl,proto3,oneof" json:"pxl,omitempty"`
}

func (*HealthCheck_PxL) Equal 

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

func (*HealthCheck_PxL) GoString 

func (this *HealthCheck_PxL) GoString() string

func (*HealthCheck_PxL) MarshalTo 

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

func (*HealthCheck_PxL) MarshalToSizedBuffer 

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

func (*HealthCheck_PxL) Size 

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

func (*HealthCheck_PxL) String 

func (this *HealthCheck_PxL) String() string

type K8SPodsReadyCheck 

type K8SPodsReadyCheck struct {
	Namespace string `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
}

func (*K8SPodsReadyCheck) Descriptor 

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

func (*K8SPodsReadyCheck) Equal 

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

func (*K8SPodsReadyCheck) GetNamespace 

func (m *K8SPodsReadyCheck) GetNamespace() string

func (*K8SPodsReadyCheck) GoString 

func (this *K8SPodsReadyCheck) GoString() string

func (*K8SPodsReadyCheck) Marshal 

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

func (*K8SPodsReadyCheck) MarshalTo 

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

func (*K8SPodsReadyCheck) MarshalToSizedBuffer 

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

func (*K8SPodsReadyCheck) ProtoMessage 

func (*K8SPodsReadyCheck) ProtoMessage()

func (*K8SPodsReadyCheck) Reset 

func (m *K8SPodsReadyCheck) Reset()

func (*K8SPodsReadyCheck) Size 

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

func (*K8SPodsReadyCheck) String 

func (this *K8SPodsReadyCheck) String() string

func (*K8SPodsReadyCheck) Unmarshal 

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

func (*K8SPodsReadyCheck) XXX_DiscardUnknown 

func (m *K8SPodsReadyCheck) XXX_DiscardUnknown()

func (*K8SPodsReadyCheck) XXX_Marshal 

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

func (*K8SPodsReadyCheck) XXX_Merge 

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

func (*K8SPodsReadyCheck) XXX_Size 

func (m *K8SPodsReadyCheck) XXX_Size() int

func (*K8SPodsReadyCheck) XXX_Unmarshal 

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

type MetricSpec 

type MetricSpec struct {
	// Types that are valid to be assigned to MetricType:
	//
	//	*MetricSpec_PxL
	//	*MetricSpec_Prom
	MetricType     isMetricSpec_MetricType `protobuf_oneof:"metric_type"`
	ActionSelector string                  `protobuf:"bytes,100,opt,name=action_selector,json=actionSelector,proto3" json:"action_selector,omitempty"`
}

func (*MetricSpec) Descriptor 

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

func (*MetricSpec) Equal 

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

func (*MetricSpec) GetActionSelector 

func (m *MetricSpec) GetActionSelector() string

func (*MetricSpec) GetMetricType 

func (m *MetricSpec) GetMetricType() isMetricSpec_MetricType

func (*MetricSpec) GetProm 

func (m *MetricSpec) GetProm() *PrometheusScrapeSpec

func (*MetricSpec) GetPxL 

func (m *MetricSpec) GetPxL() *PxLScriptSpec

func (*MetricSpec) GoString 

func (this *MetricSpec) GoString() string

func (*MetricSpec) Marshal 

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

func (*MetricSpec) MarshalTo 

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

func (*MetricSpec) MarshalToSizedBuffer 

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

func (*MetricSpec) ProtoMessage 

func (*MetricSpec) ProtoMessage()

func (*MetricSpec) Reset 

func (m *MetricSpec) Reset()

func (*MetricSpec) Size 

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

func (*MetricSpec) String 

func (this *MetricSpec) String() string

func (*MetricSpec) Unmarshal 

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

func (*MetricSpec) XXX_DiscardUnknown 

func (m *MetricSpec) XXX_DiscardUnknown()

func (*MetricSpec) XXX_Marshal 

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

func (*MetricSpec) XXX_Merge 

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

func (*MetricSpec) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*MetricSpec) XXX_Size 

func (m *MetricSpec) XXX_Size() int

func (*MetricSpec) XXX_Unmarshal 

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

type MetricSpec_Prom 

type MetricSpec_Prom struct {
	Prom *PrometheusScrapeSpec `protobuf:"bytes,2,opt,name=prom,proto3,oneof" json:"prom,omitempty"`
}

func (*MetricSpec_Prom) Equal 

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

func (*MetricSpec_Prom) GoString 

func (this *MetricSpec_Prom) GoString() string

func (*MetricSpec_Prom) MarshalTo 

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

func (*MetricSpec_Prom) MarshalToSizedBuffer 

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

func (*MetricSpec_Prom) Size 

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

func (*MetricSpec_Prom) String 

func (this *MetricSpec_Prom) String() string

type MetricSpec_PxL 

type MetricSpec_PxL struct {
	PxL *PxLScriptSpec `protobuf:"bytes,1,opt,name=pxl,proto3,oneof" json:"pxl,omitempty"`
}

func (*MetricSpec_PxL) Equal 

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

func (*MetricSpec_PxL) GoString 

func (this *MetricSpec_PxL) GoString() string

func (*MetricSpec_PxL) MarshalTo 

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

func (*MetricSpec_PxL) MarshalToSizedBuffer 

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

func (*MetricSpec_PxL) Size 

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

func (*MetricSpec_PxL) String 

func (this *MetricSpec_PxL) String() string

type NodeSpec 

type NodeSpec struct {
	MachineType string `protobuf:"bytes,1,opt,name=machine_type,json=machineType,proto3" json:"machine_type,omitempty"`
}

func (*NodeSpec) Descriptor 

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

func (*NodeSpec) Equal 

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

func (*NodeSpec) GetMachineType 

func (m *NodeSpec) GetMachineType() string

func (*NodeSpec) GoString 

func (this *NodeSpec) GoString() string

func (*NodeSpec) Marshal 

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

func (*NodeSpec) MarshalTo 

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

func (*NodeSpec) MarshalToSizedBuffer 

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

func (*NodeSpec) ProtoMessage 

func (*NodeSpec) ProtoMessage()

func (*NodeSpec) Reset 

func (m *NodeSpec) Reset()

func (*NodeSpec) Size 

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

func (*NodeSpec) String 

func (this *NodeSpec) String() string

func (*NodeSpec) Unmarshal 

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

func (*NodeSpec) XXX_DiscardUnknown 

func (m *NodeSpec) XXX_DiscardUnknown()

func (*NodeSpec) XXX_Marshal 

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

func (*NodeSpec) XXX_Merge 

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

func (*NodeSpec) XXX_Size 

func (m *NodeSpec) XXX_Size() int

func (*NodeSpec) XXX_Unmarshal 

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

type PatchSpec 

type PatchSpec struct {
	YAML   string       `protobuf:"bytes,1,opt,name=yaml,proto3" json:"yaml,omitempty"`
	Target *PatchTarget `protobuf:"bytes,2,opt,name=target,proto3" json:"target,omitempty"`
}

func (*PatchSpec) Descriptor 

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

func (*PatchSpec) Equal 

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

func (*PatchSpec) GetTarget 

func (m *PatchSpec) GetTarget() *PatchTarget

func (*PatchSpec) GetYAML 

func (m *PatchSpec) GetYAML() string

func (*PatchSpec) GoString 

func (this *PatchSpec) GoString() string

func (*PatchSpec) Marshal 

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

func (*PatchSpec) MarshalTo 

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

func (*PatchSpec) MarshalToSizedBuffer 

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

func (*PatchSpec) ProtoMessage 

func (*PatchSpec) ProtoMessage()

func (*PatchSpec) Reset 

func (m *PatchSpec) Reset()

func (*PatchSpec) Size 

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

func (*PatchSpec) String 

func (this *PatchSpec) String() string

func (*PatchSpec) Unmarshal 

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

func (*PatchSpec) XXX_DiscardUnknown 

func (m *PatchSpec) XXX_DiscardUnknown()

func (*PatchSpec) XXX_Marshal 

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

func (*PatchSpec) XXX_Merge 

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

func (*PatchSpec) XXX_Size 

func (m *PatchSpec) XXX_Size() int

func (*PatchSpec) XXX_Unmarshal 

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

type PatchTarget 

type PatchTarget struct {
	APIGroup           string `protobuf:"bytes,1,opt,name=api_group,json=apiGroup,proto3" json:"api_group,omitempty"`
	APIVersion         string `protobuf:"bytes,2,opt,name=api_version,json=apiVersion,proto3" json:"api_version,omitempty"`
	Kind               string `protobuf:"bytes,3,opt,name=kind,proto3" json:"kind,omitempty"`
	Name               string `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	Namespace          string `protobuf:"bytes,5,opt,name=namespace,proto3" json:"namespace,omitempty"`
	LabelSelector      string `protobuf:"bytes,6,opt,name=label_selector,json=labelSelector,proto3" json:"label_selector,omitempty"`
	AnnotationSelector string `protobuf:"bytes,7,opt,name=annotation_selector,json=annotationSelector,proto3" json:"annotation_selector,omitempty"`
}

func (*PatchTarget) Descriptor 

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

func (*PatchTarget) Equal 

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

func (*PatchTarget) GetAPIGroup 

func (m *PatchTarget) GetAPIGroup() string

func (*PatchTarget) GetAPIVersion 

func (m *PatchTarget) GetAPIVersion() string

func (*PatchTarget) GetAnnotationSelector 

func (m *PatchTarget) GetAnnotationSelector() string

func (*PatchTarget) GetKind 

func (m *PatchTarget) GetKind() string

func (*PatchTarget) GetLabelSelector 

func (m *PatchTarget) GetLabelSelector() string

func (*PatchTarget) GetName 

func (m *PatchTarget) GetName() string

func (*PatchTarget) GetNamespace 

func (m *PatchTarget) GetNamespace() string

func (*PatchTarget) GoString 

func (this *PatchTarget) GoString() string

func (*PatchTarget) Marshal 

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

func (*PatchTarget) MarshalTo 

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

func (*PatchTarget) MarshalToSizedBuffer 

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

func (*PatchTarget) ProtoMessage 

func (*PatchTarget) ProtoMessage()

func (*PatchTarget) Reset 

func (m *PatchTarget) Reset()

func (*PatchTarget) Size 

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

func (*PatchTarget) String 

func (this *PatchTarget) String() string

func (*PatchTarget) Unmarshal 

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

func (*PatchTarget) XXX_DiscardUnknown 

func (m *PatchTarget) XXX_DiscardUnknown()

func (*PatchTarget) XXX_Marshal 

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

func (*PatchTarget) XXX_Merge 

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

func (*PatchTarget) XXX_Size 

func (m *PatchTarget) XXX_Size() int

func (*PatchTarget) XXX_Unmarshal 

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

type PrerenderedDeploy 

type PrerenderedDeploy struct {
	YAMLPaths []string     `protobuf:"bytes,1,rep,name=yaml_paths,json=yamlPaths,proto3" json:"yaml_paths,omitempty"`
	Patches   []*PatchSpec `protobuf:"bytes,2,rep,name=patches,proto3" json:"patches,omitempty"`
}

func (*PrerenderedDeploy) Descriptor 

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

func (*PrerenderedDeploy) Equal 

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

func (*PrerenderedDeploy) GetPatches 

func (m *PrerenderedDeploy) GetPatches() []*PatchSpec

func (*PrerenderedDeploy) GetYAMLPaths 

func (m *PrerenderedDeploy) GetYAMLPaths() []string

func (*PrerenderedDeploy) GoString 

func (this *PrerenderedDeploy) GoString() string

func (*PrerenderedDeploy) Marshal 

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

func (*PrerenderedDeploy) MarshalTo 

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

func (*PrerenderedDeploy) MarshalToSizedBuffer 

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

func (*PrerenderedDeploy) ProtoMessage 

func (*PrerenderedDeploy) ProtoMessage()

func (*PrerenderedDeploy) Reset 

func (m *PrerenderedDeploy) Reset()

func (*PrerenderedDeploy) Size 

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

func (*PrerenderedDeploy) String 

func (this *PrerenderedDeploy) String() string

func (*PrerenderedDeploy) Unmarshal 

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

func (*PrerenderedDeploy) XXX_DiscardUnknown 

func (m *PrerenderedDeploy) XXX_DiscardUnknown()

func (*PrerenderedDeploy) XXX_Marshal 

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

func (*PrerenderedDeploy) XXX_Merge 

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

func (*PrerenderedDeploy) XXX_Size 

func (m *PrerenderedDeploy) XXX_Size() int

func (*PrerenderedDeploy) XXX_Unmarshal 

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

type PrometheusScrapeSpec 

type PrometheusScrapeSpec struct {
	Namespace       string            `protobuf:"bytes,1,opt,name=namespace,proto3" json:"namespace,omitempty"`
	MatchLabelKey   string            `protobuf:"bytes,2,opt,name=match_label_key,json=matchLabelKey,proto3" json:"match_label_key,omitempty"`
	MatchLabelValue string            `protobuf:"bytes,3,opt,name=match_label_value,json=matchLabelValue,proto3" json:"match_label_value,omitempty"`
	Port            int32             `protobuf:"varint,4,opt,name=port,proto3" json:"port,omitempty"`
	ScrapePeriod    *types.Duration   `protobuf:"bytes,5,opt,name=scrape_period,json=scrapePeriod,proto3" json:"scrape_period,omitempty"`
	MetricNames     map[string]string `` /* 182-byte string literal not displayed */
}

func (*PrometheusScrapeSpec) Descriptor 

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

func (*PrometheusScrapeSpec) Equal 

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

func (*PrometheusScrapeSpec) GetMatchLabelKey 

func (m *PrometheusScrapeSpec) GetMatchLabelKey() string

func (*PrometheusScrapeSpec) GetMatchLabelValue 

func (m *PrometheusScrapeSpec) GetMatchLabelValue() string

func (*PrometheusScrapeSpec) GetMetricNames 

func (m *PrometheusScrapeSpec) GetMetricNames() map[string]string

func (*PrometheusScrapeSpec) GetNamespace 

func (m *PrometheusScrapeSpec) GetNamespace() string

func (*PrometheusScrapeSpec) GetPort 

func (m *PrometheusScrapeSpec) GetPort() int32

func (*PrometheusScrapeSpec) GetScrapePeriod 

func (m *PrometheusScrapeSpec) GetScrapePeriod() *types.Duration

func (*PrometheusScrapeSpec) GoString 

func (this *PrometheusScrapeSpec) GoString() string

func (*PrometheusScrapeSpec) Marshal 

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

func (*PrometheusScrapeSpec) MarshalTo 

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

func (*PrometheusScrapeSpec) MarshalToSizedBuffer 

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

func (*PrometheusScrapeSpec) ProtoMessage 

func (*PrometheusScrapeSpec) ProtoMessage()

func (*PrometheusScrapeSpec) Reset 

func (m *PrometheusScrapeSpec) Reset()

func (*PrometheusScrapeSpec) Size 

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

func (*PrometheusScrapeSpec) String 

func (this *PrometheusScrapeSpec) String() string

func (*PrometheusScrapeSpec) Unmarshal 

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

func (*PrometheusScrapeSpec) XXX_DiscardUnknown 

func (m *PrometheusScrapeSpec) XXX_DiscardUnknown()

func (*PrometheusScrapeSpec) XXX_Marshal 

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

func (*PrometheusScrapeSpec) XXX_Merge 

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

func (*PrometheusScrapeSpec) XXX_Size 

func (m *PrometheusScrapeSpec) XXX_Size() int

func (*PrometheusScrapeSpec) XXX_Unmarshal 

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

type PxCLIDeploy 

type PxCLIDeploy struct {
	Args         []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
	Namespaces   []string `protobuf:"bytes,2,rep,name=namespaces,proto3" json:"namespaces,omitempty"`
	SetClusterID bool     `protobuf:"varint,3,opt,name=set_cluster_id,json=setClusterId,proto3" json:"set_cluster_id,omitempty"`
}

func (*PxCLIDeploy) Descriptor 

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

func (*PxCLIDeploy) Equal 

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

func (*PxCLIDeploy) GetArgs 

func (m *PxCLIDeploy) GetArgs() []string

func (*PxCLIDeploy) GetNamespaces 

func (m *PxCLIDeploy) GetNamespaces() []string

func (*PxCLIDeploy) GetSetClusterID 

func (m *PxCLIDeploy) GetSetClusterID() bool

func (*PxCLIDeploy) GoString 

func (this *PxCLIDeploy) GoString() string

func (*PxCLIDeploy) Marshal 

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

func (*PxCLIDeploy) MarshalTo 

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

func (*PxCLIDeploy) MarshalToSizedBuffer 

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

func (*PxCLIDeploy) ProtoMessage 

func (*PxCLIDeploy) ProtoMessage()

func (*PxCLIDeploy) Reset 

func (m *PxCLIDeploy) Reset()

func (*PxCLIDeploy) Size 

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

func (*PxCLIDeploy) String 

func (this *PxCLIDeploy) String() string

func (*PxCLIDeploy) Unmarshal 

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

func (*PxCLIDeploy) XXX_DiscardUnknown 

func (m *PxCLIDeploy) XXX_DiscardUnknown()

func (*PxCLIDeploy) XXX_Marshal 

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

func (*PxCLIDeploy) XXX_Merge 

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

func (*PxCLIDeploy) XXX_Size 

func (m *PxCLIDeploy) XXX_Size() int

func (*PxCLIDeploy) XXX_Unmarshal 

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

type PxLHealthCheck 

type PxLHealthCheck struct {
	Script        string `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
	SuccessColumn string `protobuf:"bytes,2,opt,name=success_column,json=successColumn,proto3" json:"success_column,omitempty"`
}

func (*PxLHealthCheck) Descriptor 

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

func (*PxLHealthCheck) Equal 

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

func (*PxLHealthCheck) GetScript 

func (m *PxLHealthCheck) GetScript() string

func (*PxLHealthCheck) GetSuccessColumn 

func (m *PxLHealthCheck) GetSuccessColumn() string

func (*PxLHealthCheck) GoString 

func (this *PxLHealthCheck) GoString() string

func (*PxLHealthCheck) Marshal 

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

func (*PxLHealthCheck) MarshalTo 

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

func (*PxLHealthCheck) MarshalToSizedBuffer 

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

func (*PxLHealthCheck) ProtoMessage 

func (*PxLHealthCheck) ProtoMessage()

func (*PxLHealthCheck) Reset 

func (m *PxLHealthCheck) Reset()

func (*PxLHealthCheck) Size 

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

func (*PxLHealthCheck) String 

func (this *PxLHealthCheck) String() string

func (*PxLHealthCheck) Unmarshal 

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

func (*PxLHealthCheck) XXX_DiscardUnknown 

func (m *PxLHealthCheck) XXX_DiscardUnknown()

func (*PxLHealthCheck) XXX_Marshal 

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

func (*PxLHealthCheck) XXX_Merge 

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

func (*PxLHealthCheck) XXX_Size 

func (m *PxLHealthCheck) XXX_Size() int

func (*PxLHealthCheck) XXX_Unmarshal 

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

type PxLScriptOutputList 

type PxLScriptOutputList struct {
	Outputs []*PxLScriptOutputSpec `protobuf:"bytes,1,rep,name=outputs,proto3" json:"outputs,omitempty"`
}

func (*PxLScriptOutputList) Descriptor 

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

func (*PxLScriptOutputList) Equal 

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

func (*PxLScriptOutputList) GetOutputs 

func (m *PxLScriptOutputList) GetOutputs() []*PxLScriptOutputSpec

func (*PxLScriptOutputList) GoString 

func (this *PxLScriptOutputList) GoString() string

func (*PxLScriptOutputList) Marshal 

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

func (*PxLScriptOutputList) MarshalTo 

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

func (*PxLScriptOutputList) MarshalToSizedBuffer 

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

func (*PxLScriptOutputList) ProtoMessage 

func (*PxLScriptOutputList) ProtoMessage()

func (*PxLScriptOutputList) Reset 

func (m *PxLScriptOutputList) Reset()

func (*PxLScriptOutputList) Size 

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

func (*PxLScriptOutputList) String 

func (this *PxLScriptOutputList) String() string

func (*PxLScriptOutputList) Unmarshal 

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

func (*PxLScriptOutputList) XXX_DiscardUnknown 

func (m *PxLScriptOutputList) XXX_DiscardUnknown()

func (*PxLScriptOutputList) XXX_Marshal 

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

func (*PxLScriptOutputList) XXX_Merge 

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

func (*PxLScriptOutputList) XXX_Size 

func (m *PxLScriptOutputList) XXX_Size() int

func (*PxLScriptOutputList) XXX_Unmarshal 

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

type PxLScriptOutputSpec 

type PxLScriptOutputSpec struct {
	// Types that are valid to be assigned to OutputSpec:
	//
	//	*PxLScriptOutputSpec_SingleMetric
	//	*PxLScriptOutputSpec_DataLossCounter
	OutputSpec isPxLScriptOutputSpec_OutputSpec `protobuf_oneof:"output_spec"`
}

func (*PxLScriptOutputSpec) Descriptor 

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

func (*PxLScriptOutputSpec) Equal 

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

func (*PxLScriptOutputSpec) GetDataLossCounter 

func (m *PxLScriptOutputSpec) GetDataLossCounter() *DataLossCounterOutput

func (*PxLScriptOutputSpec) GetOutputSpec 

func (m *PxLScriptOutputSpec) GetOutputSpec() isPxLScriptOutputSpec_OutputSpec

func (*PxLScriptOutputSpec) GetSingleMetric 

func (m *PxLScriptOutputSpec) GetSingleMetric() *SingleMetricPxLOutput

func (*PxLScriptOutputSpec) GoString 

func (this *PxLScriptOutputSpec) GoString() string

func (*PxLScriptOutputSpec) Marshal 

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

func (*PxLScriptOutputSpec) MarshalTo 

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

func (*PxLScriptOutputSpec) MarshalToSizedBuffer 

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

func (*PxLScriptOutputSpec) ProtoMessage 

func (*PxLScriptOutputSpec) ProtoMessage()

func (*PxLScriptOutputSpec) Reset 

func (m *PxLScriptOutputSpec) Reset()

func (*PxLScriptOutputSpec) Size 

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

func (*PxLScriptOutputSpec) String 

func (this *PxLScriptOutputSpec) String() string

func (*PxLScriptOutputSpec) Unmarshal 

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

func (*PxLScriptOutputSpec) XXX_DiscardUnknown 

func (m *PxLScriptOutputSpec) XXX_DiscardUnknown()

func (*PxLScriptOutputSpec) XXX_Marshal 

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

func (*PxLScriptOutputSpec) XXX_Merge 

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

func (*PxLScriptOutputSpec) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*PxLScriptOutputSpec) XXX_Size 

func (m *PxLScriptOutputSpec) XXX_Size() int

func (*PxLScriptOutputSpec) XXX_Unmarshal 

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

type PxLScriptOutputSpec_DataLossCounter 

type PxLScriptOutputSpec_DataLossCounter struct {
	DataLossCounter *DataLossCounterOutput `protobuf:"bytes,2,opt,name=data_loss_counter,json=dataLossCounter,proto3,oneof" json:"data_loss_counter,omitempty"`
}

func (*PxLScriptOutputSpec_DataLossCounter) Equal 

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

func (*PxLScriptOutputSpec_DataLossCounter) GoString 

func (this *PxLScriptOutputSpec_DataLossCounter) GoString() string

func (*PxLScriptOutputSpec_DataLossCounter) MarshalTo 

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

func (*PxLScriptOutputSpec_DataLossCounter) MarshalToSizedBuffer 

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

func (*PxLScriptOutputSpec_DataLossCounter) Size 

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

func (*PxLScriptOutputSpec_DataLossCounter) String 

func (this *PxLScriptOutputSpec_DataLossCounter) String() string

type PxLScriptOutputSpec_SingleMetric 

type PxLScriptOutputSpec_SingleMetric struct {
	SingleMetric *SingleMetricPxLOutput `protobuf:"bytes,1,opt,name=single_metric,json=singleMetric,proto3,oneof" json:"single_metric,omitempty"`
}

func (*PxLScriptOutputSpec_SingleMetric) Equal 

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

func (*PxLScriptOutputSpec_SingleMetric) GoString 

func (this *PxLScriptOutputSpec_SingleMetric) GoString() string

func (*PxLScriptOutputSpec_SingleMetric) MarshalTo 

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

func (*PxLScriptOutputSpec_SingleMetric) MarshalToSizedBuffer 

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

func (*PxLScriptOutputSpec_SingleMetric) Size 

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

func (*PxLScriptOutputSpec_SingleMetric) String 

func (this *PxLScriptOutputSpec_SingleMetric) String() string

type PxLScriptSpec 

type PxLScriptSpec struct {
	Script           string                          `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
	Streaming        bool                            `protobuf:"varint,2,opt,name=streaming,proto3" json:"streaming,omitempty"`
	CollectionPeriod *types.Duration                 `protobuf:"bytes,3,opt,name=collection_period,json=collectionPeriod,proto3" json:"collection_period,omitempty"`
	TemplateValues   map[string]string               `` /* 191-byte string literal not displayed */
	TableOutputs     map[string]*PxLScriptOutputList `` /* 185-byte string literal not displayed */
}

func (*PxLScriptSpec) Descriptor 

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

func (*PxLScriptSpec) Equal 

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

func (*PxLScriptSpec) GetCollectionPeriod 

func (m *PxLScriptSpec) GetCollectionPeriod() *types.Duration

func (*PxLScriptSpec) GetScript 

func (m *PxLScriptSpec) GetScript() string

func (*PxLScriptSpec) GetStreaming 

func (m *PxLScriptSpec) GetStreaming() bool

func (*PxLScriptSpec) GetTableOutputs 

func (m *PxLScriptSpec) GetTableOutputs() map[string]*PxLScriptOutputList

func (*PxLScriptSpec) GetTemplateValues 

func (m *PxLScriptSpec) GetTemplateValues() map[string]string

func (*PxLScriptSpec) GoString 

func (this *PxLScriptSpec) GoString() string

func (*PxLScriptSpec) Marshal 

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

func (*PxLScriptSpec) MarshalTo 

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

func (*PxLScriptSpec) MarshalToSizedBuffer 

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

func (*PxLScriptSpec) ProtoMessage 

func (*PxLScriptSpec) ProtoMessage()

func (*PxLScriptSpec) Reset 

func (m *PxLScriptSpec) Reset()

func (*PxLScriptSpec) Size 

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

func (*PxLScriptSpec) String 

func (this *PxLScriptSpec) String() string

func (*PxLScriptSpec) Unmarshal 

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

func (*PxLScriptSpec) XXX_DiscardUnknown 

func (m *PxLScriptSpec) XXX_DiscardUnknown()

func (*PxLScriptSpec) XXX_Marshal 

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

func (*PxLScriptSpec) XXX_Merge 

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

func (*PxLScriptSpec) XXX_Size 

func (m *PxLScriptSpec) XXX_Size() int

func (*PxLScriptSpec) XXX_Unmarshal 

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

type RunSpec 

type RunSpec struct {
	Actions []*ActionSpec `protobuf:"bytes,3,rep,name=actions,proto3" json:"actions,omitempty"`
}

func (*RunSpec) Descriptor 

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

func (*RunSpec) Equal 

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

func (*RunSpec) GetActions 

func (m *RunSpec) GetActions() []*ActionSpec

func (*RunSpec) GoString 

func (this *RunSpec) GoString() string

func (*RunSpec) Marshal 

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

func (*RunSpec) MarshalTo 

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

func (*RunSpec) MarshalToSizedBuffer 

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

func (*RunSpec) ProtoMessage 

func (*RunSpec) ProtoMessage()

func (*RunSpec) Reset 

func (m *RunSpec) Reset()

func (*RunSpec) Size 

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

func (*RunSpec) String 

func (this *RunSpec) String() string

func (*RunSpec) Unmarshal 

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

func (*RunSpec) XXX_DiscardUnknown 

func (m *RunSpec) XXX_DiscardUnknown()

func (*RunSpec) XXX_Marshal 

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

func (*RunSpec) XXX_Merge 

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

func (*RunSpec) XXX_Size 

func (m *RunSpec) XXX_Size() int

func (*RunSpec) XXX_Unmarshal 

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

type SingleMetricPxLOutput 

type SingleMetricPxLOutput struct {
	TimestampCol string   `protobuf:"bytes,1,opt,name=timestamp_col,json=timestampCol,proto3" json:"timestamp_col,omitempty"`
	MetricName   string   `protobuf:"bytes,2,opt,name=metric_name,json=metricName,proto3" json:"metric_name,omitempty"`
	ValueCol     string   `protobuf:"bytes,3,opt,name=value_col,json=valueCol,proto3" json:"value_col,omitempty"`
	TagCols      []string `protobuf:"bytes,4,rep,name=tag_cols,json=tagCols,proto3" json:"tag_cols,omitempty"`
}

func (*SingleMetricPxLOutput) Descriptor 

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

func (*SingleMetricPxLOutput) Equal 

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

func (*SingleMetricPxLOutput) GetMetricName 

func (m *SingleMetricPxLOutput) GetMetricName() string

func (*SingleMetricPxLOutput) GetTagCols 

func (m *SingleMetricPxLOutput) GetTagCols() []string

func (*SingleMetricPxLOutput) GetTimestampCol 

func (m *SingleMetricPxLOutput) GetTimestampCol() string

func (*SingleMetricPxLOutput) GetValueCol 

func (m *SingleMetricPxLOutput) GetValueCol() string

func (*SingleMetricPxLOutput) GoString 

func (this *SingleMetricPxLOutput) GoString() string

func (*SingleMetricPxLOutput) Marshal 

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

func (*SingleMetricPxLOutput) MarshalTo 

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

func (*SingleMetricPxLOutput) MarshalToSizedBuffer 

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

func (*SingleMetricPxLOutput) ProtoMessage 

func (*SingleMetricPxLOutput) ProtoMessage()

func (*SingleMetricPxLOutput) Reset 

func (m *SingleMetricPxLOutput) Reset()

func (*SingleMetricPxLOutput) Size 

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

func (*SingleMetricPxLOutput) String 

func (this *SingleMetricPxLOutput) String() string

func (*SingleMetricPxLOutput) Unmarshal 

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

func (*SingleMetricPxLOutput) XXX_DiscardUnknown 

func (m *SingleMetricPxLOutput) XXX_DiscardUnknown()

func (*SingleMetricPxLOutput) XXX_Marshal 

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

func (*SingleMetricPxLOutput) XXX_Merge 

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

func (*SingleMetricPxLOutput) XXX_Size 

func (m *SingleMetricPxLOutput) XXX_Size() int

func (*SingleMetricPxLOutput) XXX_Unmarshal 

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

type SkaffoldDeploy 

type SkaffoldDeploy struct {
	SkaffoldPath string       `protobuf:"bytes,1,opt,name=skaffold_path,json=skaffoldPath,proto3" json:"skaffold_path,omitempty"`
	SkaffoldArgs []string     `protobuf:"bytes,2,rep,name=skaffold_args,json=skaffoldArgs,proto3" json:"skaffold_args,omitempty"`
	Patches      []*PatchSpec `protobuf:"bytes,3,rep,name=patches,proto3" json:"patches,omitempty"`
}

func (*SkaffoldDeploy) Descriptor 

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

func (*SkaffoldDeploy) Equal 

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

func (*SkaffoldDeploy) GetPatches 

func (m *SkaffoldDeploy) GetPatches() []*PatchSpec

func (*SkaffoldDeploy) GetSkaffoldArgs 

func (m *SkaffoldDeploy) GetSkaffoldArgs() []string

func (*SkaffoldDeploy) GetSkaffoldPath 

func (m *SkaffoldDeploy) GetSkaffoldPath() string

func (*SkaffoldDeploy) GoString 

func (this *SkaffoldDeploy) GoString() string

func (*SkaffoldDeploy) Marshal 

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

func (*SkaffoldDeploy) MarshalTo 

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

func (*SkaffoldDeploy) MarshalToSizedBuffer 

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

func (*SkaffoldDeploy) ProtoMessage 

func (*SkaffoldDeploy) ProtoMessage()

func (*SkaffoldDeploy) Reset 

func (m *SkaffoldDeploy) Reset()

func (*SkaffoldDeploy) Size 

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

func (*SkaffoldDeploy) String 

func (this *SkaffoldDeploy) String() string

func (*SkaffoldDeploy) Unmarshal 

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

func (*SkaffoldDeploy) XXX_DiscardUnknown 

func (m *SkaffoldDeploy) XXX_DiscardUnknown()

func (*SkaffoldDeploy) XXX_Marshal 

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

func (*SkaffoldDeploy) XXX_Merge 

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

func (*SkaffoldDeploy) XXX_Size 

func (m *SkaffoldDeploy) XXX_Size() int

func (*SkaffoldDeploy) XXX_Unmarshal 

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

type WorkloadSpec 

type WorkloadSpec struct {
	Name           string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	DeploySteps    []*DeployStep  `protobuf:"bytes,2,rep,name=deploy_steps,json=deploySteps,proto3" json:"deploy_steps,omitempty"`
	Healthchecks   []*HealthCheck `protobuf:"bytes,3,rep,name=healthchecks,proto3" json:"healthchecks,omitempty"`
	ActionSelector string         `protobuf:"bytes,4,opt,name=action_selector,json=actionSelector,proto3" json:"action_selector,omitempty"`
}

func (*WorkloadSpec) Descriptor 

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

func (*WorkloadSpec) Equal 

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

func (*WorkloadSpec) GetActionSelector 

func (m *WorkloadSpec) GetActionSelector() string

func (*WorkloadSpec) GetDeploySteps 

func (m *WorkloadSpec) GetDeploySteps() []*DeployStep

func (*WorkloadSpec) GetHealthchecks 

func (m *WorkloadSpec) GetHealthchecks() []*HealthCheck

func (*WorkloadSpec) GetName 

func (m *WorkloadSpec) GetName() string

func (*WorkloadSpec) GoString 

func (this *WorkloadSpec) GoString() string

func (*WorkloadSpec) Marshal 

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

func (*WorkloadSpec) MarshalTo 

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

func (*WorkloadSpec) MarshalToSizedBuffer 

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

func (*WorkloadSpec) ProtoMessage 

func (*WorkloadSpec) ProtoMessage()

func (*WorkloadSpec) Reset 

func (m *WorkloadSpec) Reset()

func (*WorkloadSpec) Size 

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

func (*WorkloadSpec) String 

func (this *WorkloadSpec) String() string

func (*WorkloadSpec) Unmarshal 

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

func (*WorkloadSpec) XXX_DiscardUnknown 

func (m *WorkloadSpec) XXX_DiscardUnknown()

func (*WorkloadSpec) XXX_Marshal 

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

func (*WorkloadSpec) XXX_Merge 

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

func (*WorkloadSpec) XXX_Size 

func (m *WorkloadSpec) XXX_Size() int

func (*WorkloadSpec) XXX_Unmarshal 

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