cvmsgspb

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

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthCvmsgs        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowCvmsgs          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupCvmsgs = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var RegisterVizierAck_RegistrationStatus_name = map[int32]string{
	0: "ST_UNKNOWN",
	1: "ST_OK",
	2: "ST_FAILED_NOT_FOUND",
}
View Source 
var RegisterVizierAck_RegistrationStatus_value = map[string]int32{
	"ST_UNKNOWN":          0,
	"ST_OK":               1,
	"ST_FAILED_NOT_FOUND": 2,
}
View Source 
var VizierHeartbeatAck_HeartbeatStatus_name = map[int32]string{
	0: "HB_UNKNOWN",
	1: "HB_OK",
	2: "HB_ERROR",
}
View Source 
var VizierHeartbeatAck_HeartbeatStatus_value = map[string]int32{
	"HB_UNKNOWN": 0,
	"HB_OK":      1,
	"HB_ERROR":   2,
}
View Source 
var VizierStatus_name = map[int32]string{
	0: "VZ_ST_UNKNOWN",
	1: "VZ_ST_HEALTHY",
	2: "VZ_ST_UNHEALTHY",
	3: "VZ_ST_DISCONNECTED",
	4: "VZ_ST_UPDATING",
	5: "VZ_ST_CONNECTED",
	6: "VZ_ST_UPDATE_FAILED",
	7: "VZ_ST_DEGRADED",
}
View Source 
var VizierStatus_value = map[string]int32{
	"VZ_ST_UNKNOWN":       0,
	"VZ_ST_HEALTHY":       1,
	"VZ_ST_UNHEALTHY":     2,
	"VZ_ST_DISCONNECTED":  3,
	"VZ_ST_UPDATING":      4,
	"VZ_ST_CONNECTED":     5,
	"VZ_ST_UPDATE_FAILED": 6,
	"VZ_ST_DEGRADED":      7,
}

Functions

This section is empty.

Types

type C2VAPIStreamCancel 

type C2VAPIStreamCancel struct {
}

func (*C2VAPIStreamCancel) Descriptor 

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

func (*C2VAPIStreamCancel) Equal 

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

func (*C2VAPIStreamCancel) GoString 

func (this *C2VAPIStreamCancel) GoString() string

func (*C2VAPIStreamCancel) Marshal 

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

func (*C2VAPIStreamCancel) MarshalTo 

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

func (*C2VAPIStreamCancel) MarshalToSizedBuffer 

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

func (*C2VAPIStreamCancel) ProtoMessage 

func (*C2VAPIStreamCancel) ProtoMessage()

func (*C2VAPIStreamCancel) Reset 

func (m *C2VAPIStreamCancel) Reset()

func (*C2VAPIStreamCancel) Size 

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

func (*C2VAPIStreamCancel) String 

func (this *C2VAPIStreamCancel) String() string

func (*C2VAPIStreamCancel) Unmarshal 

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

func (*C2VAPIStreamCancel) XXX_DiscardUnknown 

func (m *C2VAPIStreamCancel) XXX_DiscardUnknown()

func (*C2VAPIStreamCancel) XXX_Marshal 

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

func (*C2VAPIStreamCancel) XXX_Merge 

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

func (*C2VAPIStreamCancel) XXX_Size 

func (m *C2VAPIStreamCancel) XXX_Size() int

func (*C2VAPIStreamCancel) XXX_Unmarshal 

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

type C2VAPIStreamRequest 

type C2VAPIStreamRequest struct {
	RequestID string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Token     string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
	// Types that are valid to be assigned to Msg:
	//	*C2VAPIStreamRequest_ExecReq
	//	*C2VAPIStreamRequest_HcReq
	//	*C2VAPIStreamRequest_CancelReq
	//	*C2VAPIStreamRequest_DebugLogReq
	//	*C2VAPIStreamRequest_DebugPodsReq
	//	*C2VAPIStreamRequest_GenerateOTelScriptReq
	Msg isC2VAPIStreamRequest_Msg `protobuf_oneof:"msg"`
}

func (*C2VAPIStreamRequest) Descriptor 

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

func (*C2VAPIStreamRequest) Equal 

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

func (*C2VAPIStreamRequest) GetCancelReq 

func (m *C2VAPIStreamRequest) GetCancelReq() *C2VAPIStreamCancel

func (*C2VAPIStreamRequest) GetDebugLogReq 

func (m *C2VAPIStreamRequest) GetDebugLogReq() *vizierpb.DebugLogRequest

func (*C2VAPIStreamRequest) GetDebugPodsReq 

func (m *C2VAPIStreamRequest) GetDebugPodsReq() *vizierpb.DebugPodsRequest

func (*C2VAPIStreamRequest) GetExecReq 

func (m *C2VAPIStreamRequest) GetExecReq() *vizierpb.ExecuteScriptRequest

func (*C2VAPIStreamRequest) GetGenerateOTelScriptReq 

func (m *C2VAPIStreamRequest) GetGenerateOTelScriptReq() *vizierpb.GenerateOTelScriptRequest

func (*C2VAPIStreamRequest) GetHcReq 

func (m *C2VAPIStreamRequest) GetHcReq() *vizierpb.HealthCheckRequest

func (*C2VAPIStreamRequest) GetMsg 

func (m *C2VAPIStreamRequest) GetMsg() isC2VAPIStreamRequest_Msg

func (*C2VAPIStreamRequest) GetRequestID 

func (m *C2VAPIStreamRequest) GetRequestID() string

func (*C2VAPIStreamRequest) GetToken 

func (m *C2VAPIStreamRequest) GetToken() string

func (*C2VAPIStreamRequest) GoString 

func (this *C2VAPIStreamRequest) GoString() string

func (*C2VAPIStreamRequest) Marshal 

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

func (*C2VAPIStreamRequest) MarshalTo 

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

func (*C2VAPIStreamRequest) MarshalToSizedBuffer 

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

func (*C2VAPIStreamRequest) ProtoMessage 

func (*C2VAPIStreamRequest) ProtoMessage()

func (*C2VAPIStreamRequest) Reset 

func (m *C2VAPIStreamRequest) Reset()

func (*C2VAPIStreamRequest) Size 

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

func (*C2VAPIStreamRequest) String 

func (this *C2VAPIStreamRequest) String() string

func (*C2VAPIStreamRequest) Unmarshal 

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

func (*C2VAPIStreamRequest) XXX_DiscardUnknown 

func (m *C2VAPIStreamRequest) XXX_DiscardUnknown()

func (*C2VAPIStreamRequest) XXX_Marshal 

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

func (*C2VAPIStreamRequest) XXX_Merge 

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

func (*C2VAPIStreamRequest) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*C2VAPIStreamRequest) XXX_Size 

func (m *C2VAPIStreamRequest) XXX_Size() int

func (*C2VAPIStreamRequest) XXX_Unmarshal 

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

type C2VAPIStreamRequest_CancelReq 

type C2VAPIStreamRequest_CancelReq struct {
	CancelReq *C2VAPIStreamCancel `protobuf:"bytes,5,opt,name=cancel_req,json=cancelReq,proto3,oneof" json:"cancel_req,omitempty"`
}

func (*C2VAPIStreamRequest_CancelReq) Equal 

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

func (*C2VAPIStreamRequest_CancelReq) GoString 

func (this *C2VAPIStreamRequest_CancelReq) GoString() string

func (*C2VAPIStreamRequest_CancelReq) MarshalTo 

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

func (*C2VAPIStreamRequest_CancelReq) MarshalToSizedBuffer 

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

func (*C2VAPIStreamRequest_CancelReq) Size 

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

func (*C2VAPIStreamRequest_CancelReq) String 

func (this *C2VAPIStreamRequest_CancelReq) String() string

type C2VAPIStreamRequest_DebugLogReq 

type C2VAPIStreamRequest_DebugLogReq struct {
	DebugLogReq *vizierpb.DebugLogRequest `protobuf:"bytes,8,opt,name=debug_log_req,json=debugLogReq,proto3,oneof" json:"debug_log_req,omitempty"`
}

func (*C2VAPIStreamRequest_DebugLogReq) Equal 

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

func (*C2VAPIStreamRequest_DebugLogReq) GoString 

func (this *C2VAPIStreamRequest_DebugLogReq) GoString() string

func (*C2VAPIStreamRequest_DebugLogReq) MarshalTo 

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

func (*C2VAPIStreamRequest_DebugLogReq) MarshalToSizedBuffer 

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

func (*C2VAPIStreamRequest_DebugLogReq) Size 

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

func (*C2VAPIStreamRequest_DebugLogReq) String 

func (this *C2VAPIStreamRequest_DebugLogReq) String() string

type C2VAPIStreamRequest_DebugPodsReq 

type C2VAPIStreamRequest_DebugPodsReq struct {
	DebugPodsReq *vizierpb.DebugPodsRequest `protobuf:"bytes,9,opt,name=debug_pods_req,json=debugPodsReq,proto3,oneof" json:"debug_pods_req,omitempty"`
}

func (*C2VAPIStreamRequest_DebugPodsReq) Equal 

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

func (*C2VAPIStreamRequest_DebugPodsReq) GoString 

func (this *C2VAPIStreamRequest_DebugPodsReq) GoString() string

func (*C2VAPIStreamRequest_DebugPodsReq) MarshalTo 

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

func (*C2VAPIStreamRequest_DebugPodsReq) MarshalToSizedBuffer 

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

func (*C2VAPIStreamRequest_DebugPodsReq) Size 

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

func (*C2VAPIStreamRequest_DebugPodsReq) String 

func (this *C2VAPIStreamRequest_DebugPodsReq) String() string

type C2VAPIStreamRequest_ExecReq 

type C2VAPIStreamRequest_ExecReq struct {
	ExecReq *vizierpb.ExecuteScriptRequest `protobuf:"bytes,3,opt,name=exec_req,json=execReq,proto3,oneof" json:"exec_req,omitempty"`
}

func (*C2VAPIStreamRequest_ExecReq) Equal 

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

func (*C2VAPIStreamRequest_ExecReq) GoString 

func (this *C2VAPIStreamRequest_ExecReq) GoString() string

func (*C2VAPIStreamRequest_ExecReq) MarshalTo 

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

func (*C2VAPIStreamRequest_ExecReq) MarshalToSizedBuffer 

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

func (*C2VAPIStreamRequest_ExecReq) Size 

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

func (*C2VAPIStreamRequest_ExecReq) String 

func (this *C2VAPIStreamRequest_ExecReq) String() string

type C2VAPIStreamRequest_GenerateOTelScriptReq 

type C2VAPIStreamRequest_GenerateOTelScriptReq struct {
	GenerateOTelScriptReq *vizierpb.GenerateOTelScriptRequest `` /* 135-byte string literal not displayed */
}

func (*C2VAPIStreamRequest_GenerateOTelScriptReq) Equal 

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

func (*C2VAPIStreamRequest_GenerateOTelScriptReq) GoString 

func (this *C2VAPIStreamRequest_GenerateOTelScriptReq) GoString() string

func (*C2VAPIStreamRequest_GenerateOTelScriptReq) MarshalTo 

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

func (*C2VAPIStreamRequest_GenerateOTelScriptReq) MarshalToSizedBuffer 

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

func (*C2VAPIStreamRequest_GenerateOTelScriptReq) Size 

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

func (*C2VAPIStreamRequest_GenerateOTelScriptReq) String 

func (this *C2VAPIStreamRequest_GenerateOTelScriptReq) String() string

type C2VAPIStreamRequest_HcReq 

type C2VAPIStreamRequest_HcReq struct {
	HcReq *vizierpb.HealthCheckRequest `protobuf:"bytes,4,opt,name=hc_req,json=hcReq,proto3,oneof" json:"hc_req,omitempty"`
}

func (*C2VAPIStreamRequest_HcReq) Equal 

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

func (*C2VAPIStreamRequest_HcReq) GoString 

func (this *C2VAPIStreamRequest_HcReq) GoString() string

func (*C2VAPIStreamRequest_HcReq) MarshalTo 

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

func (*C2VAPIStreamRequest_HcReq) MarshalToSizedBuffer 

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

func (*C2VAPIStreamRequest_HcReq) Size 

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

func (*C2VAPIStreamRequest_HcReq) String 

func (this *C2VAPIStreamRequest_HcReq) String() string

type C2VMessage 

type C2VMessage struct {
	VizierID string     `protobuf:"bytes,1,opt,name=vizier_id,json=vizierId,proto3" json:"vizier_id,omitempty"`
	Msg      *types.Any `protobuf:"bytes,2,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*C2VMessage) Descriptor 

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

func (*C2VMessage) Equal 

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

func (*C2VMessage) GetMsg 

func (m *C2VMessage) GetMsg() *types.Any

func (*C2VMessage) GetVizierID 

func (m *C2VMessage) GetVizierID() string

func (*C2VMessage) GoString 

func (this *C2VMessage) GoString() string

func (*C2VMessage) Marshal 

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

func (*C2VMessage) MarshalTo 

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

func (*C2VMessage) MarshalToSizedBuffer 

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

func (*C2VMessage) ProtoMessage 

func (*C2VMessage) ProtoMessage()

func (*C2VMessage) Reset 

func (m *C2VMessage) Reset()

func (*C2VMessage) Size 

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

func (*C2VMessage) String 

func (this *C2VMessage) String() string

func (*C2VMessage) Unmarshal 

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

func (*C2VMessage) XXX_DiscardUnknown 

func (m *C2VMessage) XXX_DiscardUnknown()

func (*C2VMessage) XXX_Marshal 

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

func (*C2VMessage) XXX_Merge 

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

func (*C2VMessage) XXX_Size 

func (m *C2VMessage) XXX_Size() int

func (*C2VMessage) XXX_Unmarshal 

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

type ContainerStatus 

type ContainerStatus struct {
	Name         string                    `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	State        metadatapb.ContainerState `protobuf:"varint,2,opt,name=state,proto3,enum=px.shared.k8s.metadatapb.ContainerState" json:"state,omitempty"`
	Message      string                    `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Reason       string                    `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	CreatedAt    *types.Timestamp          `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	RestartCount int64                     `protobuf:"varint,7,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
}

func (*ContainerStatus) Descriptor 

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

func (*ContainerStatus) Equal 

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

func (*ContainerStatus) GetCreatedAt 

func (m *ContainerStatus) GetCreatedAt() *types.Timestamp

func (*ContainerStatus) GetMessage 

func (m *ContainerStatus) GetMessage() string

func (*ContainerStatus) GetName 

func (m *ContainerStatus) GetName() string

func (*ContainerStatus) GetReason 

func (m *ContainerStatus) GetReason() string

func (*ContainerStatus) GetRestartCount 

func (m *ContainerStatus) GetRestartCount() int64

func (*ContainerStatus) GetState 

func (m *ContainerStatus) GetState() metadatapb.ContainerState

func (*ContainerStatus) GoString 

func (this *ContainerStatus) GoString() string

func (*ContainerStatus) Marshal 

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

func (*ContainerStatus) MarshalTo 

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

func (*ContainerStatus) MarshalToSizedBuffer 

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

func (*ContainerStatus) ProtoMessage 

func (*ContainerStatus) ProtoMessage()

func (*ContainerStatus) Reset 

func (m *ContainerStatus) Reset()

func (*ContainerStatus) Size 

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

func (*ContainerStatus) String 

func (this *ContainerStatus) String() string

func (*ContainerStatus) Unmarshal 

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

func (*ContainerStatus) XXX_DiscardUnknown 

func (m *ContainerStatus) XXX_DiscardUnknown()

func (*ContainerStatus) XXX_Marshal 

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

func (*ContainerStatus) XXX_Merge 

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

func (*ContainerStatus) XXX_Size 

func (m *ContainerStatus) XXX_Size() int

func (*ContainerStatus) XXX_Unmarshal 

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

type CronScript 

type CronScript struct {
	ID             *uuidpb.UUID `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	Script         string       `protobuf:"bytes,2,opt,name=script,proto3" json:"script,omitempty"`
	CronExpression string       `protobuf:"bytes,3,opt,name=cron_expression,json=cronExpression,proto3" json:"cron_expression,omitempty"`
	Configs        string       `protobuf:"bytes,4,opt,name=configs,proto3" json:"configs,omitempty"`
	FrequencyS     int64        `protobuf:"varint,5,opt,name=frequency_s,json=frequencyS,proto3" json:"frequency_s,omitempty"`
}

func (*CronScript) Descriptor 

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

func (*CronScript) Equal 

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

func (*CronScript) GetConfigs 

func (m *CronScript) GetConfigs() string

func (*CronScript) GetCronExpression 

func (m *CronScript) GetCronExpression() string

func (*CronScript) GetFrequencyS 

func (m *CronScript) GetFrequencyS() int64

func (*CronScript) GetID 

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

func (*CronScript) GetScript 

func (m *CronScript) GetScript() string

func (*CronScript) GoString 

func (this *CronScript) GoString() string

func (*CronScript) Marshal 

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

func (*CronScript) MarshalTo 

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

func (*CronScript) MarshalToSizedBuffer 

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

func (*CronScript) ProtoMessage 

func (*CronScript) ProtoMessage()

func (*CronScript) Reset 

func (m *CronScript) Reset()

func (*CronScript) Size 

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

func (*CronScript) String 

func (this *CronScript) String() string

func (*CronScript) Unmarshal 

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

func (*CronScript) XXX_DiscardUnknown 

func (m *CronScript) XXX_DiscardUnknown()

func (*CronScript) XXX_Marshal 

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

func (*CronScript) XXX_Merge 

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

func (*CronScript) XXX_Size 

func (m *CronScript) XXX_Size() int

func (*CronScript) XXX_Unmarshal 

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

type CronScriptUpdate 

type CronScriptUpdate struct {
	// Types that are valid to be assigned to Msg:
	//	*CronScriptUpdate_UpsertReq
	//	*CronScriptUpdate_DeleteReq
	Msg       isCronScriptUpdate_Msg `protobuf_oneof:"msg"`
	RequestID string                 `protobuf:"bytes,3,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	Timestamp int64                  `protobuf:"varint,4,opt,name=timestamp,proto3" json:"timestamp,omitempty"`
}

func (*CronScriptUpdate) Descriptor 

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

func (*CronScriptUpdate) Equal 

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

func (*CronScriptUpdate) GetDeleteReq 

func (m *CronScriptUpdate) GetDeleteReq() *DeleteCronScriptRequest

func (*CronScriptUpdate) GetMsg 

func (m *CronScriptUpdate) GetMsg() isCronScriptUpdate_Msg

func (*CronScriptUpdate) GetRequestID 

func (m *CronScriptUpdate) GetRequestID() string

func (*CronScriptUpdate) GetTimestamp 

func (m *CronScriptUpdate) GetTimestamp() int64

func (*CronScriptUpdate) GetUpsertReq 

func (m *CronScriptUpdate) GetUpsertReq() *RegisterOrUpdateCronScriptRequest

func (*CronScriptUpdate) GoString 

func (this *CronScriptUpdate) GoString() string

func (*CronScriptUpdate) Marshal 

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

func (*CronScriptUpdate) MarshalTo 

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

func (*CronScriptUpdate) MarshalToSizedBuffer 

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

func (*CronScriptUpdate) ProtoMessage 

func (*CronScriptUpdate) ProtoMessage()

func (*CronScriptUpdate) Reset 

func (m *CronScriptUpdate) Reset()

func (*CronScriptUpdate) Size 

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

func (*CronScriptUpdate) String 

func (this *CronScriptUpdate) String() string

func (*CronScriptUpdate) Unmarshal 

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

func (*CronScriptUpdate) XXX_DiscardUnknown 

func (m *CronScriptUpdate) XXX_DiscardUnknown()

func (*CronScriptUpdate) XXX_Marshal 

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

func (*CronScriptUpdate) XXX_Merge 

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

func (*CronScriptUpdate) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*CronScriptUpdate) XXX_Size 

func (m *CronScriptUpdate) XXX_Size() int

func (*CronScriptUpdate) XXX_Unmarshal 

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

type CronScriptUpdate_DeleteReq 

type CronScriptUpdate_DeleteReq struct {
	DeleteReq *DeleteCronScriptRequest `protobuf:"bytes,2,opt,name=delete_req,json=deleteReq,proto3,oneof" json:"delete_req,omitempty"`
}

func (*CronScriptUpdate_DeleteReq) Equal 

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

func (*CronScriptUpdate_DeleteReq) GoString 

func (this *CronScriptUpdate_DeleteReq) GoString() string

func (*CronScriptUpdate_DeleteReq) MarshalTo 

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

func (*CronScriptUpdate_DeleteReq) MarshalToSizedBuffer 

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

func (*CronScriptUpdate_DeleteReq) Size 

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

func (*CronScriptUpdate_DeleteReq) String 

func (this *CronScriptUpdate_DeleteReq) String() string

type CronScriptUpdate_UpsertReq 

type CronScriptUpdate_UpsertReq struct {
	UpsertReq *RegisterOrUpdateCronScriptRequest `protobuf:"bytes,1,opt,name=upsert_req,json=upsertReq,proto3,oneof" json:"upsert_req,omitempty"`
}

func (*CronScriptUpdate_UpsertReq) Equal 

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

func (*CronScriptUpdate_UpsertReq) GoString 

func (this *CronScriptUpdate_UpsertReq) GoString() string

func (*CronScriptUpdate_UpsertReq) MarshalTo 

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

func (*CronScriptUpdate_UpsertReq) MarshalToSizedBuffer 

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

func (*CronScriptUpdate_UpsertReq) Size 

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

func (*CronScriptUpdate_UpsertReq) String 

func (this *CronScriptUpdate_UpsertReq) String() string

type DeleteCronScriptRequest 

type DeleteCronScriptRequest struct {
	ScriptID *uuidpb.UUID `protobuf:"bytes,1,opt,name=script_id,json=scriptId,proto3" json:"script_id,omitempty"`
}

func (*DeleteCronScriptRequest) Descriptor 

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

func (*DeleteCronScriptRequest) Equal 

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

func (*DeleteCronScriptRequest) GetScriptID 

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

func (*DeleteCronScriptRequest) GoString 

func (this *DeleteCronScriptRequest) GoString() string

func (*DeleteCronScriptRequest) Marshal 

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

func (*DeleteCronScriptRequest) MarshalTo 

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

func (*DeleteCronScriptRequest) MarshalToSizedBuffer 

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

func (*DeleteCronScriptRequest) ProtoMessage 

func (*DeleteCronScriptRequest) ProtoMessage()

func (*DeleteCronScriptRequest) Reset 

func (m *DeleteCronScriptRequest) Reset()

func (*DeleteCronScriptRequest) Size 

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

func (*DeleteCronScriptRequest) String 

func (this *DeleteCronScriptRequest) String() string

func (*DeleteCronScriptRequest) Unmarshal 

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

func (*DeleteCronScriptRequest) XXX_DiscardUnknown 

func (m *DeleteCronScriptRequest) XXX_DiscardUnknown()

func (*DeleteCronScriptRequest) XXX_Marshal 

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

func (*DeleteCronScriptRequest) XXX_Merge 

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

func (*DeleteCronScriptRequest) XXX_Size 

func (m *DeleteCronScriptRequest) XXX_Size() int

func (*DeleteCronScriptRequest) XXX_Unmarshal 

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

type DeleteCronScriptResponse 

type DeleteCronScriptResponse struct {
}

func (*DeleteCronScriptResponse) Descriptor 

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

func (*DeleteCronScriptResponse) Equal 

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

func (*DeleteCronScriptResponse) GoString 

func (this *DeleteCronScriptResponse) GoString() string

func (*DeleteCronScriptResponse) Marshal 

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

func (*DeleteCronScriptResponse) MarshalTo 

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

func (*DeleteCronScriptResponse) MarshalToSizedBuffer 

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

func (*DeleteCronScriptResponse) ProtoMessage 

func (*DeleteCronScriptResponse) ProtoMessage()

func (*DeleteCronScriptResponse) Reset 

func (m *DeleteCronScriptResponse) Reset()

func (*DeleteCronScriptResponse) Size 

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

func (*DeleteCronScriptResponse) String 

func (this *DeleteCronScriptResponse) String() string

func (*DeleteCronScriptResponse) Unmarshal 

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

func (*DeleteCronScriptResponse) XXX_DiscardUnknown 

func (m *DeleteCronScriptResponse) XXX_DiscardUnknown()

func (*DeleteCronScriptResponse) XXX_Marshal 

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

func (*DeleteCronScriptResponse) XXX_Merge 

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

func (*DeleteCronScriptResponse) XXX_Size 

func (m *DeleteCronScriptResponse) XXX_Size() int

func (*DeleteCronScriptResponse) XXX_Unmarshal 

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

type GetCronScriptsChecksumRequest 

type GetCronScriptsChecksumRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
}

func (*GetCronScriptsChecksumRequest) Descriptor 

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

func (*GetCronScriptsChecksumRequest) Equal 

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

func (*GetCronScriptsChecksumRequest) GetTopic 

func (m *GetCronScriptsChecksumRequest) GetTopic() string

func (*GetCronScriptsChecksumRequest) GoString 

func (this *GetCronScriptsChecksumRequest) GoString() string

func (*GetCronScriptsChecksumRequest) Marshal 

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

func (*GetCronScriptsChecksumRequest) MarshalTo 

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

func (*GetCronScriptsChecksumRequest) MarshalToSizedBuffer 

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

func (*GetCronScriptsChecksumRequest) ProtoMessage 

func (*GetCronScriptsChecksumRequest) ProtoMessage()

func (*GetCronScriptsChecksumRequest) Reset 

func (m *GetCronScriptsChecksumRequest) Reset()

func (*GetCronScriptsChecksumRequest) Size 

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

func (*GetCronScriptsChecksumRequest) String 

func (this *GetCronScriptsChecksumRequest) String() string

func (*GetCronScriptsChecksumRequest) Unmarshal 

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

func (*GetCronScriptsChecksumRequest) XXX_DiscardUnknown 

func (m *GetCronScriptsChecksumRequest) XXX_DiscardUnknown()

func (*GetCronScriptsChecksumRequest) XXX_Marshal 

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

func (*GetCronScriptsChecksumRequest) XXX_Merge 

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

func (*GetCronScriptsChecksumRequest) XXX_Size 

func (m *GetCronScriptsChecksumRequest) XXX_Size() int

func (*GetCronScriptsChecksumRequest) XXX_Unmarshal 

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

type GetCronScriptsChecksumResponse 

type GetCronScriptsChecksumResponse struct {
	Checksum string `protobuf:"bytes,1,opt,name=checksum,proto3" json:"checksum,omitempty"`
}

func (*GetCronScriptsChecksumResponse) Descriptor 

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

func (*GetCronScriptsChecksumResponse) Equal 

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

func (*GetCronScriptsChecksumResponse) GetChecksum 

func (m *GetCronScriptsChecksumResponse) GetChecksum() string

func (*GetCronScriptsChecksumResponse) GoString 

func (this *GetCronScriptsChecksumResponse) GoString() string

func (*GetCronScriptsChecksumResponse) Marshal 

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

func (*GetCronScriptsChecksumResponse) MarshalTo 

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

func (*GetCronScriptsChecksumResponse) MarshalToSizedBuffer 

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

func (*GetCronScriptsChecksumResponse) ProtoMessage 

func (*GetCronScriptsChecksumResponse) ProtoMessage()

func (*GetCronScriptsChecksumResponse) Reset 

func (m *GetCronScriptsChecksumResponse) Reset()

func (*GetCronScriptsChecksumResponse) Size 

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

func (*GetCronScriptsChecksumResponse) String 

func (this *GetCronScriptsChecksumResponse) String() string

func (*GetCronScriptsChecksumResponse) Unmarshal 

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

func (*GetCronScriptsChecksumResponse) XXX_DiscardUnknown 

func (m *GetCronScriptsChecksumResponse) XXX_DiscardUnknown()

func (*GetCronScriptsChecksumResponse) XXX_Marshal 

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

func (*GetCronScriptsChecksumResponse) XXX_Merge 

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

func (*GetCronScriptsChecksumResponse) XXX_Size 

func (m *GetCronScriptsChecksumResponse) XXX_Size() int

func (*GetCronScriptsChecksumResponse) XXX_Unmarshal 

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

type GetCronScriptsRequest 

type GetCronScriptsRequest struct {
	Topic string `protobuf:"bytes,1,opt,name=topic,proto3" json:"topic,omitempty"`
}

func (*GetCronScriptsRequest) Descriptor 

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

func (*GetCronScriptsRequest) Equal 

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

func (*GetCronScriptsRequest) GetTopic 

func (m *GetCronScriptsRequest) GetTopic() string

func (*GetCronScriptsRequest) GoString 

func (this *GetCronScriptsRequest) GoString() string

func (*GetCronScriptsRequest) Marshal 

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

func (*GetCronScriptsRequest) MarshalTo 

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

func (*GetCronScriptsRequest) MarshalToSizedBuffer 

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

func (*GetCronScriptsRequest) ProtoMessage 

func (*GetCronScriptsRequest) ProtoMessage()

func (*GetCronScriptsRequest) Reset 

func (m *GetCronScriptsRequest) Reset()

func (*GetCronScriptsRequest) Size 

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

func (*GetCronScriptsRequest) String 

func (this *GetCronScriptsRequest) String() string

func (*GetCronScriptsRequest) Unmarshal 

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

func (*GetCronScriptsRequest) XXX_DiscardUnknown 

func (m *GetCronScriptsRequest) XXX_DiscardUnknown()

func (*GetCronScriptsRequest) XXX_Marshal 

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

func (*GetCronScriptsRequest) XXX_Merge 

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

func (*GetCronScriptsRequest) XXX_Size 

func (m *GetCronScriptsRequest) XXX_Size() int

func (*GetCronScriptsRequest) XXX_Unmarshal 

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

type GetCronScriptsResponse 

type GetCronScriptsResponse struct {
	Scripts map[string]*CronScript `` /* 155-byte string literal not displayed */
}

func (*GetCronScriptsResponse) Descriptor 

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

func (*GetCronScriptsResponse) Equal 

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

func (*GetCronScriptsResponse) GetScripts 

func (m *GetCronScriptsResponse) GetScripts() map[string]*CronScript

func (*GetCronScriptsResponse) GoString 

func (this *GetCronScriptsResponse) GoString() string

func (*GetCronScriptsResponse) Marshal 

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

func (*GetCronScriptsResponse) MarshalTo 

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

func (*GetCronScriptsResponse) MarshalToSizedBuffer 

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

func (*GetCronScriptsResponse) ProtoMessage 

func (*GetCronScriptsResponse) ProtoMessage()

func (*GetCronScriptsResponse) Reset 

func (m *GetCronScriptsResponse) Reset()

func (*GetCronScriptsResponse) Size 

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

func (*GetCronScriptsResponse) String 

func (this *GetCronScriptsResponse) String() string

func (*GetCronScriptsResponse) Unmarshal 

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

func (*GetCronScriptsResponse) XXX_DiscardUnknown 

func (m *GetCronScriptsResponse) XXX_DiscardUnknown()

func (*GetCronScriptsResponse) XXX_Marshal 

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

func (*GetCronScriptsResponse) XXX_Merge 

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

func (*GetCronScriptsResponse) XXX_Size 

func (m *GetCronScriptsResponse) XXX_Size() int

func (*GetCronScriptsResponse) XXX_Unmarshal 

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

type K8SEvent 

type K8SEvent struct {
	Message   string           `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	FirstTime *types.Timestamp `protobuf:"bytes,2,opt,name=first_time,json=firstTime,proto3" json:"first_time,omitempty"`
	LastTime  *types.Timestamp `protobuf:"bytes,3,opt,name=last_time,json=lastTime,proto3" json:"last_time,omitempty"`
}

func (*K8SEvent) Descriptor 

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

func (*K8SEvent) Equal 

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

func (*K8SEvent) GetFirstTime 

func (m *K8SEvent) GetFirstTime() *types.Timestamp

func (*K8SEvent) GetLastTime 

func (m *K8SEvent) GetLastTime() *types.Timestamp

func (*K8SEvent) GetMessage 

func (m *K8SEvent) GetMessage() string

func (*K8SEvent) GoString 

func (this *K8SEvent) GoString() string

func (*K8SEvent) Marshal 

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

func (*K8SEvent) MarshalTo 

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

func (*K8SEvent) MarshalToSizedBuffer 

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

func (*K8SEvent) ProtoMessage 

func (*K8SEvent) ProtoMessage()

func (*K8SEvent) Reset 

func (m *K8SEvent) Reset()

func (*K8SEvent) Size 

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

func (*K8SEvent) String 

func (this *K8SEvent) String() string

func (*K8SEvent) Unmarshal 

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

func (*K8SEvent) XXX_DiscardUnknown 

func (m *K8SEvent) XXX_DiscardUnknown()

func (*K8SEvent) XXX_Marshal 

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

func (*K8SEvent) XXX_Merge 

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

func (*K8SEvent) XXX_Size 

func (m *K8SEvent) XXX_Size() int

func (*K8SEvent) XXX_Unmarshal 

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

type PodStatus 

type PodStatus struct {
	Name          string              `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Status        metadatapb.PodPhase `protobuf:"varint,2,opt,name=status,proto3,enum=px.shared.k8s.metadatapb.PodPhase" json:"status,omitempty"`
	StatusMessage string              `protobuf:"bytes,3,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	Reason        string              `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	Containers    []*ContainerStatus  `protobuf:"bytes,5,rep,name=containers,proto3" json:"containers,omitempty"`
	CreatedAt     *types.Timestamp    `protobuf:"bytes,6,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	Events        []*K8SEvent         `protobuf:"bytes,7,rep,name=events,proto3" json:"events,omitempty"`
	RestartCount  int64               `protobuf:"varint,8,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
}

func (*PodStatus) Descriptor 

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

func (*PodStatus) Equal 

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

func (*PodStatus) GetContainers 

func (m *PodStatus) GetContainers() []*ContainerStatus

func (*PodStatus) GetCreatedAt 

func (m *PodStatus) GetCreatedAt() *types.Timestamp

func (*PodStatus) GetEvents 

func (m *PodStatus) GetEvents() []*K8SEvent

func (*PodStatus) GetName 

func (m *PodStatus) GetName() string

func (*PodStatus) GetReason 

func (m *PodStatus) GetReason() string

func (*PodStatus) GetRestartCount 

func (m *PodStatus) GetRestartCount() int64

func (*PodStatus) GetStatus 

func (m *PodStatus) GetStatus() metadatapb.PodPhase

func (*PodStatus) GetStatusMessage 

func (m *PodStatus) GetStatusMessage() string

func (*PodStatus) GoString 

func (this *PodStatus) GoString() string

func (*PodStatus) Marshal 

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

func (*PodStatus) MarshalTo 

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

func (*PodStatus) MarshalToSizedBuffer 

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

func (*PodStatus) ProtoMessage 

func (*PodStatus) ProtoMessage()

func (*PodStatus) Reset 

func (m *PodStatus) Reset()

func (*PodStatus) Size 

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

func (*PodStatus) String 

func (this *PodStatus) String() string

func (*PodStatus) Unmarshal 

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

func (*PodStatus) XXX_DiscardUnknown 

func (m *PodStatus) XXX_DiscardUnknown()

func (*PodStatus) XXX_Marshal 

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

func (*PodStatus) XXX_Merge 

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

func (*PodStatus) XXX_Size 

func (m *PodStatus) XXX_Size() int

func (*PodStatus) XXX_Unmarshal 

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

type RegisterOrUpdateCronScriptRequest 

type RegisterOrUpdateCronScriptRequest struct {
	Script *CronScript `protobuf:"bytes,1,opt,name=script,proto3" json:"script,omitempty"`
}

func (*RegisterOrUpdateCronScriptRequest) Descriptor 

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

func (*RegisterOrUpdateCronScriptRequest) Equal 

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

func (*RegisterOrUpdateCronScriptRequest) GetScript 

func (m *RegisterOrUpdateCronScriptRequest) GetScript() *CronScript

func (*RegisterOrUpdateCronScriptRequest) GoString 

func (this *RegisterOrUpdateCronScriptRequest) GoString() string

func (*RegisterOrUpdateCronScriptRequest) Marshal 

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

func (*RegisterOrUpdateCronScriptRequest) MarshalTo 

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

func (*RegisterOrUpdateCronScriptRequest) MarshalToSizedBuffer 

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

func (*RegisterOrUpdateCronScriptRequest) ProtoMessage 

func (*RegisterOrUpdateCronScriptRequest) ProtoMessage()

func (*RegisterOrUpdateCronScriptRequest) Reset 

func (m *RegisterOrUpdateCronScriptRequest) Reset()

func (*RegisterOrUpdateCronScriptRequest) Size 

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

func (*RegisterOrUpdateCronScriptRequest) String 

func (this *RegisterOrUpdateCronScriptRequest) String() string

func (*RegisterOrUpdateCronScriptRequest) Unmarshal 

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

func (*RegisterOrUpdateCronScriptRequest) XXX_DiscardUnknown 

func (m *RegisterOrUpdateCronScriptRequest) XXX_DiscardUnknown()

func (*RegisterOrUpdateCronScriptRequest) XXX_Marshal 

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

func (*RegisterOrUpdateCronScriptRequest) XXX_Merge 

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

func (*RegisterOrUpdateCronScriptRequest) XXX_Size 

func (m *RegisterOrUpdateCronScriptRequest) XXX_Size() int

func (*RegisterOrUpdateCronScriptRequest) XXX_Unmarshal 

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

type RegisterOrUpdateCronScriptResponse 

type RegisterOrUpdateCronScriptResponse struct {
}

func (*RegisterOrUpdateCronScriptResponse) Descriptor 

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

func (*RegisterOrUpdateCronScriptResponse) Equal 

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

func (*RegisterOrUpdateCronScriptResponse) GoString 

func (this *RegisterOrUpdateCronScriptResponse) GoString() string

func (*RegisterOrUpdateCronScriptResponse) Marshal 

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

func (*RegisterOrUpdateCronScriptResponse) MarshalTo 

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

func (*RegisterOrUpdateCronScriptResponse) MarshalToSizedBuffer 

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

func (*RegisterOrUpdateCronScriptResponse) ProtoMessage 

func (*RegisterOrUpdateCronScriptResponse) ProtoMessage()

func (*RegisterOrUpdateCronScriptResponse) Reset 

func (m *RegisterOrUpdateCronScriptResponse) Reset()

func (*RegisterOrUpdateCronScriptResponse) Size 

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

func (*RegisterOrUpdateCronScriptResponse) String 

func (this *RegisterOrUpdateCronScriptResponse) String() string

func (*RegisterOrUpdateCronScriptResponse) Unmarshal 

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

func (*RegisterOrUpdateCronScriptResponse) XXX_DiscardUnknown 

func (m *RegisterOrUpdateCronScriptResponse) XXX_DiscardUnknown()

func (*RegisterOrUpdateCronScriptResponse) XXX_Marshal 

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

func (*RegisterOrUpdateCronScriptResponse) XXX_Merge 

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

func (*RegisterOrUpdateCronScriptResponse) XXX_Size 

func (m *RegisterOrUpdateCronScriptResponse) XXX_Size() int

func (*RegisterOrUpdateCronScriptResponse) XXX_Unmarshal 

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

type RegisterVizierAck 

type RegisterVizierAck struct {
	Status     RegisterVizierAck_RegistrationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=px.cvmsgspb.RegisterVizierAck_RegistrationStatus" json:"status,omitempty"`
	VizierName string                               `protobuf:"bytes,2,opt,name=vizier_name,json=vizierName,proto3" json:"vizier_name,omitempty"`
}

func (*RegisterVizierAck) Descriptor 

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

func (*RegisterVizierAck) Equal 

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

func (*RegisterVizierAck) GetStatus 

func (m *RegisterVizierAck) GetStatus() RegisterVizierAck_RegistrationStatus

func (*RegisterVizierAck) GetVizierName 

func (m *RegisterVizierAck) GetVizierName() string

func (*RegisterVizierAck) GoString 

func (this *RegisterVizierAck) GoString() string

func (*RegisterVizierAck) Marshal 

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

func (*RegisterVizierAck) MarshalTo 

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

func (*RegisterVizierAck) MarshalToSizedBuffer 

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

func (*RegisterVizierAck) ProtoMessage 

func (*RegisterVizierAck) ProtoMessage()

func (*RegisterVizierAck) Reset 

func (m *RegisterVizierAck) Reset()

func (*RegisterVizierAck) Size 

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

func (*RegisterVizierAck) String 

func (this *RegisterVizierAck) String() string

func (*RegisterVizierAck) Unmarshal 

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

func (*RegisterVizierAck) XXX_DiscardUnknown 

func (m *RegisterVizierAck) XXX_DiscardUnknown()

func (*RegisterVizierAck) XXX_Marshal 

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

func (*RegisterVizierAck) XXX_Merge 

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

func (*RegisterVizierAck) XXX_Size 

func (m *RegisterVizierAck) XXX_Size() int

func (*RegisterVizierAck) XXX_Unmarshal 

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

type RegisterVizierAck_RegistrationStatus 

type RegisterVizierAck_RegistrationStatus int32
const (
	ST_UNKNOWN          RegisterVizierAck_RegistrationStatus = 0
	ST_OK               RegisterVizierAck_RegistrationStatus = 1
	ST_FAILED_NOT_FOUND RegisterVizierAck_RegistrationStatus = 2
)

func (RegisterVizierAck_RegistrationStatus) EnumDescriptor 

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

func (RegisterVizierAck_RegistrationStatus) String 

func (x RegisterVizierAck_RegistrationStatus) String() string

type RegisterVizierRequest 

type RegisterVizierRequest struct {
	VizierID    *uuidpb.UUID       `protobuf:"bytes,1,opt,name=vizier_id,json=vizierId,proto3" json:"vizier_id,omitempty"`
	JwtKey      string             `protobuf:"bytes,2,opt,name=jwt_key,json=jwtKey,proto3" json:"jwt_key,omitempty"`
	ClusterInfo *VizierClusterInfo `protobuf:"bytes,4,opt,name=cluster_info,json=clusterInfo,proto3" json:"cluster_info,omitempty"`
}

func (*RegisterVizierRequest) Descriptor 

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

func (*RegisterVizierRequest) Equal 

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

func (*RegisterVizierRequest) GetClusterInfo 

func (m *RegisterVizierRequest) GetClusterInfo() *VizierClusterInfo

func (*RegisterVizierRequest) GetJwtKey 

func (m *RegisterVizierRequest) GetJwtKey() string

func (*RegisterVizierRequest) GetVizierID 

func (m *RegisterVizierRequest) GetVizierID() *uuidpb.UUID

func (*RegisterVizierRequest) GoString 

func (this *RegisterVizierRequest) GoString() string

func (*RegisterVizierRequest) Marshal 

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

func (*RegisterVizierRequest) MarshalTo 

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

func (*RegisterVizierRequest) MarshalToSizedBuffer 

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

func (*RegisterVizierRequest) ProtoMessage 

func (*RegisterVizierRequest) ProtoMessage()

func (*RegisterVizierRequest) Reset 

func (m *RegisterVizierRequest) Reset()

func (*RegisterVizierRequest) Size 

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

func (*RegisterVizierRequest) String 

func (this *RegisterVizierRequest) String() string

func (*RegisterVizierRequest) Unmarshal 

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

func (*RegisterVizierRequest) XXX_DiscardUnknown 

func (m *RegisterVizierRequest) XXX_DiscardUnknown()

func (*RegisterVizierRequest) XXX_Marshal 

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

func (*RegisterVizierRequest) XXX_Merge 

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

func (*RegisterVizierRequest) XXX_Size 

func (m *RegisterVizierRequest) XXX_Size() int

func (*RegisterVizierRequest) XXX_Unmarshal 

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

type UpdateOrInstallVizierRequest 

type UpdateOrInstallVizierRequest struct {
	VizierID     *uuidpb.UUID `protobuf:"bytes,1,opt,name=vizier_id,json=vizierId,proto3" json:"vizier_id,omitempty"`
	Version      string       `protobuf:"bytes,2,opt,name=version,proto3" json:"version,omitempty"`
	Token        string       `protobuf:"bytes,3,opt,name=token,proto3" json:"token,omitempty"`
	RedeployEtcd bool         `protobuf:"varint,4,opt,name=redeploy_etcd,json=redeployEtcd,proto3" json:"redeploy_etcd,omitempty"`
}

func (*UpdateOrInstallVizierRequest) Descriptor 

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

func (*UpdateOrInstallVizierRequest) Equal 

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

func (*UpdateOrInstallVizierRequest) GetRedeployEtcd 

func (m *UpdateOrInstallVizierRequest) GetRedeployEtcd() bool

func (*UpdateOrInstallVizierRequest) GetToken 

func (m *UpdateOrInstallVizierRequest) GetToken() string

func (*UpdateOrInstallVizierRequest) GetVersion 

func (m *UpdateOrInstallVizierRequest) GetVersion() string

func (*UpdateOrInstallVizierRequest) GetVizierID 

func (m *UpdateOrInstallVizierRequest) GetVizierID() *uuidpb.UUID

func (*UpdateOrInstallVizierRequest) GoString 

func (this *UpdateOrInstallVizierRequest) GoString() string

func (*UpdateOrInstallVizierRequest) Marshal 

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

func (*UpdateOrInstallVizierRequest) MarshalTo 

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

func (*UpdateOrInstallVizierRequest) MarshalToSizedBuffer 

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

func (*UpdateOrInstallVizierRequest) ProtoMessage 

func (*UpdateOrInstallVizierRequest) ProtoMessage()

func (*UpdateOrInstallVizierRequest) Reset 

func (m *UpdateOrInstallVizierRequest) Reset()

func (*UpdateOrInstallVizierRequest) Size 

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

func (*UpdateOrInstallVizierRequest) String 

func (this *UpdateOrInstallVizierRequest) String() string

func (*UpdateOrInstallVizierRequest) Unmarshal 

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

func (*UpdateOrInstallVizierRequest) XXX_DiscardUnknown 

func (m *UpdateOrInstallVizierRequest) XXX_DiscardUnknown()

func (*UpdateOrInstallVizierRequest) XXX_Marshal 

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

func (*UpdateOrInstallVizierRequest) XXX_Merge 

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

func (*UpdateOrInstallVizierRequest) XXX_Size 

func (m *UpdateOrInstallVizierRequest) XXX_Size() int

func (*UpdateOrInstallVizierRequest) XXX_Unmarshal 

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

type UpdateOrInstallVizierResponse 

type UpdateOrInstallVizierResponse struct {
	UpdateStarted bool `protobuf:"varint,1,opt,name=update_started,json=updateStarted,proto3" json:"update_started,omitempty"`
}

func (*UpdateOrInstallVizierResponse) Descriptor 

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

func (*UpdateOrInstallVizierResponse) Equal 

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

func (*UpdateOrInstallVizierResponse) GetUpdateStarted 

func (m *UpdateOrInstallVizierResponse) GetUpdateStarted() bool

func (*UpdateOrInstallVizierResponse) GoString 

func (this *UpdateOrInstallVizierResponse) GoString() string

func (*UpdateOrInstallVizierResponse) Marshal 

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

func (*UpdateOrInstallVizierResponse) MarshalTo 

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

func (*UpdateOrInstallVizierResponse) MarshalToSizedBuffer 

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

func (*UpdateOrInstallVizierResponse) ProtoMessage 

func (*UpdateOrInstallVizierResponse) ProtoMessage()

func (*UpdateOrInstallVizierResponse) Reset 

func (m *UpdateOrInstallVizierResponse) Reset()

func (*UpdateOrInstallVizierResponse) Size 

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

func (*UpdateOrInstallVizierResponse) String 

func (this *UpdateOrInstallVizierResponse) String() string

func (*UpdateOrInstallVizierResponse) Unmarshal 

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

func (*UpdateOrInstallVizierResponse) XXX_DiscardUnknown 

func (m *UpdateOrInstallVizierResponse) XXX_DiscardUnknown()

func (*UpdateOrInstallVizierResponse) XXX_Marshal 

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

func (*UpdateOrInstallVizierResponse) XXX_Merge 

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

func (*UpdateOrInstallVizierResponse) XXX_Size 

func (m *UpdateOrInstallVizierResponse) XXX_Size() int

func (*UpdateOrInstallVizierResponse) XXX_Unmarshal 

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

type UpdateVizierConfigRequest 

type UpdateVizierConfigRequest struct {
	VizierID     *uuidpb.UUID        `protobuf:"bytes,1,opt,name=vizier_id,json=vizierId,proto3" json:"vizier_id,omitempty" db:vizier_id`
	ConfigUpdate *VizierConfigUpdate `protobuf:"bytes,2,opt,name=config_update,json=configUpdate,proto3" json:"config_update,omitempty"`
}

func (*UpdateVizierConfigRequest) Descriptor 

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

func (*UpdateVizierConfigRequest) Equal 

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

func (*UpdateVizierConfigRequest) GetConfigUpdate 

func (m *UpdateVizierConfigRequest) GetConfigUpdate() *VizierConfigUpdate

func (*UpdateVizierConfigRequest) GetVizierID 

func (m *UpdateVizierConfigRequest) GetVizierID() *uuidpb.UUID

func (*UpdateVizierConfigRequest) GoString 

func (this *UpdateVizierConfigRequest) GoString() string

func (*UpdateVizierConfigRequest) Marshal 

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

func (*UpdateVizierConfigRequest) MarshalTo 

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

func (*UpdateVizierConfigRequest) MarshalToSizedBuffer 

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

func (*UpdateVizierConfigRequest) ProtoMessage 

func (*UpdateVizierConfigRequest) ProtoMessage()

func (*UpdateVizierConfigRequest) Reset 

func (m *UpdateVizierConfigRequest) Reset()

func (*UpdateVizierConfigRequest) Size 

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

func (*UpdateVizierConfigRequest) String 

func (this *UpdateVizierConfigRequest) String() string

func (*UpdateVizierConfigRequest) Unmarshal 

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

func (*UpdateVizierConfigRequest) XXX_DiscardUnknown 

func (m *UpdateVizierConfigRequest) XXX_DiscardUnknown()

func (*UpdateVizierConfigRequest) XXX_Marshal 

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

func (*UpdateVizierConfigRequest) XXX_Merge 

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

func (*UpdateVizierConfigRequest) XXX_Size 

func (m *UpdateVizierConfigRequest) XXX_Size() int

func (*UpdateVizierConfigRequest) XXX_Unmarshal 

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

type UpdateVizierConfigResponse 

type UpdateVizierConfigResponse struct {
}

func (*UpdateVizierConfigResponse) Descriptor 

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

func (*UpdateVizierConfigResponse) Equal 

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

func (*UpdateVizierConfigResponse) GoString 

func (this *UpdateVizierConfigResponse) GoString() string

func (*UpdateVizierConfigResponse) Marshal 

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

func (*UpdateVizierConfigResponse) MarshalTo 

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

func (*UpdateVizierConfigResponse) MarshalToSizedBuffer 

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

func (*UpdateVizierConfigResponse) ProtoMessage 

func (*UpdateVizierConfigResponse) ProtoMessage()

func (*UpdateVizierConfigResponse) Reset 

func (m *UpdateVizierConfigResponse) Reset()

func (*UpdateVizierConfigResponse) Size 

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

func (*UpdateVizierConfigResponse) String 

func (this *UpdateVizierConfigResponse) String() string

func (*UpdateVizierConfigResponse) Unmarshal 

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

func (*UpdateVizierConfigResponse) XXX_DiscardUnknown 

func (m *UpdateVizierConfigResponse) XXX_DiscardUnknown()

func (*UpdateVizierConfigResponse) XXX_Marshal 

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

func (*UpdateVizierConfigResponse) XXX_Merge 

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

func (*UpdateVizierConfigResponse) XXX_Size 

func (m *UpdateVizierConfigResponse) XXX_Size() int

func (*UpdateVizierConfigResponse) XXX_Unmarshal 

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

type V2CAPIStreamResponse 

type V2CAPIStreamResponse struct {
	RequestID string `protobuf:"bytes,1,opt,name=request_id,json=requestId,proto3" json:"request_id,omitempty"`
	// Types that are valid to be assigned to Msg:
	//	*V2CAPIStreamResponse_ExecResp
	//	*V2CAPIStreamResponse_HcResp
	//	*V2CAPIStreamResponse_Status
	//	*V2CAPIStreamResponse_DebugLogResp
	//	*V2CAPIStreamResponse_DebugPodsResp
	//	*V2CAPIStreamResponse_GenerateOTelScriptResp
	Msg isV2CAPIStreamResponse_Msg `protobuf_oneof:"msg"`
}

func (*V2CAPIStreamResponse) Descriptor 

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

func (*V2CAPIStreamResponse) Equal 

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

func (*V2CAPIStreamResponse) GetDebugLogResp 

func (m *V2CAPIStreamResponse) GetDebugLogResp() *vizierpb.DebugLogResponse

func (*V2CAPIStreamResponse) GetDebugPodsResp 

func (m *V2CAPIStreamResponse) GetDebugPodsResp() *vizierpb.DebugPodsResponse

func (*V2CAPIStreamResponse) GetExecResp 

func (m *V2CAPIStreamResponse) GetExecResp() *vizierpb.ExecuteScriptResponse

func (*V2CAPIStreamResponse) GetGenerateOTelScriptResp 

func (m *V2CAPIStreamResponse) GetGenerateOTelScriptResp() *vizierpb.GenerateOTelScriptResponse

func (*V2CAPIStreamResponse) GetHcResp 

func (m *V2CAPIStreamResponse) GetHcResp() *vizierpb.HealthCheckResponse

func (*V2CAPIStreamResponse) GetMsg 

func (m *V2CAPIStreamResponse) GetMsg() isV2CAPIStreamResponse_Msg

func (*V2CAPIStreamResponse) GetRequestID 

func (m *V2CAPIStreamResponse) GetRequestID() string

func (*V2CAPIStreamResponse) GetStatus 

func (m *V2CAPIStreamResponse) GetStatus() *vizierpb.Status

func (*V2CAPIStreamResponse) GoString 

func (this *V2CAPIStreamResponse) GoString() string

func (*V2CAPIStreamResponse) Marshal 

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

func (*V2CAPIStreamResponse) MarshalTo 

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

func (*V2CAPIStreamResponse) MarshalToSizedBuffer 

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

func (*V2CAPIStreamResponse) ProtoMessage 

func (*V2CAPIStreamResponse) ProtoMessage()

func (*V2CAPIStreamResponse) Reset 

func (m *V2CAPIStreamResponse) Reset()

func (*V2CAPIStreamResponse) Size 

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

func (*V2CAPIStreamResponse) String 

func (this *V2CAPIStreamResponse) String() string

func (*V2CAPIStreamResponse) Unmarshal 

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

func (*V2CAPIStreamResponse) XXX_DiscardUnknown 

func (m *V2CAPIStreamResponse) XXX_DiscardUnknown()

func (*V2CAPIStreamResponse) XXX_Marshal 

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

func (*V2CAPIStreamResponse) XXX_Merge 

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

func (*V2CAPIStreamResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*V2CAPIStreamResponse) XXX_Size 

func (m *V2CAPIStreamResponse) XXX_Size() int

func (*V2CAPIStreamResponse) XXX_Unmarshal 

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

type V2CAPIStreamResponse_DebugLogResp 

type V2CAPIStreamResponse_DebugLogResp struct {
	DebugLogResp *vizierpb.DebugLogResponse `protobuf:"bytes,7,opt,name=debug_log_resp,json=debugLogResp,proto3,oneof" json:"debug_log_resp,omitempty"`
}

func (*V2CAPIStreamResponse_DebugLogResp) Equal 

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

func (*V2CAPIStreamResponse_DebugLogResp) GoString 

func (this *V2CAPIStreamResponse_DebugLogResp) GoString() string

func (*V2CAPIStreamResponse_DebugLogResp) MarshalTo 

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

func (*V2CAPIStreamResponse_DebugLogResp) MarshalToSizedBuffer 

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

func (*V2CAPIStreamResponse_DebugLogResp) Size 

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

func (*V2CAPIStreamResponse_DebugLogResp) String 

func (this *V2CAPIStreamResponse_DebugLogResp) String() string

type V2CAPIStreamResponse_DebugPodsResp 

type V2CAPIStreamResponse_DebugPodsResp struct {
	DebugPodsResp *vizierpb.DebugPodsResponse `protobuf:"bytes,8,opt,name=debug_pods_resp,json=debugPodsResp,proto3,oneof" json:"debug_pods_resp,omitempty"`
}

func (*V2CAPIStreamResponse_DebugPodsResp) Equal 

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

func (*V2CAPIStreamResponse_DebugPodsResp) GoString 

func (this *V2CAPIStreamResponse_DebugPodsResp) GoString() string

func (*V2CAPIStreamResponse_DebugPodsResp) MarshalTo 

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

func (*V2CAPIStreamResponse_DebugPodsResp) MarshalToSizedBuffer 

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

func (*V2CAPIStreamResponse_DebugPodsResp) Size 

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

func (*V2CAPIStreamResponse_DebugPodsResp) String 

func (this *V2CAPIStreamResponse_DebugPodsResp) String() string

type V2CAPIStreamResponse_ExecResp 

type V2CAPIStreamResponse_ExecResp struct {
	ExecResp *vizierpb.ExecuteScriptResponse `protobuf:"bytes,2,opt,name=exec_resp,json=execResp,proto3,oneof" json:"exec_resp,omitempty"`
}

func (*V2CAPIStreamResponse_ExecResp) Equal 

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

func (*V2CAPIStreamResponse_ExecResp) GoString 

func (this *V2CAPIStreamResponse_ExecResp) GoString() string

func (*V2CAPIStreamResponse_ExecResp) MarshalTo 

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

func (*V2CAPIStreamResponse_ExecResp) MarshalToSizedBuffer 

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

func (*V2CAPIStreamResponse_ExecResp) Size 

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

func (*V2CAPIStreamResponse_ExecResp) String 

func (this *V2CAPIStreamResponse_ExecResp) String() string

type V2CAPIStreamResponse_GenerateOTelScriptResp 

type V2CAPIStreamResponse_GenerateOTelScriptResp struct {
	GenerateOTelScriptResp *vizierpb.GenerateOTelScriptResponse `` /* 137-byte string literal not displayed */
}

func (*V2CAPIStreamResponse_GenerateOTelScriptResp) Equal 

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

func (*V2CAPIStreamResponse_GenerateOTelScriptResp) GoString 

func (this *V2CAPIStreamResponse_GenerateOTelScriptResp) GoString() string

func (*V2CAPIStreamResponse_GenerateOTelScriptResp) MarshalTo 

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

func (*V2CAPIStreamResponse_GenerateOTelScriptResp) MarshalToSizedBuffer 

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

func (*V2CAPIStreamResponse_GenerateOTelScriptResp) Size 

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

func (*V2CAPIStreamResponse_GenerateOTelScriptResp) String 

func (this *V2CAPIStreamResponse_GenerateOTelScriptResp) String() string

type V2CAPIStreamResponse_HcResp 

type V2CAPIStreamResponse_HcResp struct {
	HcResp *vizierpb.HealthCheckResponse `protobuf:"bytes,3,opt,name=hc_resp,json=hcResp,proto3,oneof" json:"hc_resp,omitempty"`
}

func (*V2CAPIStreamResponse_HcResp) Equal 

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

func (*V2CAPIStreamResponse_HcResp) GoString 

func (this *V2CAPIStreamResponse_HcResp) GoString() string

func (*V2CAPIStreamResponse_HcResp) MarshalTo 

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

func (*V2CAPIStreamResponse_HcResp) MarshalToSizedBuffer 

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

func (*V2CAPIStreamResponse_HcResp) Size 

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

func (*V2CAPIStreamResponse_HcResp) String 

func (this *V2CAPIStreamResponse_HcResp) String() string

type V2CAPIStreamResponse_Status 

type V2CAPIStreamResponse_Status struct {
	Status *vizierpb.Status `protobuf:"bytes,4,opt,name=status,proto3,oneof" json:"status,omitempty"`
}

func (*V2CAPIStreamResponse_Status) Equal 

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

func (*V2CAPIStreamResponse_Status) GoString 

func (this *V2CAPIStreamResponse_Status) GoString() string

func (*V2CAPIStreamResponse_Status) MarshalTo 

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

func (*V2CAPIStreamResponse_Status) MarshalToSizedBuffer 

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

func (*V2CAPIStreamResponse_Status) Size 

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

func (*V2CAPIStreamResponse_Status) String 

func (this *V2CAPIStreamResponse_Status) String() string

type V2CMessage 

type V2CMessage struct {
	VizierID   string     `protobuf:"bytes,1,opt,name=vizier_id,json=vizierId,proto3" json:"vizier_id,omitempty"`
	ClusterUID string     `protobuf:"bytes,2,opt,name=cluster_uid,json=clusterUid,proto3" json:"cluster_uid,omitempty"`
	SessionId  int64      `protobuf:"varint,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Msg        *types.Any `protobuf:"bytes,4,opt,name=msg,proto3" json:"msg,omitempty"`
}

func (*V2CMessage) Descriptor 

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

func (*V2CMessage) Equal 

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

func (*V2CMessage) GetClusterUID 

func (m *V2CMessage) GetClusterUID() string

func (*V2CMessage) GetMsg 

func (m *V2CMessage) GetMsg() *types.Any

func (*V2CMessage) GetSessionId 

func (m *V2CMessage) GetSessionId() int64

func (*V2CMessage) GetVizierID 

func (m *V2CMessage) GetVizierID() string

func (*V2CMessage) GoString 

func (this *V2CMessage) GoString() string

func (*V2CMessage) Marshal 

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

func (*V2CMessage) MarshalTo 

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

func (*V2CMessage) MarshalToSizedBuffer 

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

func (*V2CMessage) ProtoMessage 

func (*V2CMessage) ProtoMessage()

func (*V2CMessage) Reset 

func (m *V2CMessage) Reset()

func (*V2CMessage) Size 

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

func (*V2CMessage) String 

func (this *V2CMessage) String() string

func (*V2CMessage) Unmarshal 

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

func (*V2CMessage) XXX_DiscardUnknown 

func (m *V2CMessage) XXX_DiscardUnknown()

func (*V2CMessage) XXX_Marshal 

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

func (*V2CMessage) XXX_Merge 

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

func (*V2CMessage) XXX_Size 

func (m *V2CMessage) XXX_Size() int

func (*V2CMessage) XXX_Unmarshal 

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

type VLogMessage 

type VLogMessage struct {
	Data []byte `protobuf:"bytes,1,opt,name=data,proto3" json:"data,omitempty"`
}

func (*VLogMessage) Descriptor 

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

func (*VLogMessage) Equal 

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

func (*VLogMessage) GetData 

func (m *VLogMessage) GetData() []byte

func (*VLogMessage) GoString 

func (this *VLogMessage) GoString() string

func (*VLogMessage) Marshal 

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

func (*VLogMessage) MarshalTo 

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

func (*VLogMessage) MarshalToSizedBuffer 

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

func (*VLogMessage) ProtoMessage 

func (*VLogMessage) ProtoMessage()

func (*VLogMessage) Reset 

func (m *VLogMessage) Reset()

func (*VLogMessage) Size 

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

func (*VLogMessage) String 

func (this *VLogMessage) String() string

func (*VLogMessage) Unmarshal 

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

func (*VLogMessage) XXX_DiscardUnknown 

func (m *VLogMessage) XXX_DiscardUnknown()

func (*VLogMessage) XXX_Marshal 

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

func (*VLogMessage) XXX_Merge 

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

func (*VLogMessage) XXX_Size 

func (m *VLogMessage) XXX_Size() int

func (*VLogMessage) XXX_Unmarshal 

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

type VizierClusterInfo 

type VizierClusterInfo struct {
	ClusterUID    string `protobuf:"bytes,1,opt,name=cluster_uid,json=clusterUid,proto3" json:"cluster_uid,omitempty"`
	ClusterName   string `protobuf:"bytes,2,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	VizierVersion string `protobuf:"bytes,4,opt,name=vizier_version,json=vizierVersion,proto3" json:"vizier_version,omitempty"`
}

func (*VizierClusterInfo) Descriptor 

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

func (*VizierClusterInfo) Equal 

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

func (*VizierClusterInfo) GetClusterName 

func (m *VizierClusterInfo) GetClusterName() string

func (*VizierClusterInfo) GetClusterUID 

func (m *VizierClusterInfo) GetClusterUID() string

func (*VizierClusterInfo) GetVizierVersion 

func (m *VizierClusterInfo) GetVizierVersion() string

func (*VizierClusterInfo) GoString 

func (this *VizierClusterInfo) GoString() string

func (*VizierClusterInfo) Marshal 

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

func (*VizierClusterInfo) MarshalTo 

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

func (*VizierClusterInfo) MarshalToSizedBuffer 

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

func (*VizierClusterInfo) ProtoMessage 

func (*VizierClusterInfo) ProtoMessage()

func (*VizierClusterInfo) Reset 

func (m *VizierClusterInfo) Reset()

func (*VizierClusterInfo) Size 

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

func (*VizierClusterInfo) String 

func (this *VizierClusterInfo) String() string

func (*VizierClusterInfo) Unmarshal 

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

func (*VizierClusterInfo) XXX_DiscardUnknown 

func (m *VizierClusterInfo) XXX_DiscardUnknown()

func (*VizierClusterInfo) XXX_Marshal 

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

func (*VizierClusterInfo) XXX_Merge 

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

func (*VizierClusterInfo) XXX_Size 

func (m *VizierClusterInfo) XXX_Size() int

func (*VizierClusterInfo) XXX_Unmarshal 

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

type VizierConfig 

type VizierConfig struct {
}

func (*VizierConfig) Descriptor 

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

func (*VizierConfig) Equal 

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

func (*VizierConfig) GoString 

func (this *VizierConfig) GoString() string

func (*VizierConfig) Marshal 

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

func (*VizierConfig) MarshalTo 

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

func (*VizierConfig) MarshalToSizedBuffer 

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

func (*VizierConfig) ProtoMessage 

func (*VizierConfig) ProtoMessage()

func (*VizierConfig) Reset 

func (m *VizierConfig) Reset()

func (*VizierConfig) Size 

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

func (*VizierConfig) String 

func (this *VizierConfig) String() string

func (*VizierConfig) Unmarshal 

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

func (*VizierConfig) XXX_DiscardUnknown 

func (m *VizierConfig) XXX_DiscardUnknown()

func (*VizierConfig) XXX_Marshal 

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

func (*VizierConfig) XXX_Merge 

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

func (*VizierConfig) XXX_Size 

func (m *VizierConfig) XXX_Size() int

func (*VizierConfig) XXX_Unmarshal 

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

type VizierConfigUpdate 

type VizierConfigUpdate struct {
}

func (*VizierConfigUpdate) Descriptor 

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

func (*VizierConfigUpdate) Equal 

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

func (*VizierConfigUpdate) GoString 

func (this *VizierConfigUpdate) GoString() string

func (*VizierConfigUpdate) Marshal 

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

func (*VizierConfigUpdate) MarshalTo 

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

func (*VizierConfigUpdate) MarshalToSizedBuffer 

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

func (*VizierConfigUpdate) ProtoMessage 

func (*VizierConfigUpdate) ProtoMessage()

func (*VizierConfigUpdate) Reset 

func (m *VizierConfigUpdate) Reset()

func (*VizierConfigUpdate) Size 

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

func (*VizierConfigUpdate) String 

func (this *VizierConfigUpdate) String() string

func (*VizierConfigUpdate) Unmarshal 

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

func (*VizierConfigUpdate) XXX_DiscardUnknown 

func (m *VizierConfigUpdate) XXX_DiscardUnknown()

func (*VizierConfigUpdate) XXX_Marshal 

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

func (*VizierConfigUpdate) XXX_Merge 

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

func (*VizierConfigUpdate) XXX_Size 

func (m *VizierConfigUpdate) XXX_Size() int

func (*VizierConfigUpdate) XXX_Unmarshal 

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

type VizierConnectionInfo 

type VizierConnectionInfo struct {
	Token string `protobuf:"bytes,2,opt,name=token,proto3" json:"token,omitempty"`
}

func (*VizierConnectionInfo) Descriptor 

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

func (*VizierConnectionInfo) Equal 

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

func (*VizierConnectionInfo) GetToken 

func (m *VizierConnectionInfo) GetToken() string

func (*VizierConnectionInfo) GoString 

func (this *VizierConnectionInfo) GoString() string

func (*VizierConnectionInfo) Marshal 

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

func (*VizierConnectionInfo) MarshalTo 

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

func (*VizierConnectionInfo) MarshalToSizedBuffer 

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

func (*VizierConnectionInfo) ProtoMessage 

func (*VizierConnectionInfo) ProtoMessage()

func (*VizierConnectionInfo) Reset 

func (m *VizierConnectionInfo) Reset()

func (*VizierConnectionInfo) Size 

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

func (*VizierConnectionInfo) String 

func (this *VizierConnectionInfo) String() string

func (*VizierConnectionInfo) Unmarshal 

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

func (*VizierConnectionInfo) XXX_DiscardUnknown 

func (m *VizierConnectionInfo) XXX_DiscardUnknown()

func (*VizierConnectionInfo) XXX_Marshal 

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

func (*VizierConnectionInfo) XXX_Merge 

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

func (*VizierConnectionInfo) XXX_Size 

func (m *VizierConnectionInfo) XXX_Size() int

func (*VizierConnectionInfo) XXX_Unmarshal 

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

type VizierHeartbeat 

type VizierHeartbeat struct {
	VizierID                      *uuidpb.UUID          `protobuf:"bytes,1,opt,name=vizier_id,json=vizierId,proto3" json:"vizier_id,omitempty"`
	Time                          int64                 `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	SequenceNumber                int64                 `protobuf:"varint,3,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	PodStatuses                   map[string]*PodStatus `` /* 182-byte string literal not displayed */
	UnhealthyDataPlanePodStatuses map[string]*PodStatus `` /* 243-byte string literal not displayed */
	PodStatusesLastUpdated        int64                 `` /* 132-byte string literal not displayed */
	Status                        VizierStatus          `protobuf:"varint,8,opt,name=status,proto3,enum=px.cvmsgspb.VizierStatus" json:"status,omitempty"`
	NumNodes                      int32                 `protobuf:"varint,11,opt,name=num_nodes,json=numNodes,proto3" json:"num_nodes,omitempty"`
	NumInstrumentedNodes          int32                 `protobuf:"varint,12,opt,name=num_instrumented_nodes,json=numInstrumentedNodes,proto3" json:"num_instrumented_nodes,omitempty"`
	DisableAutoUpdate             bool                  `protobuf:"varint,13,opt,name=disable_auto_update,json=disableAutoUpdate,proto3" json:"disable_auto_update,omitempty"`
	StatusMessage                 string                `protobuf:"bytes,14,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	K8sClusterVersion             string                `protobuf:"bytes,16,opt,name=k8s_cluster_version,json=k8sClusterVersion,proto3" json:"k8s_cluster_version,omitempty"`
	OperatorVersion               string                `protobuf:"bytes,17,opt,name=operator_version,json=operatorVersion,proto3" json:"operator_version,omitempty"`
}

func (*VizierHeartbeat) Descriptor 

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

func (*VizierHeartbeat) Equal 

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

func (*VizierHeartbeat) GetDisableAutoUpdate 

func (m *VizierHeartbeat) GetDisableAutoUpdate() bool

func (*VizierHeartbeat) GetK8sClusterVersion 

func (m *VizierHeartbeat) GetK8sClusterVersion() string

func (*VizierHeartbeat) GetNumInstrumentedNodes 

func (m *VizierHeartbeat) GetNumInstrumentedNodes() int32

func (*VizierHeartbeat) GetNumNodes 

func (m *VizierHeartbeat) GetNumNodes() int32

func (*VizierHeartbeat) GetOperatorVersion 

func (m *VizierHeartbeat) GetOperatorVersion() string

func (*VizierHeartbeat) GetPodStatuses 

func (m *VizierHeartbeat) GetPodStatuses() map[string]*PodStatus

func (*VizierHeartbeat) GetPodStatusesLastUpdated 

func (m *VizierHeartbeat) GetPodStatusesLastUpdated() int64

func (*VizierHeartbeat) GetSequenceNumber 

func (m *VizierHeartbeat) GetSequenceNumber() int64

func (*VizierHeartbeat) GetStatus 

func (m *VizierHeartbeat) GetStatus() VizierStatus

func (*VizierHeartbeat) GetStatusMessage 

func (m *VizierHeartbeat) GetStatusMessage() string

func (*VizierHeartbeat) GetTime 

func (m *VizierHeartbeat) GetTime() int64

func (*VizierHeartbeat) GetUnhealthyDataPlanePodStatuses 

func (m *VizierHeartbeat) GetUnhealthyDataPlanePodStatuses() map[string]*PodStatus

func (*VizierHeartbeat) GetVizierID 

func (m *VizierHeartbeat) GetVizierID() *uuidpb.UUID

func (*VizierHeartbeat) GoString 

func (this *VizierHeartbeat) GoString() string

func (*VizierHeartbeat) Marshal 

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

func (*VizierHeartbeat) MarshalTo 

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

func (*VizierHeartbeat) MarshalToSizedBuffer 

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

func (*VizierHeartbeat) ProtoMessage 

func (*VizierHeartbeat) ProtoMessage()

func (*VizierHeartbeat) Reset 

func (m *VizierHeartbeat) Reset()

func (*VizierHeartbeat) Size 

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

func (*VizierHeartbeat) String 

func (this *VizierHeartbeat) String() string

func (*VizierHeartbeat) Unmarshal 

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

func (*VizierHeartbeat) XXX_DiscardUnknown 

func (m *VizierHeartbeat) XXX_DiscardUnknown()

func (*VizierHeartbeat) XXX_Marshal 

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

func (*VizierHeartbeat) XXX_Merge 

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

func (*VizierHeartbeat) XXX_Size 

func (m *VizierHeartbeat) XXX_Size() int

func (*VizierHeartbeat) XXX_Unmarshal 

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

type VizierHeartbeatAck 

type VizierHeartbeatAck struct {
	Status         VizierHeartbeatAck_HeartbeatStatus `protobuf:"varint,1,opt,name=status,proto3,enum=px.cvmsgspb.VizierHeartbeatAck_HeartbeatStatus" json:"status,omitempty"`
	Time           int64                              `protobuf:"varint,2,opt,name=time,proto3" json:"time,omitempty"`
	SequenceNumber int64                              `protobuf:"varint,3,opt,name=sequence_number,json=sequenceNumber,proto3" json:"sequence_number,omitempty"`
	ErrorMessage   string                             `protobuf:"bytes,4,opt,name=error_message,json=errorMessage,proto3" json:"error_message,omitempty"`
}

func (*VizierHeartbeatAck) Descriptor 

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

func (*VizierHeartbeatAck) Equal 

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

func (*VizierHeartbeatAck) GetErrorMessage 

func (m *VizierHeartbeatAck) GetErrorMessage() string

func (*VizierHeartbeatAck) GetSequenceNumber 

func (m *VizierHeartbeatAck) GetSequenceNumber() int64

func (*VizierHeartbeatAck) GetStatus 

func (m *VizierHeartbeatAck) GetStatus() VizierHeartbeatAck_HeartbeatStatus

func (*VizierHeartbeatAck) GetTime 

func (m *VizierHeartbeatAck) GetTime() int64

func (*VizierHeartbeatAck) GoString 

func (this *VizierHeartbeatAck) GoString() string

func (*VizierHeartbeatAck) Marshal 

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

func (*VizierHeartbeatAck) MarshalTo 

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

func (*VizierHeartbeatAck) MarshalToSizedBuffer 

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

func (*VizierHeartbeatAck) ProtoMessage 

func (*VizierHeartbeatAck) ProtoMessage()

func (*VizierHeartbeatAck) Reset 

func (m *VizierHeartbeatAck) Reset()

func (*VizierHeartbeatAck) Size 

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

func (*VizierHeartbeatAck) String 

func (this *VizierHeartbeatAck) String() string

func (*VizierHeartbeatAck) Unmarshal 

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

func (*VizierHeartbeatAck) XXX_DiscardUnknown 

func (m *VizierHeartbeatAck) XXX_DiscardUnknown()

func (*VizierHeartbeatAck) XXX_Marshal 

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

func (*VizierHeartbeatAck) XXX_Merge 

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

func (*VizierHeartbeatAck) XXX_Size 

func (m *VizierHeartbeatAck) XXX_Size() int

func (*VizierHeartbeatAck) XXX_Unmarshal 

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

type VizierHeartbeatAck_HeartbeatStatus 

type VizierHeartbeatAck_HeartbeatStatus int32
const (
	HB_UNKNOWN VizierHeartbeatAck_HeartbeatStatus = 0
	HB_OK      VizierHeartbeatAck_HeartbeatStatus = 1
	HB_ERROR   VizierHeartbeatAck_HeartbeatStatus = 2
)

func (VizierHeartbeatAck_HeartbeatStatus) EnumDescriptor 

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

func (VizierHeartbeatAck_HeartbeatStatus) String 

func (x VizierHeartbeatAck_HeartbeatStatus) String() string

type VizierInfo 

type VizierInfo struct {
	VizierID                      *uuidpb.UUID          `protobuf:"bytes,1,opt,name=vizier_id,json=vizierId,proto3" json:"vizier_id,omitempty" db:vizier_id`
	Status                        VizierStatus          `protobuf:"varint,2,opt,name=status,proto3,enum=px.cvmsgspb.VizierStatus" json:"status,omitempty"`
	LastHeartbeatNs               int64                 `` /* 127-byte string literal not displayed */
	Config                        *VizierConfig         `protobuf:"bytes,4,opt,name=config,proto3" json:"config,omitempty"`
	ClusterUID                    string                `protobuf:"bytes,5,opt,name=cluster_uid,json=clusterUid,proto3" json:"cluster_uid,omitempty"`
	ClusterName                   string                `protobuf:"bytes,6,opt,name=cluster_name,json=clusterName,proto3" json:"cluster_name,omitempty"`
	ClusterVersion                string                `protobuf:"bytes,7,opt,name=cluster_version,json=clusterVersion,proto3" json:"cluster_version,omitempty"`
	OperatorVersion               string                `protobuf:"bytes,17,opt,name=operator_version,json=operatorVersion,proto3" json:"operator_version,omitempty"`
	VizierVersion                 string                `protobuf:"bytes,8,opt,name=vizier_version,json=vizierVersion,proto3" json:"vizier_version,omitempty"`
	ControlPlanePodStatuses       map[string]*PodStatus `` /* 222-byte string literal not displayed */
	UnhealthyDataPlanePodStatuses map[string]*PodStatus `` /* 243-byte string literal not displayed */
	NumNodes                      int32                 `protobuf:"varint,11,opt,name=num_nodes,json=numNodes,proto3" json:"num_nodes,omitempty"`
	NumInstrumentedNodes          int32                 `protobuf:"varint,12,opt,name=num_instrumented_nodes,json=numInstrumentedNodes,proto3" json:"num_instrumented_nodes,omitempty"`
	StatusMessage                 string                `protobuf:"bytes,13,opt,name=status_message,json=statusMessage,proto3" json:"status_message,omitempty"`
	PreviousStatus                VizierStatus          `` /* 135-byte string literal not displayed */
	PreviousStatusTime            *types.Timestamp      `protobuf:"bytes,16,opt,name=previous_status_time,json=previousStatusTime,proto3" json:"previous_status_time,omitempty"`
}

func (*VizierInfo) Descriptor 

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

func (*VizierInfo) Equal 

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

func (*VizierInfo) GetClusterName 

func (m *VizierInfo) GetClusterName() string

func (*VizierInfo) GetClusterUID 

func (m *VizierInfo) GetClusterUID() string

func (*VizierInfo) GetClusterVersion 

func (m *VizierInfo) GetClusterVersion() string

func (*VizierInfo) GetConfig 

func (m *VizierInfo) GetConfig() *VizierConfig

func (*VizierInfo) GetControlPlanePodStatuses 

func (m *VizierInfo) GetControlPlanePodStatuses() map[string]*PodStatus

func (*VizierInfo) GetLastHeartbeatNs 

func (m *VizierInfo) GetLastHeartbeatNs() int64

func (*VizierInfo) GetNumInstrumentedNodes 

func (m *VizierInfo) GetNumInstrumentedNodes() int32

func (*VizierInfo) GetNumNodes 

func (m *VizierInfo) GetNumNodes() int32

func (*VizierInfo) GetOperatorVersion 

func (m *VizierInfo) GetOperatorVersion() string

func (*VizierInfo) GetPreviousStatus 

func (m *VizierInfo) GetPreviousStatus() VizierStatus

func (*VizierInfo) GetPreviousStatusTime 

func (m *VizierInfo) GetPreviousStatusTime() *types.Timestamp

func (*VizierInfo) GetStatus 

func (m *VizierInfo) GetStatus() VizierStatus

func (*VizierInfo) GetStatusMessage 

func (m *VizierInfo) GetStatusMessage() string

func (*VizierInfo) GetUnhealthyDataPlanePodStatuses 

func (m *VizierInfo) GetUnhealthyDataPlanePodStatuses() map[string]*PodStatus

func (*VizierInfo) GetVizierID 

func (m *VizierInfo) GetVizierID() *uuidpb.UUID

func (*VizierInfo) GetVizierVersion 

func (m *VizierInfo) GetVizierVersion() string

func (*VizierInfo) GoString 

func (this *VizierInfo) GoString() string

func (*VizierInfo) Marshal 

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

func (*VizierInfo) MarshalTo 

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

func (*VizierInfo) MarshalToSizedBuffer 

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

func (*VizierInfo) ProtoMessage 

func (*VizierInfo) ProtoMessage()

func (*VizierInfo) Reset 

func (m *VizierInfo) Reset()

func (*VizierInfo) Size 

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

func (*VizierInfo) String 

func (this *VizierInfo) String() string

func (*VizierInfo) Unmarshal 

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

func (*VizierInfo) XXX_DiscardUnknown 

func (m *VizierInfo) XXX_DiscardUnknown()

func (*VizierInfo) XXX_Marshal 

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

func (*VizierInfo) XXX_Merge 

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

func (*VizierInfo) XXX_Size 

func (m *VizierInfo) XXX_Size() int

func (*VizierInfo) XXX_Unmarshal 

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

type VizierStatus 

type VizierStatus int32
const (
	VZ_ST_UNKNOWN       VizierStatus = 0
	VZ_ST_HEALTHY       VizierStatus = 1
	VZ_ST_UNHEALTHY     VizierStatus = 2
	VZ_ST_DISCONNECTED  VizierStatus = 3
	VZ_ST_UPDATING      VizierStatus = 4
	VZ_ST_CONNECTED     VizierStatus = 5
	VZ_ST_UPDATE_FAILED VizierStatus = 6
	VZ_ST_DEGRADED      VizierStatus = 7
)

func (VizierStatus) EnumDescriptor 

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

func (VizierStatus) String 

func (x VizierStatus) 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.