vizierpb

package
v0.4.0 Latest Latest
Warning

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

 Go to latest Published: Aug 29, 2022 License: Apache-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	ErrInvalidLengthVizierapi        = fmt.Errorf("proto: negative length found during unmarshaling")
	ErrIntOverflowVizierapi          = fmt.Errorf("proto: integer overflow")
	ErrUnexpectedEndOfGroupVizierapi = fmt.Errorf("proto: unexpected end of group")
)
View Source 
var ContainerState_name = map[int32]string{
	0: "CONTAINER_STATE_UNKNOWN",
	1: "CONTAINER_STATE_RUNNING",
	2: "CONTAINER_STATE_TERMINATED",
	3: "CONTAINER_STATE_WAITING",
}
View Source 
var ContainerState_value = map[string]int32{
	"CONTAINER_STATE_UNKNOWN":    0,
	"CONTAINER_STATE_RUNNING":    1,
	"CONTAINER_STATE_TERMINATED": 2,
	"CONTAINER_STATE_WAITING":    3,
}
View Source 
var DataType_name = map[int32]string{
	0: "DATA_TYPE_UNKNOWN",
	1: "BOOLEAN",
	2: "INT64",
	3: "UINT128",
	4: "FLOAT64",
	5: "STRING",
	6: "TIME64NS",
}
View Source 
var DataType_value = map[string]int32{
	"DATA_TYPE_UNKNOWN": 0,
	"BOOLEAN":           1,
	"INT64":             2,
	"UINT128":           3,
	"FLOAT64":           4,
	"STRING":            5,
	"TIME64NS":          6,
}
View Source 
var LifeCycleState_name = map[int32]string{
	0: "UNKNOWN_STATE",
	1: "PENDING_STATE",
	2: "RUNNING_STATE",
	3: "FAILED_STATE",
	4: "TERMINATED_STATE",
}
View Source 
var LifeCycleState_value = map[string]int32{
	"UNKNOWN_STATE":    0,
	"PENDING_STATE":    1,
	"RUNNING_STATE":    2,
	"FAILED_STATE":     3,
	"TERMINATED_STATE": 4,
}
View Source 
var PodPhase_name = map[int32]string{
	0: "PHASE_UNKNOWN",
	1: "PENDING",
	2: "RUNNING",
	3: "SUCCEEDED",
	4: "FAILED",
}
View Source 
var PodPhase_value = map[string]int32{
	"PHASE_UNKNOWN": 0,
	"PENDING":       1,
	"RUNNING":       2,
	"SUCCEEDED":     3,
	"FAILED":        4,
}
View Source 
var SemanticType_name = map[int32]string{
	0:    "ST_UNSPECIFIED",
	1:    "ST_NONE",
	2:    "ST_TIME_NS",
	100:  "ST_AGENT_UID",
	101:  "ST_ASID",
	200:  "ST_UPID",
	300:  "ST_SERVICE_NAME",
	400:  "ST_POD_NAME",
	401:  "ST_POD_PHASE",
	402:  "ST_POD_STATUS",
	500:  "ST_NODE_NAME",
	600:  "ST_CONTAINER_NAME",
	601:  "ST_CONTAINER_STATE",
	602:  "ST_CONTAINER_STATUS",
	700:  "ST_NAMESPACE_NAME",
	800:  "ST_BYTES",
	900:  "ST_PERCENT",
	901:  "ST_DURATION_NS",
	902:  "ST_THROUGHPUT_PER_NS",
	903:  "ST_THROUGHPUT_BYTES_PER_NS",
	1000: "ST_QUANTILES",
	1001: "ST_DURATION_NS_QUANTILES",
	1100: "ST_IP_ADDRESS",
	1200: "ST_PORT",
	1300: "ST_HTTP_REQ_METHOD",
	1400: "ST_HTTP_RESP_STATUS",
	1500: "ST_HTTP_RESP_MESSAGE",
	3000: "ST_SCRIPT_REFERENCE",
}
View Source 
var SemanticType_value = map[string]int32{
	"ST_UNSPECIFIED":             0,
	"ST_NONE":                    1,
	"ST_TIME_NS":                 2,
	"ST_AGENT_UID":               100,
	"ST_ASID":                    101,
	"ST_UPID":                    200,
	"ST_SERVICE_NAME":            300,
	"ST_POD_NAME":                400,
	"ST_POD_PHASE":               401,
	"ST_POD_STATUS":              402,
	"ST_NODE_NAME":               500,
	"ST_CONTAINER_NAME":          600,
	"ST_CONTAINER_STATE":         601,
	"ST_CONTAINER_STATUS":        602,
	"ST_NAMESPACE_NAME":          700,
	"ST_BYTES":                   800,
	"ST_PERCENT":                 900,
	"ST_DURATION_NS":             901,
	"ST_THROUGHPUT_PER_NS":       902,
	"ST_THROUGHPUT_BYTES_PER_NS": 903,
	"ST_QUANTILES":               1000,
	"ST_DURATION_NS_QUANTILES":   1001,
	"ST_IP_ADDRESS":              1100,
	"ST_PORT":                    1200,
	"ST_HTTP_REQ_METHOD":         1300,
	"ST_HTTP_RESP_STATUS":        1400,
	"ST_HTTP_RESP_MESSAGE":       1500,
	"ST_SCRIPT_REFERENCE":        3000,
}

Functions

func RegisterVizierDebugServiceServer 

func RegisterVizierDebugServiceServer(s *grpc.Server, srv VizierDebugServiceServer)

func RegisterVizierServiceServer 

func RegisterVizierServiceServer(s *grpc.Server, srv VizierServiceServer)

Types

type BooleanColumn 

type BooleanColumn struct {
	Data []bool `protobuf:"varint,1,rep,packed,name=data,proto3" json:"data,omitempty"`
}

func (*BooleanColumn) Descriptor 

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

func (*BooleanColumn) Equal 

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

func (*BooleanColumn) GetData 

func (m *BooleanColumn) GetData() []bool

func (*BooleanColumn) GoString 

func (this *BooleanColumn) GoString() string

func (*BooleanColumn) Marshal 

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

func (*BooleanColumn) MarshalTo 

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

func (*BooleanColumn) MarshalToSizedBuffer 

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

func (*BooleanColumn) ProtoMessage 

func (*BooleanColumn) ProtoMessage()

func (*BooleanColumn) Reset 

func (m *BooleanColumn) Reset()

func (*BooleanColumn) Size 

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

func (*BooleanColumn) String 

func (this *BooleanColumn) String() string

func (*BooleanColumn) Unmarshal 

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

func (*BooleanColumn) XXX_DiscardUnknown 

func (m *BooleanColumn) XXX_DiscardUnknown()

func (*BooleanColumn) XXX_Marshal 

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

func (*BooleanColumn) XXX_Merge 

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

func (*BooleanColumn) XXX_Size 

func (m *BooleanColumn) XXX_Size() int

func (*BooleanColumn) XXX_Unmarshal 

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

type Column 

type Column struct {
	// Types that are valid to be assigned to ColData:
	//
	//	*Column_BooleanData
	//	*Column_Int64Data
	//	*Column_Uint128Data
	//	*Column_Time64NsData
	//	*Column_Float64Data
	//	*Column_StringData
	ColData isColumn_ColData `protobuf_oneof:"col_data"`
}

func (*Column) Descriptor 

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

func (*Column) Equal 

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

func (*Column) GetBooleanData 

func (m *Column) GetBooleanData() *BooleanColumn

func (*Column) GetColData 

func (m *Column) GetColData() isColumn_ColData

func (*Column) GetFloat64Data 

func (m *Column) GetFloat64Data() *Float64Column

func (*Column) GetInt64Data 

func (m *Column) GetInt64Data() *Int64Column

func (*Column) GetStringData 

func (m *Column) GetStringData() *StringColumn

func (*Column) GetTime64NsData 

func (m *Column) GetTime64NsData() *Time64NSColumn

func (*Column) GetUint128Data 

func (m *Column) GetUint128Data() *UInt128Column

func (*Column) GoString 

func (this *Column) GoString() string

func (*Column) Marshal 

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

func (*Column) MarshalTo 

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

func (*Column) MarshalToSizedBuffer 

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

func (*Column) ProtoMessage 

func (*Column) ProtoMessage()

func (*Column) Reset 

func (m *Column) Reset()

func (*Column) Size 

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

func (*Column) String 

func (this *Column) String() string

func (*Column) Unmarshal 

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

func (*Column) XXX_DiscardUnknown 

func (m *Column) XXX_DiscardUnknown()

func (*Column) XXX_Marshal 

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

func (*Column) XXX_Merge 

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

func (*Column) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*Column) XXX_Size 

func (m *Column) XXX_Size() int

func (*Column) XXX_Unmarshal 

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

type Column_BooleanData 

type Column_BooleanData struct {
	BooleanData *BooleanColumn `protobuf:"bytes,1,opt,name=boolean_data,json=booleanData,proto3,oneof" json:"boolean_data,omitempty"`
}

func (*Column_BooleanData) Equal 

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

func (*Column_BooleanData) GoString 

func (this *Column_BooleanData) GoString() string

func (*Column_BooleanData) MarshalTo 

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

func (*Column_BooleanData) MarshalToSizedBuffer 

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

func (*Column_BooleanData) Size 

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

func (*Column_BooleanData) String 

func (this *Column_BooleanData) String() string

type Column_Float64Data 

type Column_Float64Data struct {
	Float64Data *Float64Column `protobuf:"bytes,5,opt,name=float64_data,json=float64Data,proto3,oneof" json:"float64_data,omitempty"`
}

func (*Column_Float64Data) Equal 

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

func (*Column_Float64Data) GoString 

func (this *Column_Float64Data) GoString() string

func (*Column_Float64Data) MarshalTo 

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

func (*Column_Float64Data) MarshalToSizedBuffer 

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

func (*Column_Float64Data) Size 

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

func (*Column_Float64Data) String 

func (this *Column_Float64Data) String() string

type Column_Int64Data 

type Column_Int64Data struct {
	Int64Data *Int64Column `protobuf:"bytes,2,opt,name=int64_data,json=int64Data,proto3,oneof" json:"int64_data,omitempty"`
}

func (*Column_Int64Data) Equal 

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

func (*Column_Int64Data) GoString 

func (this *Column_Int64Data) GoString() string

func (*Column_Int64Data) MarshalTo 

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

func (*Column_Int64Data) MarshalToSizedBuffer 

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

func (*Column_Int64Data) Size 

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

func (*Column_Int64Data) String 

func (this *Column_Int64Data) String() string

type Column_StringData 

type Column_StringData struct {
	StringData *StringColumn `protobuf:"bytes,6,opt,name=string_data,json=stringData,proto3,oneof" json:"string_data,omitempty"`
}

func (*Column_StringData) Equal 

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

func (*Column_StringData) GoString 

func (this *Column_StringData) GoString() string

func (*Column_StringData) MarshalTo 

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

func (*Column_StringData) MarshalToSizedBuffer 

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

func (*Column_StringData) Size 

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

func (*Column_StringData) String 

func (this *Column_StringData) String() string

type Column_Time64NsData 

type Column_Time64NsData struct {
	Time64NsData *Time64NSColumn `protobuf:"bytes,4,opt,name=time64ns_data,json=time64nsData,proto3,oneof" json:"time64ns_data,omitempty"`
}

func (*Column_Time64NsData) Equal 

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

func (*Column_Time64NsData) GoString 

func (this *Column_Time64NsData) GoString() string

func (*Column_Time64NsData) MarshalTo 

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

func (*Column_Time64NsData) MarshalToSizedBuffer 

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

func (*Column_Time64NsData) Size 

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

func (*Column_Time64NsData) String 

func (this *Column_Time64NsData) String() string

type Column_Uint128Data 

type Column_Uint128Data struct {
	Uint128Data *UInt128Column `protobuf:"bytes,3,opt,name=uint128_data,json=uint128Data,proto3,oneof" json:"uint128_data,omitempty"`
}

func (*Column_Uint128Data) Equal 

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

func (*Column_Uint128Data) GoString 

func (this *Column_Uint128Data) GoString() string

func (*Column_Uint128Data) MarshalTo 

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

func (*Column_Uint128Data) MarshalToSizedBuffer 

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

func (*Column_Uint128Data) Size 

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

func (*Column_Uint128Data) String 

func (this *Column_Uint128Data) String() string

type CompilerError 

type CompilerError struct {
	Line    uint64 `protobuf:"varint,1,opt,name=line,proto3" json:"line,omitempty"`
	Column  uint64 `protobuf:"varint,2,opt,name=column,proto3" json:"column,omitempty"`
	Message string `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
}

func (*CompilerError) Descriptor 

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

func (*CompilerError) Equal 

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

func (*CompilerError) GetColumn 

func (m *CompilerError) GetColumn() uint64

func (*CompilerError) GetLine 

func (m *CompilerError) GetLine() uint64

func (*CompilerError) GetMessage 

func (m *CompilerError) GetMessage() string

func (*CompilerError) GoString 

func (this *CompilerError) GoString() string

func (*CompilerError) Marshal 

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

func (*CompilerError) MarshalTo 

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

func (*CompilerError) MarshalToSizedBuffer 

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

func (*CompilerError) ProtoMessage 

func (*CompilerError) ProtoMessage()

func (*CompilerError) Reset 

func (m *CompilerError) Reset()

func (*CompilerError) Size 

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

func (*CompilerError) String 

func (this *CompilerError) String() string

func (*CompilerError) Unmarshal 

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

func (*CompilerError) XXX_DiscardUnknown 

func (m *CompilerError) XXX_DiscardUnknown()

func (*CompilerError) XXX_Marshal 

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

func (*CompilerError) XXX_Merge 

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

func (*CompilerError) XXX_Size 

func (m *CompilerError) XXX_Size() int

func (*CompilerError) XXX_Unmarshal 

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

type Configs added in v0.3.0 

type Configs struct {
	OTelEndpointConfig *Configs_OTelEndpointConfig `protobuf:"bytes,1,opt,name=otel_endpoint_config,json=otelEndpointConfig,proto3" json:"otel_endpoint_config,omitempty"`
	PluginConfig       *Configs_PluginConfig       `protobuf:"bytes,2,opt,name=plugin_config,json=pluginConfig,proto3" json:"plugin_config,omitempty"`
}

func (*Configs) Descriptor added in v0.3.0 

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

func (*Configs) Equal added in v0.3.0 

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

func (*Configs) GetOTelEndpointConfig added in v0.3.0 

func (m *Configs) GetOTelEndpointConfig() *Configs_OTelEndpointConfig

func (*Configs) GetPluginConfig added in v0.3.1 

func (m *Configs) GetPluginConfig() *Configs_PluginConfig

func (*Configs) GoString added in v0.3.0 

func (this *Configs) GoString() string

func (*Configs) Marshal added in v0.3.0 

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

func (*Configs) MarshalTo added in v0.3.0 

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

func (*Configs) MarshalToSizedBuffer added in v0.3.0 

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

func (*Configs) ProtoMessage added in v0.3.0 

func (*Configs) ProtoMessage()

func (*Configs) Reset added in v0.3.0 

func (m *Configs) Reset()

func (*Configs) Size added in v0.3.0 

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

func (*Configs) String added in v0.3.0 

func (this *Configs) String() string

func (*Configs) Unmarshal added in v0.3.0 

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

func (*Configs) XXX_DiscardUnknown added in v0.3.0 

func (m *Configs) XXX_DiscardUnknown()

func (*Configs) XXX_Marshal added in v0.3.0 

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

func (*Configs) XXX_Merge added in v0.3.0 

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

func (*Configs) XXX_Size added in v0.3.0 

func (m *Configs) XXX_Size() int

func (*Configs) XXX_Unmarshal added in v0.3.0 

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

type Configs_OTelEndpointConfig added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) Descriptor added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) Equal added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) GetHeaders added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) GetInsecure added in v0.3.1 

func (m *Configs_OTelEndpointConfig) GetInsecure() bool

func (*Configs_OTelEndpointConfig) GetURL added in v0.3.0 

func (m *Configs_OTelEndpointConfig) GetURL() string

func (*Configs_OTelEndpointConfig) GoString added in v0.3.0 

func (this *Configs_OTelEndpointConfig) GoString() string

func (*Configs_OTelEndpointConfig) Marshal added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) MarshalTo added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) MarshalToSizedBuffer added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) ProtoMessage added in v0.3.0 

func (*Configs_OTelEndpointConfig) ProtoMessage()

func (*Configs_OTelEndpointConfig) Reset added in v0.3.0 

func (m *Configs_OTelEndpointConfig) Reset()

func (*Configs_OTelEndpointConfig) Size added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) String added in v0.3.0 

func (this *Configs_OTelEndpointConfig) String() string

func (*Configs_OTelEndpointConfig) Unmarshal added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) XXX_DiscardUnknown added in v0.3.0 

func (m *Configs_OTelEndpointConfig) XXX_DiscardUnknown()

func (*Configs_OTelEndpointConfig) XXX_Marshal added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) XXX_Merge added in v0.3.0 

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

func (*Configs_OTelEndpointConfig) XXX_Size added in v0.3.0 

func (m *Configs_OTelEndpointConfig) XXX_Size() int

func (*Configs_OTelEndpointConfig) XXX_Unmarshal added in v0.3.0 

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

type Configs_PluginConfig added in v0.3.1 

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

func (*Configs_PluginConfig) Descriptor added in v0.3.1 

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

func (*Configs_PluginConfig) Equal added in v0.3.1 

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

func (*Configs_PluginConfig) GetEndTimeNs added in v0.4.0 

func (m *Configs_PluginConfig) GetEndTimeNs() int64

func (*Configs_PluginConfig) GetStartTimeNs added in v0.3.1 

func (m *Configs_PluginConfig) GetStartTimeNs() int64

func (*Configs_PluginConfig) GoString added in v0.3.1 

func (this *Configs_PluginConfig) GoString() string

func (*Configs_PluginConfig) Marshal added in v0.3.1 

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

func (*Configs_PluginConfig) MarshalTo added in v0.3.1 

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

func (*Configs_PluginConfig) MarshalToSizedBuffer added in v0.3.1 

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

func (*Configs_PluginConfig) ProtoMessage added in v0.3.1 

func (*Configs_PluginConfig) ProtoMessage()

func (*Configs_PluginConfig) Reset added in v0.3.1 

func (m *Configs_PluginConfig) Reset()

func (*Configs_PluginConfig) Size added in v0.3.1 

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

func (*Configs_PluginConfig) String added in v0.3.1 

func (this *Configs_PluginConfig) String() string

func (*Configs_PluginConfig) Unmarshal added in v0.3.1 

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

func (*Configs_PluginConfig) XXX_DiscardUnknown added in v0.3.1 

func (m *Configs_PluginConfig) XXX_DiscardUnknown()

func (*Configs_PluginConfig) XXX_Marshal added in v0.3.1 

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

func (*Configs_PluginConfig) XXX_Merge added in v0.3.1 

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

func (*Configs_PluginConfig) XXX_Size added in v0.3.1 

func (m *Configs_PluginConfig) XXX_Size() int

func (*Configs_PluginConfig) XXX_Unmarshal added in v0.3.1 

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

type ContainerState 

type ContainerState int32
const (
	CONTAINER_STATE_UNKNOWN    ContainerState = 0
	CONTAINER_STATE_RUNNING    ContainerState = 1
	CONTAINER_STATE_TERMINATED ContainerState = 2
	CONTAINER_STATE_WAITING    ContainerState = 3
)

func (ContainerState) EnumDescriptor 

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

func (ContainerState) String 

func (x ContainerState) String() string

type ContainerStatus 

type ContainerStatus struct {
	Name             string         `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	ContainerState   ContainerState `` /* 140-byte string literal not displayed */
	Message          string         `protobuf:"bytes,3,opt,name=message,proto3" json:"message,omitempty"`
	Reason           string         `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	StartTimestampNS int64          `protobuf:"varint,5,opt,name=start_timestamp_ns,json=startTimestampNs,proto3" json:"start_timestamp_ns,omitempty"`
	RestartCount     int64          `protobuf:"varint,6,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) GetContainerState 

func (m *ContainerStatus) GetContainerState() ContainerState

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 added in v0.2.0 

func (m *ContainerStatus) GetRestartCount() int64

func (*ContainerStatus) GetStartTimestampNS 

func (m *ContainerStatus) GetStartTimestampNS() int64

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 DataType 

type DataType int32
const (
	DATA_TYPE_UNKNOWN DataType = 0
	BOOLEAN           DataType = 1
	INT64             DataType = 2
	UINT128           DataType = 3
	FLOAT64           DataType = 4
	STRING            DataType = 5
	TIME64NS          DataType = 6
)

func (DataType) EnumDescriptor 

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

func (DataType) String 

func (x DataType) String() string

type DebugLogRequest 

type DebugLogRequest struct {
	ClusterID string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	PodName   string `protobuf:"bytes,2,opt,name=pod_name,json=podName,proto3" json:"pod_name,omitempty"`
	Previous  bool   `protobuf:"varint,3,opt,name=previous,proto3" json:"previous,omitempty"`
	Container string `protobuf:"bytes,4,opt,name=container,proto3" json:"container,omitempty"`
}

func (*DebugLogRequest) Descriptor 

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

func (*DebugLogRequest) Equal 

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

func (*DebugLogRequest) GetClusterID 

func (m *DebugLogRequest) GetClusterID() string

func (*DebugLogRequest) GetContainer 

func (m *DebugLogRequest) GetContainer() string

func (*DebugLogRequest) GetPodName 

func (m *DebugLogRequest) GetPodName() string

func (*DebugLogRequest) GetPrevious 

func (m *DebugLogRequest) GetPrevious() bool

func (*DebugLogRequest) GoString 

func (this *DebugLogRequest) GoString() string

func (*DebugLogRequest) Marshal 

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

func (*DebugLogRequest) MarshalTo 

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

func (*DebugLogRequest) MarshalToSizedBuffer 

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

func (*DebugLogRequest) ProtoMessage 

func (*DebugLogRequest) ProtoMessage()

func (*DebugLogRequest) Reset 

func (m *DebugLogRequest) Reset()

func (*DebugLogRequest) Size 

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

func (*DebugLogRequest) String 

func (this *DebugLogRequest) String() string

func (*DebugLogRequest) Unmarshal 

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

func (*DebugLogRequest) XXX_DiscardUnknown 

func (m *DebugLogRequest) XXX_DiscardUnknown()

func (*DebugLogRequest) XXX_Marshal 

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

func (*DebugLogRequest) XXX_Merge 

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

func (*DebugLogRequest) XXX_Size 

func (m *DebugLogRequest) XXX_Size() int

func (*DebugLogRequest) XXX_Unmarshal 

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

type DebugLogResponse 

type DebugLogResponse struct {
	Data string `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
}

func (*DebugLogResponse) Descriptor 

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

func (*DebugLogResponse) Equal 

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

func (*DebugLogResponse) GetData 

func (m *DebugLogResponse) GetData() string

func (*DebugLogResponse) GoString 

func (this *DebugLogResponse) GoString() string

func (*DebugLogResponse) Marshal 

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

func (*DebugLogResponse) MarshalTo 

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

func (*DebugLogResponse) MarshalToSizedBuffer 

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

func (*DebugLogResponse) ProtoMessage 

func (*DebugLogResponse) ProtoMessage()

func (*DebugLogResponse) Reset 

func (m *DebugLogResponse) Reset()

func (*DebugLogResponse) Size 

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

func (*DebugLogResponse) String 

func (this *DebugLogResponse) String() string

func (*DebugLogResponse) Unmarshal 

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

func (*DebugLogResponse) XXX_DiscardUnknown 

func (m *DebugLogResponse) XXX_DiscardUnknown()

func (*DebugLogResponse) XXX_Marshal 

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

func (*DebugLogResponse) XXX_Merge 

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

func (*DebugLogResponse) XXX_Size 

func (m *DebugLogResponse) XXX_Size() int

func (*DebugLogResponse) XXX_Unmarshal 

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

type DebugPodsRequest 

type DebugPodsRequest struct {
	ClusterID string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
}

func (*DebugPodsRequest) Descriptor 

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

func (*DebugPodsRequest) Equal 

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

func (*DebugPodsRequest) GetClusterID 

func (m *DebugPodsRequest) GetClusterID() string

func (*DebugPodsRequest) GoString 

func (this *DebugPodsRequest) GoString() string

func (*DebugPodsRequest) Marshal 

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

func (*DebugPodsRequest) MarshalTo 

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

func (*DebugPodsRequest) MarshalToSizedBuffer 

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

func (*DebugPodsRequest) ProtoMessage 

func (*DebugPodsRequest) ProtoMessage()

func (*DebugPodsRequest) Reset 

func (m *DebugPodsRequest) Reset()

func (*DebugPodsRequest) Size 

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

func (*DebugPodsRequest) String 

func (this *DebugPodsRequest) String() string

func (*DebugPodsRequest) Unmarshal 

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

func (*DebugPodsRequest) XXX_DiscardUnknown 

func (m *DebugPodsRequest) XXX_DiscardUnknown()

func (*DebugPodsRequest) XXX_Marshal 

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

func (*DebugPodsRequest) XXX_Merge 

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

func (*DebugPodsRequest) XXX_Size 

func (m *DebugPodsRequest) XXX_Size() int

func (*DebugPodsRequest) XXX_Unmarshal 

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

type DebugPodsResponse 

type DebugPodsResponse struct {
	DataPlanePods    []*VizierPodStatus `protobuf:"bytes,1,rep,name=data_plane_pods,json=dataPlanePods,proto3" json:"data_plane_pods,omitempty"`
	ControlPlanePods []*VizierPodStatus `protobuf:"bytes,2,rep,name=control_plane_pods,json=controlPlanePods,proto3" json:"control_plane_pods,omitempty"`
}

func (*DebugPodsResponse) Descriptor 

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

func (*DebugPodsResponse) Equal 

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

func (*DebugPodsResponse) GetControlPlanePods 

func (m *DebugPodsResponse) GetControlPlanePods() []*VizierPodStatus

func (*DebugPodsResponse) GetDataPlanePods 

func (m *DebugPodsResponse) GetDataPlanePods() []*VizierPodStatus

func (*DebugPodsResponse) GoString 

func (this *DebugPodsResponse) GoString() string

func (*DebugPodsResponse) Marshal 

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

func (*DebugPodsResponse) MarshalTo 

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

func (*DebugPodsResponse) MarshalToSizedBuffer 

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

func (*DebugPodsResponse) ProtoMessage 

func (*DebugPodsResponse) ProtoMessage()

func (*DebugPodsResponse) Reset 

func (m *DebugPodsResponse) Reset()

func (*DebugPodsResponse) Size 

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

func (*DebugPodsResponse) String 

func (this *DebugPodsResponse) String() string

func (*DebugPodsResponse) Unmarshal 

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

func (*DebugPodsResponse) XXX_DiscardUnknown 

func (m *DebugPodsResponse) XXX_DiscardUnknown()

func (*DebugPodsResponse) XXX_Marshal 

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

func (*DebugPodsResponse) XXX_Merge 

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

func (*DebugPodsResponse) XXX_Size 

func (m *DebugPodsResponse) XXX_Size() int

func (*DebugPodsResponse) XXX_Unmarshal 

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

type ErrorDetails 

type ErrorDetails struct {
	// Types that are valid to be assigned to Error:
	//
	//	*ErrorDetails_CompilerError
	Error isErrorDetails_Error `protobuf_oneof:"error"`
}

func (*ErrorDetails) Descriptor 

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

func (*ErrorDetails) Equal 

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

func (*ErrorDetails) GetCompilerError 

func (m *ErrorDetails) GetCompilerError() *CompilerError

func (*ErrorDetails) GetError 

func (m *ErrorDetails) GetError() isErrorDetails_Error

func (*ErrorDetails) GoString 

func (this *ErrorDetails) GoString() string

func (*ErrorDetails) Marshal 

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

func (*ErrorDetails) MarshalTo 

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

func (*ErrorDetails) MarshalToSizedBuffer 

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

func (*ErrorDetails) ProtoMessage 

func (*ErrorDetails) ProtoMessage()

func (*ErrorDetails) Reset 

func (m *ErrorDetails) Reset()

func (*ErrorDetails) Size 

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

func (*ErrorDetails) String 

func (this *ErrorDetails) String() string

func (*ErrorDetails) Unmarshal 

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

func (*ErrorDetails) XXX_DiscardUnknown 

func (m *ErrorDetails) XXX_DiscardUnknown()

func (*ErrorDetails) XXX_Marshal 

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

func (*ErrorDetails) XXX_Merge 

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

func (*ErrorDetails) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ErrorDetails) XXX_Size 

func (m *ErrorDetails) XXX_Size() int

func (*ErrorDetails) XXX_Unmarshal 

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

type ErrorDetails_CompilerError 

type ErrorDetails_CompilerError struct {
	CompilerError *CompilerError `protobuf:"bytes,1,opt,name=compiler_error,json=compilerError,proto3,oneof" json:"compiler_error,omitempty"`
}

func (*ErrorDetails_CompilerError) Equal 

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

func (*ErrorDetails_CompilerError) GoString 

func (this *ErrorDetails_CompilerError) GoString() string

func (*ErrorDetails_CompilerError) MarshalTo 

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

func (*ErrorDetails_CompilerError) MarshalToSizedBuffer 

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

func (*ErrorDetails_CompilerError) Size 

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

func (*ErrorDetails_CompilerError) String 

func (this *ErrorDetails_CompilerError) String() string

type ExecuteScriptRequest 

type ExecuteScriptRequest struct {
	QueryStr          string                                  `protobuf:"bytes,1,opt,name=query_str,json=queryStr,proto3" json:"query_str,omitempty"`
	ClusterID         string                                  `protobuf:"bytes,3,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
	ExecFuncs         []*ExecuteScriptRequest_FuncToExecute   `protobuf:"bytes,4,rep,name=exec_funcs,json=execFuncs,proto3" json:"exec_funcs,omitempty"`
	Mutation          bool                                    `protobuf:"varint,5,opt,name=mutation,proto3" json:"mutation,omitempty"`
	EncryptionOptions *ExecuteScriptRequest_EncryptionOptions `protobuf:"bytes,6,opt,name=encryption_options,json=encryptionOptions,proto3" json:"encryption_options,omitempty"`
	QueryID           string                                  `protobuf:"bytes,7,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	Configs           *Configs                                `protobuf:"bytes,9,opt,name=configs,proto3" json:"configs,omitempty"`
	QueryName         string                                  `protobuf:"bytes,10,opt,name=query_name,json=queryName,proto3" json:"query_name,omitempty"`
}

func (*ExecuteScriptRequest) Descriptor 

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

func (*ExecuteScriptRequest) Equal 

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

func (*ExecuteScriptRequest) GetClusterID 

func (m *ExecuteScriptRequest) GetClusterID() string

func (*ExecuteScriptRequest) GetConfigs added in v0.3.0 

func (m *ExecuteScriptRequest) GetConfigs() *Configs

func (*ExecuteScriptRequest) GetEncryptionOptions added in v0.2.0 

func (m *ExecuteScriptRequest) GetEncryptionOptions() *ExecuteScriptRequest_EncryptionOptions

func (*ExecuteScriptRequest) GetExecFuncs 

func (m *ExecuteScriptRequest) GetExecFuncs() []*ExecuteScriptRequest_FuncToExecute

func (*ExecuteScriptRequest) GetMutation 

func (m *ExecuteScriptRequest) GetMutation() bool

func (*ExecuteScriptRequest) GetQueryID added in v0.2.0 

func (m *ExecuteScriptRequest) GetQueryID() string

func (*ExecuteScriptRequest) GetQueryName added in v0.3.1 

func (m *ExecuteScriptRequest) GetQueryName() string

func (*ExecuteScriptRequest) GetQueryStr 

func (m *ExecuteScriptRequest) GetQueryStr() string

func (*ExecuteScriptRequest) GoString 

func (this *ExecuteScriptRequest) GoString() string

func (*ExecuteScriptRequest) Marshal 

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

func (*ExecuteScriptRequest) MarshalTo 

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

func (*ExecuteScriptRequest) MarshalToSizedBuffer 

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

func (*ExecuteScriptRequest) ProtoMessage 

func (*ExecuteScriptRequest) ProtoMessage()

func (*ExecuteScriptRequest) Reset 

func (m *ExecuteScriptRequest) Reset()

func (*ExecuteScriptRequest) Size 

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

func (*ExecuteScriptRequest) String 

func (this *ExecuteScriptRequest) String() string

func (*ExecuteScriptRequest) Unmarshal 

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

func (*ExecuteScriptRequest) XXX_DiscardUnknown 

func (m *ExecuteScriptRequest) XXX_DiscardUnknown()

func (*ExecuteScriptRequest) XXX_Marshal 

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

func (*ExecuteScriptRequest) XXX_Merge 

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

func (*ExecuteScriptRequest) XXX_Size 

func (m *ExecuteScriptRequest) XXX_Size() int

func (*ExecuteScriptRequest) XXX_Unmarshal 

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

type ExecuteScriptRequest_EncryptionOptions added in v0.2.0 

type ExecuteScriptRequest_EncryptionOptions struct {
	JwkKey         string `protobuf:"bytes,1,opt,name=jwk_key,json=jwkKey,proto3" json:"jwk_key,omitempty"`
	KeyAlg         string `protobuf:"bytes,2,opt,name=key_alg,json=keyAlg,proto3" json:"key_alg,omitempty"`
	ContentAlg     string `protobuf:"bytes,3,opt,name=content_alg,json=contentAlg,proto3" json:"content_alg,omitempty"`
	CompressionAlg string `protobuf:"bytes,4,opt,name=compression_alg,json=compressionAlg,proto3" json:"compression_alg,omitempty"`
}

func (*ExecuteScriptRequest_EncryptionOptions) Descriptor added in v0.2.0 

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

func (*ExecuteScriptRequest_EncryptionOptions) Equal added in v0.2.0 

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

func (*ExecuteScriptRequest_EncryptionOptions) GetCompressionAlg added in v0.2.0 

func (m *ExecuteScriptRequest_EncryptionOptions) GetCompressionAlg() string

func (*ExecuteScriptRequest_EncryptionOptions) GetContentAlg added in v0.2.0 

func (m *ExecuteScriptRequest_EncryptionOptions) GetContentAlg() string

func (*ExecuteScriptRequest_EncryptionOptions) GetJwkKey added in v0.2.0 

func (m *ExecuteScriptRequest_EncryptionOptions) GetJwkKey() string

func (*ExecuteScriptRequest_EncryptionOptions) GetKeyAlg added in v0.2.0 

func (m *ExecuteScriptRequest_EncryptionOptions) GetKeyAlg() string

func (*ExecuteScriptRequest_EncryptionOptions) GoString added in v0.2.0 

func (this *ExecuteScriptRequest_EncryptionOptions) GoString() string

func (*ExecuteScriptRequest_EncryptionOptions) Marshal added in v0.2.0 

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

func (*ExecuteScriptRequest_EncryptionOptions) MarshalTo added in v0.2.0 

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

func (*ExecuteScriptRequest_EncryptionOptions) MarshalToSizedBuffer added in v0.2.0 

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

func (*ExecuteScriptRequest_EncryptionOptions) ProtoMessage added in v0.2.0 

func (*ExecuteScriptRequest_EncryptionOptions) ProtoMessage()

func (*ExecuteScriptRequest_EncryptionOptions) Reset added in v0.2.0 

func (m *ExecuteScriptRequest_EncryptionOptions) Reset()

func (*ExecuteScriptRequest_EncryptionOptions) Size added in v0.2.0 

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

func (*ExecuteScriptRequest_EncryptionOptions) String added in v0.2.0 

func (this *ExecuteScriptRequest_EncryptionOptions) String() string

func (*ExecuteScriptRequest_EncryptionOptions) Unmarshal added in v0.2.0 

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

func (*ExecuteScriptRequest_EncryptionOptions) XXX_DiscardUnknown added in v0.2.0 

func (m *ExecuteScriptRequest_EncryptionOptions) XXX_DiscardUnknown()

func (*ExecuteScriptRequest_EncryptionOptions) XXX_Marshal added in v0.2.0 

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

func (*ExecuteScriptRequest_EncryptionOptions) XXX_Merge added in v0.2.0 

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

func (*ExecuteScriptRequest_EncryptionOptions) XXX_Size added in v0.2.0 

func (m *ExecuteScriptRequest_EncryptionOptions) XXX_Size() int

func (*ExecuteScriptRequest_EncryptionOptions) XXX_Unmarshal added in v0.2.0 

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

type ExecuteScriptRequest_FuncToExecute 

type ExecuteScriptRequest_FuncToExecute struct {
	FuncName          string                                         `protobuf:"bytes,1,opt,name=func_name,json=funcName,proto3" json:"func_name,omitempty"`
	ArgValues         []*ExecuteScriptRequest_FuncToExecute_ArgValue `protobuf:"bytes,2,rep,name=arg_values,json=argValues,proto3" json:"arg_values,omitempty"`
	OutputTablePrefix string                                         `protobuf:"bytes,3,opt,name=output_table_prefix,json=outputTablePrefix,proto3" json:"output_table_prefix,omitempty"`
}

func (*ExecuteScriptRequest_FuncToExecute) Descriptor 

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

func (*ExecuteScriptRequest_FuncToExecute) Equal 

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

func (*ExecuteScriptRequest_FuncToExecute) GetArgValues 

func (m *ExecuteScriptRequest_FuncToExecute) GetArgValues() []*ExecuteScriptRequest_FuncToExecute_ArgValue

func (*ExecuteScriptRequest_FuncToExecute) GetFuncName 

func (m *ExecuteScriptRequest_FuncToExecute) GetFuncName() string

func (*ExecuteScriptRequest_FuncToExecute) GetOutputTablePrefix 

func (m *ExecuteScriptRequest_FuncToExecute) GetOutputTablePrefix() string

func (*ExecuteScriptRequest_FuncToExecute) GoString 

func (this *ExecuteScriptRequest_FuncToExecute) GoString() string

func (*ExecuteScriptRequest_FuncToExecute) Marshal 

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

func (*ExecuteScriptRequest_FuncToExecute) MarshalTo 

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

func (*ExecuteScriptRequest_FuncToExecute) MarshalToSizedBuffer 

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

func (*ExecuteScriptRequest_FuncToExecute) ProtoMessage 

func (*ExecuteScriptRequest_FuncToExecute) ProtoMessage()

func (*ExecuteScriptRequest_FuncToExecute) Reset 

func (m *ExecuteScriptRequest_FuncToExecute) Reset()

func (*ExecuteScriptRequest_FuncToExecute) Size 

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

func (*ExecuteScriptRequest_FuncToExecute) String 

func (this *ExecuteScriptRequest_FuncToExecute) String() string

func (*ExecuteScriptRequest_FuncToExecute) Unmarshal 

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

func (*ExecuteScriptRequest_FuncToExecute) XXX_DiscardUnknown 

func (m *ExecuteScriptRequest_FuncToExecute) XXX_DiscardUnknown()

func (*ExecuteScriptRequest_FuncToExecute) XXX_Marshal 

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

func (*ExecuteScriptRequest_FuncToExecute) XXX_Merge 

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

func (*ExecuteScriptRequest_FuncToExecute) XXX_Size 

func (m *ExecuteScriptRequest_FuncToExecute) XXX_Size() int

func (*ExecuteScriptRequest_FuncToExecute) XXX_Unmarshal 

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

type ExecuteScriptRequest_FuncToExecute_ArgValue 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) Descriptor 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) Equal 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) GetName 

func (m *ExecuteScriptRequest_FuncToExecute_ArgValue) GetName() string

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) GetValue 

func (m *ExecuteScriptRequest_FuncToExecute_ArgValue) GetValue() string

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) GoString 

func (this *ExecuteScriptRequest_FuncToExecute_ArgValue) GoString() string

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) Marshal 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) MarshalTo 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) MarshalToSizedBuffer 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) ProtoMessage 

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) ProtoMessage()

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) Reset 

func (m *ExecuteScriptRequest_FuncToExecute_ArgValue) Reset()

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) Size 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) String 

func (this *ExecuteScriptRequest_FuncToExecute_ArgValue) String() string

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) Unmarshal 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) XXX_DiscardUnknown 

func (m *ExecuteScriptRequest_FuncToExecute_ArgValue) XXX_DiscardUnknown()

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) XXX_Marshal 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) XXX_Merge 

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

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) XXX_Size 

func (m *ExecuteScriptRequest_FuncToExecute_ArgValue) XXX_Size() int

func (*ExecuteScriptRequest_FuncToExecute_ArgValue) XXX_Unmarshal 

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

type ExecuteScriptResponse 

type ExecuteScriptResponse struct {
	Status  *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	QueryID string  `protobuf:"bytes,2,opt,name=query_id,json=queryId,proto3" json:"query_id,omitempty"`
	// Types that are valid to be assigned to Result:
	//
	//	*ExecuteScriptResponse_Data
	//	*ExecuteScriptResponse_MetaData
	Result       isExecuteScriptResponse_Result `protobuf_oneof:"result"`
	MutationInfo *MutationInfo                  `protobuf:"bytes,5,opt,name=mutation_info,json=mutationInfo,proto3" json:"mutation_info,omitempty"`
}

func (*ExecuteScriptResponse) Descriptor 

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

func (*ExecuteScriptResponse) Equal 

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

func (*ExecuteScriptResponse) GetData 

func (m *ExecuteScriptResponse) GetData() *QueryData

func (*ExecuteScriptResponse) GetMetaData 

func (m *ExecuteScriptResponse) GetMetaData() *QueryMetadata

func (*ExecuteScriptResponse) GetMutationInfo 

func (m *ExecuteScriptResponse) GetMutationInfo() *MutationInfo

func (*ExecuteScriptResponse) GetQueryID 

func (m *ExecuteScriptResponse) GetQueryID() string

func (*ExecuteScriptResponse) GetResult 

func (m *ExecuteScriptResponse) GetResult() isExecuteScriptResponse_Result

func (*ExecuteScriptResponse) GetStatus 

func (m *ExecuteScriptResponse) GetStatus() *Status

func (*ExecuteScriptResponse) GoString 

func (this *ExecuteScriptResponse) GoString() string

func (*ExecuteScriptResponse) Marshal 

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

func (*ExecuteScriptResponse) MarshalTo 

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

func (*ExecuteScriptResponse) MarshalToSizedBuffer 

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

func (*ExecuteScriptResponse) ProtoMessage 

func (*ExecuteScriptResponse) ProtoMessage()

func (*ExecuteScriptResponse) Reset 

func (m *ExecuteScriptResponse) Reset()

func (*ExecuteScriptResponse) Size 

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

func (*ExecuteScriptResponse) String 

func (this *ExecuteScriptResponse) String() string

func (*ExecuteScriptResponse) Unmarshal 

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

func (*ExecuteScriptResponse) XXX_DiscardUnknown 

func (m *ExecuteScriptResponse) XXX_DiscardUnknown()

func (*ExecuteScriptResponse) XXX_Marshal 

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

func (*ExecuteScriptResponse) XXX_Merge 

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

func (*ExecuteScriptResponse) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ExecuteScriptResponse) XXX_Size 

func (m *ExecuteScriptResponse) XXX_Size() int

func (*ExecuteScriptResponse) XXX_Unmarshal 

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

type ExecuteScriptResponse_Data 

type ExecuteScriptResponse_Data struct {
	Data *QueryData `protobuf:"bytes,3,opt,name=data,proto3,oneof" json:"data,omitempty"`
}

func (*ExecuteScriptResponse_Data) Equal 

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

func (*ExecuteScriptResponse_Data) GoString 

func (this *ExecuteScriptResponse_Data) GoString() string

func (*ExecuteScriptResponse_Data) MarshalTo 

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

func (*ExecuteScriptResponse_Data) MarshalToSizedBuffer 

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

func (*ExecuteScriptResponse_Data) Size 

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

func (*ExecuteScriptResponse_Data) String 

func (this *ExecuteScriptResponse_Data) String() string

type ExecuteScriptResponse_MetaData 

type ExecuteScriptResponse_MetaData struct {
	MetaData *QueryMetadata `protobuf:"bytes,4,opt,name=meta_data,json=metaData,proto3,oneof" json:"meta_data,omitempty"`
}

func (*ExecuteScriptResponse_MetaData) Equal 

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

func (*ExecuteScriptResponse_MetaData) GoString 

func (this *ExecuteScriptResponse_MetaData) GoString() string

func (*ExecuteScriptResponse_MetaData) MarshalTo 

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

func (*ExecuteScriptResponse_MetaData) MarshalToSizedBuffer 

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

func (*ExecuteScriptResponse_MetaData) Size 

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

func (*ExecuteScriptResponse_MetaData) String 

func (this *ExecuteScriptResponse_MetaData) String() string

type Float64Column 

type Float64Column struct {
	Data []float64 `protobuf:"fixed64,1,rep,packed,name=data,proto3" json:"data,omitempty"`
}

func (*Float64Column) Descriptor 

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

func (*Float64Column) Equal 

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

func (*Float64Column) GetData 

func (m *Float64Column) GetData() []float64

func (*Float64Column) GoString 

func (this *Float64Column) GoString() string

func (*Float64Column) Marshal 

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

func (*Float64Column) MarshalTo 

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

func (*Float64Column) MarshalToSizedBuffer 

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

func (*Float64Column) ProtoMessage 

func (*Float64Column) ProtoMessage()

func (*Float64Column) Reset 

func (m *Float64Column) Reset()

func (*Float64Column) Size 

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

func (*Float64Column) String 

func (this *Float64Column) String() string

func (*Float64Column) Unmarshal 

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

func (*Float64Column) XXX_DiscardUnknown 

func (m *Float64Column) XXX_DiscardUnknown()

func (*Float64Column) XXX_Marshal 

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

func (*Float64Column) XXX_Merge 

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

func (*Float64Column) XXX_Size 

func (m *Float64Column) XXX_Size() int

func (*Float64Column) XXX_Unmarshal 

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

type HealthCheckRequest 

type HealthCheckRequest struct {
	ClusterID string `protobuf:"bytes,1,opt,name=cluster_id,json=clusterId,proto3" json:"cluster_id,omitempty"`
}

func (*HealthCheckRequest) Descriptor 

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

func (*HealthCheckRequest) Equal 

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

func (*HealthCheckRequest) GetClusterID 

func (m *HealthCheckRequest) GetClusterID() string

func (*HealthCheckRequest) GoString 

func (this *HealthCheckRequest) GoString() string

func (*HealthCheckRequest) Marshal 

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

func (*HealthCheckRequest) MarshalTo 

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

func (*HealthCheckRequest) MarshalToSizedBuffer 

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

func (*HealthCheckRequest) ProtoMessage 

func (*HealthCheckRequest) ProtoMessage()

func (*HealthCheckRequest) Reset 

func (m *HealthCheckRequest) Reset()

func (*HealthCheckRequest) Size 

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

func (*HealthCheckRequest) String 

func (this *HealthCheckRequest) String() string

func (*HealthCheckRequest) Unmarshal 

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

func (*HealthCheckRequest) XXX_DiscardUnknown 

func (m *HealthCheckRequest) XXX_DiscardUnknown()

func (*HealthCheckRequest) XXX_Marshal 

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

func (*HealthCheckRequest) XXX_Merge 

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

func (*HealthCheckRequest) XXX_Size 

func (m *HealthCheckRequest) XXX_Size() int

func (*HealthCheckRequest) XXX_Unmarshal 

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

type HealthCheckResponse 

type HealthCheckResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
}

func (*HealthCheckResponse) Descriptor 

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

func (*HealthCheckResponse) Equal 

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

func (*HealthCheckResponse) GetStatus 

func (m *HealthCheckResponse) GetStatus() *Status

func (*HealthCheckResponse) GoString 

func (this *HealthCheckResponse) GoString() string

func (*HealthCheckResponse) Marshal 

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

func (*HealthCheckResponse) MarshalTo 

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

func (*HealthCheckResponse) MarshalToSizedBuffer 

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

func (*HealthCheckResponse) ProtoMessage 

func (*HealthCheckResponse) ProtoMessage()

func (*HealthCheckResponse) Reset 

func (m *HealthCheckResponse) Reset()

func (*HealthCheckResponse) Size 

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

func (*HealthCheckResponse) String 

func (this *HealthCheckResponse) String() string

func (*HealthCheckResponse) Unmarshal 

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

func (*HealthCheckResponse) XXX_DiscardUnknown 

func (m *HealthCheckResponse) XXX_DiscardUnknown()

func (*HealthCheckResponse) XXX_Marshal 

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

func (*HealthCheckResponse) XXX_Merge 

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

func (*HealthCheckResponse) XXX_Size 

func (m *HealthCheckResponse) XXX_Size() int

func (*HealthCheckResponse) XXX_Unmarshal 

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

type Int64Column 

type Int64Column struct {
	Data []int64 `protobuf:"varint,1,rep,packed,name=data,proto3" json:"data,omitempty"`
}

func (*Int64Column) Descriptor 

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

func (*Int64Column) Equal 

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

func (*Int64Column) GetData 

func (m *Int64Column) GetData() []int64

func (*Int64Column) GoString 

func (this *Int64Column) GoString() string

func (*Int64Column) Marshal 

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

func (*Int64Column) MarshalTo 

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

func (*Int64Column) MarshalToSizedBuffer 

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

func (*Int64Column) ProtoMessage 

func (*Int64Column) ProtoMessage()

func (*Int64Column) Reset 

func (m *Int64Column) Reset()

func (*Int64Column) Size 

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

func (*Int64Column) String 

func (this *Int64Column) String() string

func (*Int64Column) Unmarshal 

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

func (*Int64Column) XXX_DiscardUnknown 

func (m *Int64Column) XXX_DiscardUnknown()

func (*Int64Column) XXX_Marshal 

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

func (*Int64Column) XXX_Merge 

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

func (*Int64Column) XXX_Size 

func (m *Int64Column) XXX_Size() int

func (*Int64Column) XXX_Unmarshal 

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

type LifeCycleState 

type LifeCycleState int32
const (
	UNKNOWN_STATE    LifeCycleState = 0
	PENDING_STATE    LifeCycleState = 1
	RUNNING_STATE    LifeCycleState = 2
	FAILED_STATE     LifeCycleState = 3
	TERMINATED_STATE LifeCycleState = 4
)

func (LifeCycleState) EnumDescriptor 

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

func (LifeCycleState) String 

func (x LifeCycleState) String() string

type MutationInfo 

type MutationInfo struct {
	Status *Status                       `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	States []*MutationInfo_MutationState `protobuf:"bytes,2,rep,name=states,proto3" json:"states,omitempty"`
}

func (*MutationInfo) Descriptor 

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

func (*MutationInfo) Equal 

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

func (*MutationInfo) GetStates 

func (m *MutationInfo) GetStates() []*MutationInfo_MutationState

func (*MutationInfo) GetStatus 

func (m *MutationInfo) GetStatus() *Status

func (*MutationInfo) GoString 

func (this *MutationInfo) GoString() string

func (*MutationInfo) Marshal 

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

func (*MutationInfo) MarshalTo 

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

func (*MutationInfo) MarshalToSizedBuffer 

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

func (*MutationInfo) ProtoMessage 

func (*MutationInfo) ProtoMessage()

func (*MutationInfo) Reset 

func (m *MutationInfo) Reset()

func (*MutationInfo) Size 

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

func (*MutationInfo) String 

func (this *MutationInfo) String() string

func (*MutationInfo) Unmarshal 

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

func (*MutationInfo) XXX_DiscardUnknown 

func (m *MutationInfo) XXX_DiscardUnknown()

func (*MutationInfo) XXX_Marshal 

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

func (*MutationInfo) XXX_Merge 

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

func (*MutationInfo) XXX_Size 

func (m *MutationInfo) XXX_Size() int

func (*MutationInfo) XXX_Unmarshal 

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

type MutationInfo_MutationState 

type MutationInfo_MutationState struct {
	ID    string         `protobuf:"bytes,1,opt,name=id,proto3" json:"id,omitempty"`
	State LifeCycleState `protobuf:"varint,2,opt,name=state,proto3,enum=px.api.vizierpb.LifeCycleState" json:"state,omitempty"`
	Name  string         `protobuf:"bytes,3,opt,name=name,proto3" json:"name,omitempty"`
}

func (*MutationInfo_MutationState) Descriptor 

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

func (*MutationInfo_MutationState) Equal 

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

func (*MutationInfo_MutationState) GetID 

func (m *MutationInfo_MutationState) GetID() string

func (*MutationInfo_MutationState) GetName 

func (m *MutationInfo_MutationState) GetName() string

func (*MutationInfo_MutationState) GetState 

func (m *MutationInfo_MutationState) GetState() LifeCycleState

func (*MutationInfo_MutationState) GoString 

func (this *MutationInfo_MutationState) GoString() string

func (*MutationInfo_MutationState) Marshal 

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

func (*MutationInfo_MutationState) MarshalTo 

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

func (*MutationInfo_MutationState) MarshalToSizedBuffer 

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

func (*MutationInfo_MutationState) ProtoMessage 

func (*MutationInfo_MutationState) ProtoMessage()

func (*MutationInfo_MutationState) Reset 

func (m *MutationInfo_MutationState) Reset()

func (*MutationInfo_MutationState) Size 

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

func (*MutationInfo_MutationState) String 

func (this *MutationInfo_MutationState) String() string

func (*MutationInfo_MutationState) Unmarshal 

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

func (*MutationInfo_MutationState) XXX_DiscardUnknown 

func (m *MutationInfo_MutationState) XXX_DiscardUnknown()

func (*MutationInfo_MutationState) XXX_Marshal 

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

func (*MutationInfo_MutationState) XXX_Merge 

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

func (*MutationInfo_MutationState) XXX_Size 

func (m *MutationInfo_MutationState) XXX_Size() int

func (*MutationInfo_MutationState) XXX_Unmarshal 

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

type PodPhase 

type PodPhase int32
const (
	PHASE_UNKNOWN PodPhase = 0
	PENDING       PodPhase = 1
	RUNNING       PodPhase = 2
	SUCCEEDED     PodPhase = 3
	FAILED        PodPhase = 4
)

func (PodPhase) EnumDescriptor 

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

func (PodPhase) String 

func (x PodPhase) String() string

type QueryData 

type QueryData struct {
	Batch          *RowBatchData        `protobuf:"bytes,1,opt,name=batch,proto3" json:"batch,omitempty"`
	EncryptedBatch []byte               `protobuf:"bytes,3,opt,name=encrypted_batch,json=encryptedBatch,proto3" json:"encrypted_batch,omitempty"`
	ExecutionStats *QueryExecutionStats `protobuf:"bytes,2,opt,name=execution_stats,json=executionStats,proto3" json:"execution_stats,omitempty"`
}

func (*QueryData) Descriptor 

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

func (*QueryData) Equal 

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

func (*QueryData) GetBatch 

func (m *QueryData) GetBatch() *RowBatchData

func (*QueryData) GetEncryptedBatch added in v0.2.0 

func (m *QueryData) GetEncryptedBatch() []byte

func (*QueryData) GetExecutionStats 

func (m *QueryData) GetExecutionStats() *QueryExecutionStats

func (*QueryData) GoString 

func (this *QueryData) GoString() string

func (*QueryData) Marshal 

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

func (*QueryData) MarshalTo 

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

func (*QueryData) MarshalToSizedBuffer 

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

func (*QueryData) ProtoMessage 

func (*QueryData) ProtoMessage()

func (*QueryData) Reset 

func (m *QueryData) Reset()

func (*QueryData) Size 

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

func (*QueryData) String 

func (this *QueryData) String() string

func (*QueryData) Unmarshal 

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

func (*QueryData) XXX_DiscardUnknown 

func (m *QueryData) XXX_DiscardUnknown()

func (*QueryData) XXX_Marshal 

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

func (*QueryData) XXX_Merge 

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

func (*QueryData) XXX_Size 

func (m *QueryData) XXX_Size() int

func (*QueryData) XXX_Unmarshal 

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

type QueryExecutionStats 

type QueryExecutionStats struct {
	Timing           *QueryTimingInfo `protobuf:"bytes,1,opt,name=timing,proto3" json:"timing,omitempty"`
	BytesProcessed   int64            `protobuf:"varint,2,opt,name=bytes_processed,json=bytesProcessed,proto3" json:"bytes_processed,omitempty"`
	RecordsProcessed int64            `protobuf:"varint,3,opt,name=records_processed,json=recordsProcessed,proto3" json:"records_processed,omitempty"`
}

func (*QueryExecutionStats) Descriptor 

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

func (*QueryExecutionStats) Equal 

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

func (*QueryExecutionStats) GetBytesProcessed 

func (m *QueryExecutionStats) GetBytesProcessed() int64

func (*QueryExecutionStats) GetRecordsProcessed 

func (m *QueryExecutionStats) GetRecordsProcessed() int64

func (*QueryExecutionStats) GetTiming 

func (m *QueryExecutionStats) GetTiming() *QueryTimingInfo

func (*QueryExecutionStats) GoString 

func (this *QueryExecutionStats) GoString() string

func (*QueryExecutionStats) Marshal 

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

func (*QueryExecutionStats) MarshalTo 

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

func (*QueryExecutionStats) MarshalToSizedBuffer 

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

func (*QueryExecutionStats) ProtoMessage 

func (*QueryExecutionStats) ProtoMessage()

func (*QueryExecutionStats) Reset 

func (m *QueryExecutionStats) Reset()

func (*QueryExecutionStats) Size 

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

func (*QueryExecutionStats) String 

func (this *QueryExecutionStats) String() string

func (*QueryExecutionStats) Unmarshal 

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

func (*QueryExecutionStats) XXX_DiscardUnknown 

func (m *QueryExecutionStats) XXX_DiscardUnknown()

func (*QueryExecutionStats) XXX_Marshal 

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

func (*QueryExecutionStats) XXX_Merge 

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

func (*QueryExecutionStats) XXX_Size 

func (m *QueryExecutionStats) XXX_Size() int

func (*QueryExecutionStats) XXX_Unmarshal 

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

type QueryMetadata 

type QueryMetadata struct {
	Relation *Relation `protobuf:"bytes,1,opt,name=relation,proto3" json:"relation,omitempty"`
	Name     string    `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	ID       string    `protobuf:"bytes,3,opt,name=id,proto3" json:"id,omitempty"`
}

func (*QueryMetadata) Descriptor 

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

func (*QueryMetadata) Equal 

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

func (*QueryMetadata) GetID 

func (m *QueryMetadata) GetID() string

func (*QueryMetadata) GetName 

func (m *QueryMetadata) GetName() string

func (*QueryMetadata) GetRelation 

func (m *QueryMetadata) GetRelation() *Relation

func (*QueryMetadata) GoString 

func (this *QueryMetadata) GoString() string

func (*QueryMetadata) Marshal 

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

func (*QueryMetadata) MarshalTo 

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

func (*QueryMetadata) MarshalToSizedBuffer 

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

func (*QueryMetadata) ProtoMessage 

func (*QueryMetadata) ProtoMessage()

func (*QueryMetadata) Reset 

func (m *QueryMetadata) Reset()

func (*QueryMetadata) Size 

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

func (*QueryMetadata) String 

func (this *QueryMetadata) String() string

func (*QueryMetadata) Unmarshal 

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

func (*QueryMetadata) XXX_DiscardUnknown 

func (m *QueryMetadata) XXX_DiscardUnknown()

func (*QueryMetadata) XXX_Marshal 

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

func (*QueryMetadata) XXX_Merge 

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

func (*QueryMetadata) XXX_Size 

func (m *QueryMetadata) XXX_Size() int

func (*QueryMetadata) XXX_Unmarshal 

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

type QueryTimingInfo 

type QueryTimingInfo struct {
	ExecutionTimeNs   int64 `protobuf:"varint,1,opt,name=execution_time_ns,json=executionTimeNs,proto3" json:"execution_time_ns,omitempty"`
	CompilationTimeNs int64 `protobuf:"varint,2,opt,name=compilation_time_ns,json=compilationTimeNs,proto3" json:"compilation_time_ns,omitempty"`
}

func (*QueryTimingInfo) Descriptor 

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

func (*QueryTimingInfo) Equal 

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

func (*QueryTimingInfo) GetCompilationTimeNs 

func (m *QueryTimingInfo) GetCompilationTimeNs() int64

func (*QueryTimingInfo) GetExecutionTimeNs 

func (m *QueryTimingInfo) GetExecutionTimeNs() int64

func (*QueryTimingInfo) GoString 

func (this *QueryTimingInfo) GoString() string

func (*QueryTimingInfo) Marshal 

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

func (*QueryTimingInfo) MarshalTo 

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

func (*QueryTimingInfo) MarshalToSizedBuffer 

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

func (*QueryTimingInfo) ProtoMessage 

func (*QueryTimingInfo) ProtoMessage()

func (*QueryTimingInfo) Reset 

func (m *QueryTimingInfo) Reset()

func (*QueryTimingInfo) Size 

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

func (*QueryTimingInfo) String 

func (this *QueryTimingInfo) String() string

func (*QueryTimingInfo) Unmarshal 

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

func (*QueryTimingInfo) XXX_DiscardUnknown 

func (m *QueryTimingInfo) XXX_DiscardUnknown()

func (*QueryTimingInfo) XXX_Marshal 

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

func (*QueryTimingInfo) XXX_Merge 

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

func (*QueryTimingInfo) XXX_Size 

func (m *QueryTimingInfo) XXX_Size() int

func (*QueryTimingInfo) XXX_Unmarshal 

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

type Relation 

type Relation struct {
	Columns []*Relation_ColumnInfo `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
}

func (*Relation) Descriptor 

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

func (*Relation) Equal 

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

func (*Relation) GetColumns 

func (m *Relation) GetColumns() []*Relation_ColumnInfo

func (*Relation) GoString 

func (this *Relation) GoString() string

func (*Relation) Marshal 

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

func (*Relation) MarshalTo 

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

func (*Relation) MarshalToSizedBuffer 

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

func (*Relation) ProtoMessage 

func (*Relation) ProtoMessage()

func (*Relation) Reset 

func (m *Relation) Reset()

func (*Relation) Size 

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

func (*Relation) String 

func (this *Relation) String() string

func (*Relation) Unmarshal 

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

func (*Relation) XXX_DiscardUnknown 

func (m *Relation) XXX_DiscardUnknown()

func (*Relation) XXX_Marshal 

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

func (*Relation) XXX_Merge 

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

func (*Relation) XXX_Size 

func (m *Relation) XXX_Size() int

func (*Relation) XXX_Unmarshal 

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

type Relation_ColumnInfo 

type Relation_ColumnInfo struct {
	ColumnName         string       `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	ColumnType         DataType     `protobuf:"varint,2,opt,name=column_type,json=columnType,proto3,enum=px.api.vizierpb.DataType" json:"column_type,omitempty"`
	ColumnDesc         string       `protobuf:"bytes,3,opt,name=column_desc,json=columnDesc,proto3" json:"column_desc,omitempty"`
	ColumnSemanticType SemanticType `` /* 152-byte string literal not displayed */
}

func (*Relation_ColumnInfo) Descriptor 

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

func (*Relation_ColumnInfo) Equal 

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

func (*Relation_ColumnInfo) GetColumnDesc 

func (m *Relation_ColumnInfo) GetColumnDesc() string

func (*Relation_ColumnInfo) GetColumnName 

func (m *Relation_ColumnInfo) GetColumnName() string

func (*Relation_ColumnInfo) GetColumnSemanticType 

func (m *Relation_ColumnInfo) GetColumnSemanticType() SemanticType

func (*Relation_ColumnInfo) GetColumnType 

func (m *Relation_ColumnInfo) GetColumnType() DataType

func (*Relation_ColumnInfo) GoString 

func (this *Relation_ColumnInfo) GoString() string

func (*Relation_ColumnInfo) Marshal 

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

func (*Relation_ColumnInfo) MarshalTo 

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

func (*Relation_ColumnInfo) MarshalToSizedBuffer 

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

func (*Relation_ColumnInfo) ProtoMessage 

func (*Relation_ColumnInfo) ProtoMessage()

func (*Relation_ColumnInfo) Reset 

func (m *Relation_ColumnInfo) Reset()

func (*Relation_ColumnInfo) Size 

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

func (*Relation_ColumnInfo) String 

func (this *Relation_ColumnInfo) String() string

func (*Relation_ColumnInfo) Unmarshal 

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

func (*Relation_ColumnInfo) XXX_DiscardUnknown 

func (m *Relation_ColumnInfo) XXX_DiscardUnknown()

func (*Relation_ColumnInfo) XXX_Marshal 

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

func (*Relation_ColumnInfo) XXX_Merge 

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

func (*Relation_ColumnInfo) XXX_Size 

func (m *Relation_ColumnInfo) XXX_Size() int

func (*Relation_ColumnInfo) XXX_Unmarshal 

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

type RowBatchData 

type RowBatchData struct {
	TableID string    `protobuf:"bytes,5,opt,name=table_id,json=tableId,proto3" json:"table_id,omitempty"`
	Cols    []*Column `protobuf:"bytes,1,rep,name=cols,proto3" json:"cols,omitempty"`
	NumRows int64     `protobuf:"varint,2,opt,name=num_rows,json=numRows,proto3" json:"num_rows,omitempty"`
	Eow     bool      `protobuf:"varint,3,opt,name=eow,proto3" json:"eow,omitempty"`
	Eos     bool      `protobuf:"varint,4,opt,name=eos,proto3" json:"eos,omitempty"`
}

func (*RowBatchData) Descriptor 

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

func (*RowBatchData) Equal 

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

func (*RowBatchData) GetCols 

func (m *RowBatchData) GetCols() []*Column

func (*RowBatchData) GetEos 

func (m *RowBatchData) GetEos() bool

func (*RowBatchData) GetEow 

func (m *RowBatchData) GetEow() bool

func (*RowBatchData) GetNumRows 

func (m *RowBatchData) GetNumRows() int64

func (*RowBatchData) GetTableID 

func (m *RowBatchData) GetTableID() string

func (*RowBatchData) GoString 

func (this *RowBatchData) GoString() string

func (*RowBatchData) Marshal 

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

func (*RowBatchData) MarshalTo 

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

func (*RowBatchData) MarshalToSizedBuffer 

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

func (*RowBatchData) ProtoMessage 

func (*RowBatchData) ProtoMessage()

func (*RowBatchData) Reset 

func (m *RowBatchData) Reset()

func (*RowBatchData) Size 

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

func (*RowBatchData) String 

func (this *RowBatchData) String() string

func (*RowBatchData) Unmarshal 

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

func (*RowBatchData) XXX_DiscardUnknown 

func (m *RowBatchData) XXX_DiscardUnknown()

func (*RowBatchData) XXX_Marshal 

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

func (*RowBatchData) XXX_Merge 

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

func (*RowBatchData) XXX_Size 

func (m *RowBatchData) XXX_Size() int

func (*RowBatchData) XXX_Unmarshal 

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

type ScalarValue 

type ScalarValue struct {
	DataType DataType `protobuf:"varint,1,opt,name=data_type,json=dataType,proto3,enum=px.api.vizierpb.DataType" json:"data_type,omitempty"`
	// Types that are valid to be assigned to Value:
	//
	//	*ScalarValue_BoolValue
	//	*ScalarValue_Int64Value
	//	*ScalarValue_Float64Value
	//	*ScalarValue_StringValue
	//	*ScalarValue_Time64NsValue
	//	*ScalarValue_Uint128Value
	Value isScalarValue_Value `protobuf_oneof:"value"`
}

func (*ScalarValue) Descriptor 

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

func (*ScalarValue) Equal 

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

func (*ScalarValue) GetBoolValue 

func (m *ScalarValue) GetBoolValue() bool

func (*ScalarValue) GetDataType 

func (m *ScalarValue) GetDataType() DataType

func (*ScalarValue) GetFloat64Value 

func (m *ScalarValue) GetFloat64Value() float64

func (*ScalarValue) GetInt64Value 

func (m *ScalarValue) GetInt64Value() int64

func (*ScalarValue) GetStringValue 

func (m *ScalarValue) GetStringValue() string

func (*ScalarValue) GetTime64NsValue 

func (m *ScalarValue) GetTime64NsValue() int64

func (*ScalarValue) GetUint128Value 

func (m *ScalarValue) GetUint128Value() *UInt128

func (*ScalarValue) GetValue 

func (m *ScalarValue) GetValue() isScalarValue_Value

func (*ScalarValue) GoString 

func (this *ScalarValue) GoString() string

func (*ScalarValue) Marshal 

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

func (*ScalarValue) MarshalTo 

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

func (*ScalarValue) MarshalToSizedBuffer 

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

func (*ScalarValue) ProtoMessage 

func (*ScalarValue) ProtoMessage()

func (*ScalarValue) Reset 

func (m *ScalarValue) Reset()

func (*ScalarValue) Size 

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

func (*ScalarValue) String 

func (this *ScalarValue) String() string

func (*ScalarValue) Unmarshal 

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

func (*ScalarValue) XXX_DiscardUnknown 

func (m *ScalarValue) XXX_DiscardUnknown()

func (*ScalarValue) XXX_Marshal 

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

func (*ScalarValue) XXX_Merge 

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

func (*ScalarValue) XXX_OneofWrappers 

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

XXX_OneofWrappers is for the internal use of the proto package.

func (*ScalarValue) XXX_Size 

func (m *ScalarValue) XXX_Size() int

func (*ScalarValue) XXX_Unmarshal 

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

type ScalarValue_BoolValue 

type ScalarValue_BoolValue struct {
	BoolValue bool `protobuf:"varint,2,opt,name=bool_value,json=boolValue,proto3,oneof" json:"bool_value,omitempty"`
}

func (*ScalarValue_BoolValue) Equal 

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

func (*ScalarValue_BoolValue) GoString 

func (this *ScalarValue_BoolValue) GoString() string

func (*ScalarValue_BoolValue) MarshalTo 

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

func (*ScalarValue_BoolValue) MarshalToSizedBuffer 

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

func (*ScalarValue_BoolValue) Size 

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

func (*ScalarValue_BoolValue) String 

func (this *ScalarValue_BoolValue) String() string

type ScalarValue_Float64Value 

type ScalarValue_Float64Value struct {
	Float64Value float64 `protobuf:"fixed64,4,opt,name=float64_value,json=float64Value,proto3,oneof" json:"float64_value,omitempty"`
}

func (*ScalarValue_Float64Value) Equal 

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

func (*ScalarValue_Float64Value) GoString 

func (this *ScalarValue_Float64Value) GoString() string

func (*ScalarValue_Float64Value) MarshalTo 

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

func (*ScalarValue_Float64Value) MarshalToSizedBuffer 

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

func (*ScalarValue_Float64Value) Size 

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

func (*ScalarValue_Float64Value) String 

func (this *ScalarValue_Float64Value) String() string

type ScalarValue_Int64Value 

type ScalarValue_Int64Value struct {
	Int64Value int64 `protobuf:"varint,3,opt,name=int64_value,json=int64Value,proto3,oneof" json:"int64_value,omitempty"`
}

func (*ScalarValue_Int64Value) Equal 

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

func (*ScalarValue_Int64Value) GoString 

func (this *ScalarValue_Int64Value) GoString() string

func (*ScalarValue_Int64Value) MarshalTo 

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

func (*ScalarValue_Int64Value) MarshalToSizedBuffer 

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

func (*ScalarValue_Int64Value) Size 

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

func (*ScalarValue_Int64Value) String 

func (this *ScalarValue_Int64Value) String() string

type ScalarValue_StringValue 

type ScalarValue_StringValue struct {
	StringValue string `protobuf:"bytes,5,opt,name=string_value,json=stringValue,proto3,oneof" json:"string_value,omitempty"`
}

func (*ScalarValue_StringValue) Equal 

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

func (*ScalarValue_StringValue) GoString 

func (this *ScalarValue_StringValue) GoString() string

func (*ScalarValue_StringValue) MarshalTo 

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

func (*ScalarValue_StringValue) MarshalToSizedBuffer 

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

func (*ScalarValue_StringValue) Size 

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

func (*ScalarValue_StringValue) String 

func (this *ScalarValue_StringValue) String() string

type ScalarValue_Time64NsValue 

type ScalarValue_Time64NsValue struct {
	Time64NsValue int64 `protobuf:"varint,6,opt,name=time64_ns_value,json=time64NsValue,proto3,oneof" json:"time64_ns_value,omitempty"`
}

func (*ScalarValue_Time64NsValue) Equal 

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

func (*ScalarValue_Time64NsValue) GoString 

func (this *ScalarValue_Time64NsValue) GoString() string

func (*ScalarValue_Time64NsValue) MarshalTo 

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

func (*ScalarValue_Time64NsValue) MarshalToSizedBuffer 

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

func (*ScalarValue_Time64NsValue) Size 

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

func (*ScalarValue_Time64NsValue) String 

func (this *ScalarValue_Time64NsValue) String() string

type ScalarValue_Uint128Value 

type ScalarValue_Uint128Value struct {
	Uint128Value *UInt128 `protobuf:"bytes,7,opt,name=uint128_value,json=uint128Value,proto3,oneof" json:"uint128_value,omitempty"`
}

func (*ScalarValue_Uint128Value) Equal 

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

func (*ScalarValue_Uint128Value) GoString 

func (this *ScalarValue_Uint128Value) GoString() string

func (*ScalarValue_Uint128Value) MarshalTo 

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

func (*ScalarValue_Uint128Value) MarshalToSizedBuffer 

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

func (*ScalarValue_Uint128Value) Size 

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

func (*ScalarValue_Uint128Value) String 

func (this *ScalarValue_Uint128Value) String() string

type SemanticType 

type SemanticType int32
const (
	ST_UNSPECIFIED             SemanticType = 0
	ST_NONE                    SemanticType = 1
	ST_TIME_NS                 SemanticType = 2
	ST_AGENT_UID               SemanticType = 100
	ST_ASID                    SemanticType = 101
	ST_UPID                    SemanticType = 200
	ST_SERVICE_NAME            SemanticType = 300
	ST_POD_NAME                SemanticType = 400
	ST_POD_PHASE               SemanticType = 401
	ST_POD_STATUS              SemanticType = 402
	ST_NODE_NAME               SemanticType = 500
	ST_CONTAINER_NAME          SemanticType = 600
	ST_CONTAINER_STATE         SemanticType = 601
	ST_CONTAINER_STATUS        SemanticType = 602
	ST_NAMESPACE_NAME          SemanticType = 700
	ST_BYTES                   SemanticType = 800
	ST_PERCENT                 SemanticType = 900
	ST_DURATION_NS             SemanticType = 901
	ST_THROUGHPUT_PER_NS       SemanticType = 902
	ST_THROUGHPUT_BYTES_PER_NS SemanticType = 903
	ST_QUANTILES               SemanticType = 1000
	ST_DURATION_NS_QUANTILES   SemanticType = 1001
	ST_IP_ADDRESS              SemanticType = 1100
	ST_PORT                    SemanticType = 1200
	ST_HTTP_REQ_METHOD         SemanticType = 1300
	ST_HTTP_RESP_STATUS        SemanticType = 1400
	ST_HTTP_RESP_MESSAGE       SemanticType = 1500
	ST_SCRIPT_REFERENCE        SemanticType = 3000
)

func (SemanticType) EnumDescriptor 

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

func (SemanticType) String 

func (x SemanticType) String() string

type Status 

type Status struct {
	Code         int32           `protobuf:"varint,1,opt,name=code,proto3" json:"code,omitempty"`
	Message      string          `protobuf:"bytes,2,opt,name=message,proto3" json:"message,omitempty"`
	ErrorDetails []*ErrorDetails `protobuf:"bytes,4,rep,name=error_details,json=errorDetails,proto3" json:"error_details,omitempty"`
}

func (*Status) Descriptor 

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

func (*Status) Equal 

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

func (*Status) GetCode 

func (m *Status) GetCode() int32

func (*Status) GetErrorDetails 

func (m *Status) GetErrorDetails() []*ErrorDetails

func (*Status) GetMessage 

func (m *Status) GetMessage() string

func (*Status) GoString 

func (this *Status) GoString() string

func (*Status) Marshal 

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

func (*Status) MarshalTo 

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

func (*Status) MarshalToSizedBuffer 

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

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) Reset 

func (m *Status) Reset()

func (*Status) Size 

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

func (*Status) String 

func (this *Status) String() string

func (*Status) Unmarshal 

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

func (*Status) XXX_DiscardUnknown 

func (m *Status) XXX_DiscardUnknown()

func (*Status) XXX_Marshal 

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

func (*Status) XXX_Merge 

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

func (*Status) XXX_Size 

func (m *Status) XXX_Size() int

func (*Status) XXX_Unmarshal 

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

type StringColumn 

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

func (*StringColumn) Descriptor 

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

func (*StringColumn) Equal 

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

func (*StringColumn) GetData 

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

func (*StringColumn) GoString 

func (this *StringColumn) GoString() string

func (*StringColumn) Marshal 

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

func (*StringColumn) MarshalTo 

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

func (*StringColumn) MarshalToSizedBuffer 

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

func (*StringColumn) ProtoMessage 

func (*StringColumn) ProtoMessage()

func (*StringColumn) Reset 

func (m *StringColumn) Reset()

func (*StringColumn) Size 

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

func (*StringColumn) String 

func (this *StringColumn) String() string

func (*StringColumn) Unmarshal 

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

func (*StringColumn) XXX_DiscardUnknown 

func (m *StringColumn) XXX_DiscardUnknown()

func (*StringColumn) XXX_Marshal 

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

func (*StringColumn) XXX_Merge 

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

func (*StringColumn) XXX_Size 

func (m *StringColumn) XXX_Size() int

func (*StringColumn) XXX_Unmarshal 

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

type Time64NSColumn 

type Time64NSColumn struct {
	Data []int64 `protobuf:"varint,1,rep,packed,name=data,proto3" json:"data,omitempty"`
}

func (*Time64NSColumn) Descriptor 

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

func (*Time64NSColumn) Equal 

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

func (*Time64NSColumn) GetData 

func (m *Time64NSColumn) GetData() []int64

func (*Time64NSColumn) GoString 

func (this *Time64NSColumn) GoString() string

func (*Time64NSColumn) Marshal 

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

func (*Time64NSColumn) MarshalTo 

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

func (*Time64NSColumn) MarshalToSizedBuffer 

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

func (*Time64NSColumn) ProtoMessage 

func (*Time64NSColumn) ProtoMessage()

func (*Time64NSColumn) Reset 

func (m *Time64NSColumn) Reset()

func (*Time64NSColumn) Size 

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

func (*Time64NSColumn) String 

func (this *Time64NSColumn) String() string

func (*Time64NSColumn) Unmarshal 

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

func (*Time64NSColumn) XXX_DiscardUnknown 

func (m *Time64NSColumn) XXX_DiscardUnknown()

func (*Time64NSColumn) XXX_Marshal 

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

func (*Time64NSColumn) XXX_Merge 

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

func (*Time64NSColumn) XXX_Size 

func (m *Time64NSColumn) XXX_Size() int

func (*Time64NSColumn) XXX_Unmarshal 

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

type UInt128 

type UInt128 struct {
	Low  uint64 `protobuf:"varint,1,opt,name=low,proto3" json:"low,omitempty"`
	High uint64 `protobuf:"varint,2,opt,name=high,proto3" json:"high,omitempty"`
}

func (*UInt128) Descriptor 

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

func (*UInt128) Equal 

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

func (*UInt128) GetHigh 

func (m *UInt128) GetHigh() uint64

func (*UInt128) GetLow 

func (m *UInt128) GetLow() uint64

func (*UInt128) GoString 

func (this *UInt128) GoString() string

func (*UInt128) Marshal 

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

func (*UInt128) MarshalTo 

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

func (*UInt128) MarshalToSizedBuffer 

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

func (*UInt128) ProtoMessage 

func (*UInt128) ProtoMessage()

func (*UInt128) Reset 

func (m *UInt128) Reset()

func (*UInt128) Size 

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

func (*UInt128) String 

func (this *UInt128) String() string

func (*UInt128) Unmarshal 

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

func (*UInt128) XXX_DiscardUnknown 

func (m *UInt128) XXX_DiscardUnknown()

func (*UInt128) XXX_Marshal 

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

func (*UInt128) XXX_Merge 

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

func (*UInt128) XXX_Size 

func (m *UInt128) XXX_Size() int

func (*UInt128) XXX_Unmarshal 

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

type UInt128Column 

type UInt128Column struct {
	Data []*UInt128 `protobuf:"bytes,1,rep,name=data,proto3" json:"data,omitempty"`
}

func (*UInt128Column) Descriptor 

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

func (*UInt128Column) Equal 

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

func (*UInt128Column) GetData 

func (m *UInt128Column) GetData() []*UInt128

func (*UInt128Column) GoString 

func (this *UInt128Column) GoString() string

func (*UInt128Column) Marshal 

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

func (*UInt128Column) MarshalTo 

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

func (*UInt128Column) MarshalToSizedBuffer 

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

func (*UInt128Column) ProtoMessage 

func (*UInt128Column) ProtoMessage()

func (*UInt128Column) Reset 

func (m *UInt128Column) Reset()

func (*UInt128Column) Size 

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

func (*UInt128Column) String 

func (this *UInt128Column) String() string

func (*UInt128Column) Unmarshal 

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

func (*UInt128Column) XXX_DiscardUnknown 

func (m *UInt128Column) XXX_DiscardUnknown()

func (*UInt128Column) XXX_Marshal 

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

func (*UInt128Column) XXX_Merge 

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

func (*UInt128Column) XXX_Size 

func (m *UInt128Column) XXX_Size() int

func (*UInt128Column) XXX_Unmarshal 

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

type UnimplementedVizierDebugServiceServer 

type UnimplementedVizierDebugServiceServer struct {
}

UnimplementedVizierDebugServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedVizierDebugServiceServer) DebugLog 

func (*UnimplementedVizierDebugServiceServer) DebugLog(req *DebugLogRequest, srv VizierDebugService_DebugLogServer) error

func (*UnimplementedVizierDebugServiceServer) DebugPods 

func (*UnimplementedVizierDebugServiceServer) DebugPods(req *DebugPodsRequest, srv VizierDebugService_DebugPodsServer) error

type UnimplementedVizierServiceServer 

type UnimplementedVizierServiceServer struct {
}

UnimplementedVizierServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedVizierServiceServer) ExecuteScript 

func (*UnimplementedVizierServiceServer) ExecuteScript(req *ExecuteScriptRequest, srv VizierService_ExecuteScriptServer) error

func (*UnimplementedVizierServiceServer) HealthCheck 

func (*UnimplementedVizierServiceServer) HealthCheck(req *HealthCheckRequest, srv VizierService_HealthCheckServer) error

type VizierDebugServiceClient 

type VizierDebugServiceClient interface {
	DebugLog(ctx context.Context, in *DebugLogRequest, opts ...grpc.CallOption) (VizierDebugService_DebugLogClient, error)
	DebugPods(ctx context.Context, in *DebugPodsRequest, opts ...grpc.CallOption) (VizierDebugService_DebugPodsClient, error)
}

VizierDebugServiceClient is the client API for VizierDebugService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVizierDebugServiceClient 

func NewVizierDebugServiceClient(cc *grpc.ClientConn) VizierDebugServiceClient

type VizierDebugServiceServer 

type VizierDebugServiceServer interface {
	DebugLog(*DebugLogRequest, VizierDebugService_DebugLogServer) error
	DebugPods(*DebugPodsRequest, VizierDebugService_DebugPodsServer) error
}

VizierDebugServiceServer is the server API for VizierDebugService service.

type VizierDebugService_DebugLogClient 

type VizierDebugService_DebugLogClient interface {
	Recv() (*DebugLogResponse, error)
	grpc.ClientStream
}

type VizierDebugService_DebugLogServer 

type VizierDebugService_DebugLogServer interface {
	Send(*DebugLogResponse) error
	grpc.ServerStream
}

type VizierDebugService_DebugPodsClient 

type VizierDebugService_DebugPodsClient interface {
	Recv() (*DebugPodsResponse, error)
	grpc.ClientStream
}

type VizierDebugService_DebugPodsServer 

type VizierDebugService_DebugPodsServer interface {
	Send(*DebugPodsResponse) error
	grpc.ServerStream
}

type VizierPodStatus 

type VizierPodStatus struct {
	Name              string             `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Phase             PodPhase           `protobuf:"varint,2,opt,name=phase,proto3,enum=px.api.vizierpb.PodPhase" json:"phase,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         int64              `protobuf:"varint,5,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	ContainerStatuses []*ContainerStatus `protobuf:"bytes,6,rep,name=container_statuses,json=containerStatuses,proto3" json:"container_statuses,omitempty"`
	RestartCount      int64              `protobuf:"varint,7,opt,name=restart_count,json=restartCount,proto3" json:"restart_count,omitempty"`
}

func (*VizierPodStatus) Descriptor 

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

func (*VizierPodStatus) Equal 

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

func (*VizierPodStatus) GetContainerStatuses 

func (m *VizierPodStatus) GetContainerStatuses() []*ContainerStatus

func (*VizierPodStatus) GetCreatedAt 

func (m *VizierPodStatus) GetCreatedAt() int64

func (*VizierPodStatus) GetMessage 

func (m *VizierPodStatus) GetMessage() string

func (*VizierPodStatus) GetName 

func (m *VizierPodStatus) GetName() string

func (*VizierPodStatus) GetPhase 

func (m *VizierPodStatus) GetPhase() PodPhase

func (*VizierPodStatus) GetReason 

func (m *VizierPodStatus) GetReason() string

func (*VizierPodStatus) GetRestartCount added in v0.2.0 

func (m *VizierPodStatus) GetRestartCount() int64

func (*VizierPodStatus) GoString 

func (this *VizierPodStatus) GoString() string

func (*VizierPodStatus) Marshal 

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

func (*VizierPodStatus) MarshalTo 

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

func (*VizierPodStatus) MarshalToSizedBuffer 

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

func (*VizierPodStatus) ProtoMessage 

func (*VizierPodStatus) ProtoMessage()

func (*VizierPodStatus) Reset 

func (m *VizierPodStatus) Reset()

func (*VizierPodStatus) Size 

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

func (*VizierPodStatus) String 

func (this *VizierPodStatus) String() string

func (*VizierPodStatus) Unmarshal 

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

func (*VizierPodStatus) XXX_DiscardUnknown 

func (m *VizierPodStatus) XXX_DiscardUnknown()

func (*VizierPodStatus) XXX_Marshal 

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

func (*VizierPodStatus) XXX_Merge 

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

func (*VizierPodStatus) XXX_Size 

func (m *VizierPodStatus) XXX_Size() int

func (*VizierPodStatus) XXX_Unmarshal 

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

type VizierServiceClient 

type VizierServiceClient interface {
	ExecuteScript(ctx context.Context, in *ExecuteScriptRequest, opts ...grpc.CallOption) (VizierService_ExecuteScriptClient, error)
	HealthCheck(ctx context.Context, in *HealthCheckRequest, opts ...grpc.CallOption) (VizierService_HealthCheckClient, error)
}

VizierServiceClient is the client API for VizierService service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://godoc.org/google.golang.org/grpc#ClientConn.NewStream.

func NewVizierServiceClient 

func NewVizierServiceClient(cc *grpc.ClientConn) VizierServiceClient

type VizierServiceServer 

type VizierServiceServer interface {
	ExecuteScript(*ExecuteScriptRequest, VizierService_ExecuteScriptServer) error
	HealthCheck(*HealthCheckRequest, VizierService_HealthCheckServer) error
}

VizierServiceServer is the server API for VizierService service.

type VizierService_ExecuteScriptClient 

type VizierService_ExecuteScriptClient interface {
	Recv() (*ExecuteScriptResponse, error)
	grpc.ClientStream
}

type VizierService_ExecuteScriptServer 

type VizierService_ExecuteScriptServer interface {
	Send(*ExecuteScriptResponse) error
	grpc.ServerStream
}

type VizierService_HealthCheckClient 

type VizierService_HealthCheckClient interface {
	Recv() (*HealthCheckResponse, error)
	grpc.ClientStream
}

type VizierService_HealthCheckServer 

type VizierService_HealthCheckServer interface {
	Send(*HealthCheckResponse) error
	grpc.ServerStream
}

Source Files

View all Source files

Directories

Path Synopsis
Package mock_vizierpb is a generated GoMock package.
 Package mock_vizierpb is a generated GoMock package.

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.