exec

package
v1.2.0 Latest Latest
Warning

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

 Go to latest Published: Mar 21, 2022 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	Default_Roles_SqlQuery         = bool(true)
	Default_Roles_LogicalPlan      = bool(true)
	Default_Roles_PhysicalPlan     = bool(true)
	Default_Roles_JavaExecutor     = bool(true)
	Default_Roles_DistributedCache = bool(true)
)

Default values for Roles fields.

Variables

View Source 
var (
	DrillbitEndpoint_State_name = map[int32]string{
		0: "STARTUP",
		1: "ONLINE",
		2: "QUIESCENT",
		3: "OFFLINE",
	}
	DrillbitEndpoint_State_value = map[string]int32{
		"STARTUP":   0,
		"ONLINE":    1,
		"QUIESCENT": 2,
		"OFFLINE":   3,
	}
)

Enum value maps for DrillbitEndpoint_State.

View Source 
var (
	ValueMode_name = map[int32]string{
		0: "VALUE_VECTOR",
		1: "RLE",
		2: "DICT",
	}
	ValueMode_value = map[string]int32{
		"VALUE_VECTOR": 0,
		"RLE":          1,
		"DICT":         2,
	}
)

Enum value maps for ValueMode.

View Source 
var File_Coordination_proto protoreflect.FileDescriptor
View Source 
var File_SchemaDef_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type DrillServiceInstance 

type DrillServiceInstance struct {
	Id                  *string           `protobuf:"bytes,1,opt,name=id" json:"id,omitempty"`
	RegistrationTimeUTC *int64            `protobuf:"varint,2,opt,name=registrationTimeUTC" json:"registrationTimeUTC,omitempty"`
	Endpoint            *DrillbitEndpoint `protobuf:"bytes,3,opt,name=endpoint" json:"endpoint,omitempty"`
	// contains filtered or unexported fields
}

func (*DrillServiceInstance) Descriptor deprecated 

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

Deprecated: Use DrillServiceInstance.ProtoReflect.Descriptor instead.

func (*DrillServiceInstance) GetEndpoint 

func (x *DrillServiceInstance) GetEndpoint() *DrillbitEndpoint

func (*DrillServiceInstance) GetId 

func (x *DrillServiceInstance) GetId() string

func (*DrillServiceInstance) GetRegistrationTimeUTC 

func (x *DrillServiceInstance) GetRegistrationTimeUTC() int64

func (*DrillServiceInstance) ProtoMessage 

func (*DrillServiceInstance) ProtoMessage()

func (*DrillServiceInstance) ProtoReflect 

func (x *DrillServiceInstance) ProtoReflect() protoreflect.Message

func (*DrillServiceInstance) Reset 

func (x *DrillServiceInstance) Reset()

func (*DrillServiceInstance) String 

func (x *DrillServiceInstance) String() string

type DrillbitEndpoint 

type DrillbitEndpoint struct {
	Address     *string                 `protobuf:"bytes,1,opt,name=address" json:"address,omitempty"`
	UserPort    *int32                  `protobuf:"varint,2,opt,name=user_port,json=userPort" json:"user_port,omitempty"`
	ControlPort *int32                  `protobuf:"varint,3,opt,name=control_port,json=controlPort" json:"control_port,omitempty"`
	DataPort    *int32                  `protobuf:"varint,4,opt,name=data_port,json=dataPort" json:"data_port,omitempty"`
	Roles       *Roles                  `protobuf:"bytes,5,opt,name=roles" json:"roles,omitempty"`
	Version     *string                 `protobuf:"bytes,6,opt,name=version" json:"version,omitempty"`
	State       *DrillbitEndpoint_State `protobuf:"varint,7,opt,name=state,enum=exec.DrillbitEndpoint_State" json:"state,omitempty"`
	HttpPort    *int32                  `protobuf:"varint,8,opt,name=http_port,json=httpPort" json:"http_port,omitempty"`
	// contains filtered or unexported fields
}

func (*DrillbitEndpoint) Descriptor deprecated 

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

Deprecated: Use DrillbitEndpoint.ProtoReflect.Descriptor instead.

func (*DrillbitEndpoint) GetAddress 

func (x *DrillbitEndpoint) GetAddress() string

func (*DrillbitEndpoint) GetControlPort 

func (x *DrillbitEndpoint) GetControlPort() int32

func (*DrillbitEndpoint) GetDataPort 

func (x *DrillbitEndpoint) GetDataPort() int32

func (*DrillbitEndpoint) GetHttpPort 

func (x *DrillbitEndpoint) GetHttpPort() int32

func (*DrillbitEndpoint) GetRoles 

func (x *DrillbitEndpoint) GetRoles() *Roles

func (*DrillbitEndpoint) GetState 

func (x *DrillbitEndpoint) GetState() DrillbitEndpoint_State

func (*DrillbitEndpoint) GetUserPort 

func (x *DrillbitEndpoint) GetUserPort() int32

func (*DrillbitEndpoint) GetVersion 

func (x *DrillbitEndpoint) GetVersion() string

func (*DrillbitEndpoint) ProtoMessage 

func (*DrillbitEndpoint) ProtoMessage()

func (*DrillbitEndpoint) ProtoReflect 

func (x *DrillbitEndpoint) ProtoReflect() protoreflect.Message

func (*DrillbitEndpoint) Reset 

func (x *DrillbitEndpoint) Reset()

func (*DrillbitEndpoint) String 

func (x *DrillbitEndpoint) String() string

type DrillbitEndpoint_State 

type DrillbitEndpoint_State int32
const (
	DrillbitEndpoint_STARTUP   DrillbitEndpoint_State = 0
	DrillbitEndpoint_ONLINE    DrillbitEndpoint_State = 1
	DrillbitEndpoint_QUIESCENT DrillbitEndpoint_State = 2
	DrillbitEndpoint_OFFLINE   DrillbitEndpoint_State = 3
)

func (DrillbitEndpoint_State) Descriptor 

func (DrillbitEndpoint_State) Descriptor() protoreflect.EnumDescriptor

func (DrillbitEndpoint_State) Enum 

func (x DrillbitEndpoint_State) Enum() *DrillbitEndpoint_State

func (DrillbitEndpoint_State) EnumDescriptor deprecated 

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

Deprecated: Use DrillbitEndpoint_State.Descriptor instead.

func (DrillbitEndpoint_State) Number 

func (x DrillbitEndpoint_State) Number() protoreflect.EnumNumber

func (DrillbitEndpoint_State) String 

func (x DrillbitEndpoint_State) String() string

func (DrillbitEndpoint_State) Type 

func (DrillbitEndpoint_State) Type() protoreflect.EnumType

func (*DrillbitEndpoint_State) UnmarshalJSON deprecated 

func (x *DrillbitEndpoint_State) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

type Roles 

type Roles struct {
	SqlQuery         *bool `protobuf:"varint,1,opt,name=sql_query,json=sqlQuery,def=1" json:"sql_query,omitempty"`
	LogicalPlan      *bool `protobuf:"varint,2,opt,name=logical_plan,json=logicalPlan,def=1" json:"logical_plan,omitempty"`
	PhysicalPlan     *bool `protobuf:"varint,3,opt,name=physical_plan,json=physicalPlan,def=1" json:"physical_plan,omitempty"`
	JavaExecutor     *bool `protobuf:"varint,4,opt,name=java_executor,json=javaExecutor,def=1" json:"java_executor,omitempty"`
	DistributedCache *bool `protobuf:"varint,5,opt,name=distributed_cache,json=distributedCache,def=1" json:"distributed_cache,omitempty"`
	// contains filtered or unexported fields
}

func (*Roles) Descriptor deprecated 

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

Deprecated: Use Roles.ProtoReflect.Descriptor instead.

func (*Roles) GetDistributedCache 

func (x *Roles) GetDistributedCache() bool

func (*Roles) GetJavaExecutor 

func (x *Roles) GetJavaExecutor() bool

func (*Roles) GetLogicalPlan 

func (x *Roles) GetLogicalPlan() bool

func (*Roles) GetPhysicalPlan 

func (x *Roles) GetPhysicalPlan() bool

func (*Roles) GetSqlQuery 

func (x *Roles) GetSqlQuery() bool

func (*Roles) ProtoMessage 

func (*Roles) ProtoMessage()

func (*Roles) ProtoReflect 

func (x *Roles) ProtoReflect() protoreflect.Message

func (*Roles) Reset 

func (x *Roles) Reset()

func (*Roles) String 

func (x *Roles) String() string

type ValueMode 

type ValueMode int32
const (
	ValueMode_VALUE_VECTOR ValueMode = 0
	ValueMode_RLE          ValueMode = 1
	ValueMode_DICT         ValueMode = 2
)

func (ValueMode) Descriptor 

func (ValueMode) Descriptor() protoreflect.EnumDescriptor

func (ValueMode) Enum 

func (x ValueMode) Enum() *ValueMode

func (ValueMode) EnumDescriptor deprecated 

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

Deprecated: Use ValueMode.Descriptor instead.

func (ValueMode) Number 

func (x ValueMode) Number() protoreflect.EnumNumber

func (ValueMode) String 

func (x ValueMode) String() string

func (ValueMode) Type 

func (ValueMode) Type() protoreflect.EnumType

func (*ValueMode) UnmarshalJSON deprecated 

func (x *ValueMode) UnmarshalJSON(b []byte) error

Deprecated: Do not use.

Source Files

View all Source files

Directories

Path Synopsis
bit
control
data

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.