control

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

Documentation

Index

Constants

View Source 
const (
	Default_PlanFragment_MemInitial = int64(20000000)
	Default_PlanFragment_MemMax     = int64(2000000000)
)

Default values for PlanFragment fields.

View Source 
const (
	Default_BitControlHandshake_Channel = shared.RpcChannel_BIT_CONTROL
)

Default values for BitControlHandshake fields.

Variables

View Source 
var (
	RpcType_name = map[int32]string{
		0:  "HANDSHAKE",
		1:  "ACK",
		2:  "GOODBYE",
		3:  "REQ_INITIALIZE_FRAGMENTS",
		6:  "REQ_CANCEL_FRAGMENT",
		7:  "REQ_RECEIVER_FINISHED",
		8:  "REQ_FRAGMENT_STATUS",
		9:  "REQ_BIT_STATUS",
		10: "REQ_QUERY_STATUS",
		15: "REQ_QUERY_CANCEL",
		16: "REQ_UNPAUSE_FRAGMENT",
		17: "REQ_CUSTOM",
		11: "RESP_FRAGMENT_HANDLE",
		12: "RESP_FRAGMENT_STATUS",
		13: "RESP_BIT_STATUS",
		14: "RESP_QUERY_STATUS",
		18: "RESP_CUSTOM",
		19: "SASL_MESSAGE",
	}
	RpcType_value = map[string]int32{
		"HANDSHAKE":                0,
		"ACK":                      1,
		"GOODBYE":                  2,
		"REQ_INITIALIZE_FRAGMENTS": 3,
		"REQ_CANCEL_FRAGMENT":      6,
		"REQ_RECEIVER_FINISHED":    7,
		"REQ_FRAGMENT_STATUS":      8,
		"REQ_BIT_STATUS":           9,
		"REQ_QUERY_STATUS":         10,
		"REQ_QUERY_CANCEL":         15,
		"REQ_UNPAUSE_FRAGMENT":     16,
		"REQ_CUSTOM":               17,
		"RESP_FRAGMENT_HANDLE":     11,
		"RESP_FRAGMENT_STATUS":     12,
		"RESP_BIT_STATUS":          13,
		"RESP_QUERY_STATUS":        14,
		"RESP_CUSTOM":              18,
		"SASL_MESSAGE":             19,
	}
)

Enum value maps for RpcType.

View Source 
var File_BitControl_proto protoreflect.FileDescriptor

Functions

This section is empty.

Types

type BitControlHandshake 

type BitControlHandshake struct {
	RpcVersion               *int32                 `protobuf:"varint,1,opt,name=rpc_version,json=rpcVersion" json:"rpc_version,omitempty"`
	Channel                  *shared.RpcChannel     `protobuf:"varint,2,opt,name=channel,enum=exec.shared.RpcChannel,def=0" json:"channel,omitempty"`
	Endpoint                 *exec.DrillbitEndpoint `protobuf:"bytes,3,opt,name=endpoint" json:"endpoint,omitempty"`
	AuthenticationMechanisms []string               `protobuf:"bytes,4,rep,name=authenticationMechanisms" json:"authenticationMechanisms,omitempty"`
	// contains filtered or unexported fields
}

func (*BitControlHandshake) Descriptor deprecated 

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

Deprecated: Use BitControlHandshake.ProtoReflect.Descriptor instead.

func (*BitControlHandshake) GetAuthenticationMechanisms 

func (x *BitControlHandshake) GetAuthenticationMechanisms() []string

func (*BitControlHandshake) GetChannel 

func (x *BitControlHandshake) GetChannel() shared.RpcChannel

func (*BitControlHandshake) GetEndpoint 

func (x *BitControlHandshake) GetEndpoint() *exec.DrillbitEndpoint

func (*BitControlHandshake) GetRpcVersion 

func (x *BitControlHandshake) GetRpcVersion() int32

func (*BitControlHandshake) ProtoMessage 

func (*BitControlHandshake) ProtoMessage()

func (*BitControlHandshake) ProtoReflect 

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

func (*BitControlHandshake) Reset 

func (x *BitControlHandshake) Reset()

func (*BitControlHandshake) String 

func (x *BitControlHandshake) String() string

type BitStatus 

type BitStatus struct {
	FragmentStatus []*FragmentStatus `protobuf:"bytes,1,rep,name=fragment_status,json=fragmentStatus" json:"fragment_status,omitempty"`
	// contains filtered or unexported fields
}

func (*BitStatus) Descriptor deprecated 

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

Deprecated: Use BitStatus.ProtoReflect.Descriptor instead.

func (*BitStatus) GetFragmentStatus 

func (x *BitStatus) GetFragmentStatus() []*FragmentStatus

func (*BitStatus) ProtoMessage 

func (*BitStatus) ProtoMessage()

func (*BitStatus) ProtoReflect 

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

func (*BitStatus) Reset 

func (x *BitStatus) Reset()

func (*BitStatus) String 

func (x *BitStatus) String() string

type Collector 

type Collector struct {
	OppositeMajorFragmentId *int32  `` /* 128-byte string literal not displayed */
	IncomingMinorFragment   []int32 `` /* 127-byte string literal not displayed */
	SupportsOutOfOrder      *bool   `protobuf:"varint,3,opt,name=supports_out_of_order,json=supportsOutOfOrder" json:"supports_out_of_order,omitempty"`
	IsSpooling              *bool   `protobuf:"varint,4,opt,name=is_spooling,json=isSpooling" json:"is_spooling,omitempty"`
	EnableDynamicFc         *bool   `protobuf:"varint,5,opt,name=enable_dynamic_fc,json=enableDynamicFc" json:"enable_dynamic_fc,omitempty"`
	// contains filtered or unexported fields
}

func (*Collector) Descriptor deprecated 

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

Deprecated: Use Collector.ProtoReflect.Descriptor instead.

func (*Collector) GetEnableDynamicFc 

func (x *Collector) GetEnableDynamicFc() bool

func (*Collector) GetIncomingMinorFragment 

func (x *Collector) GetIncomingMinorFragment() []int32

func (*Collector) GetIsSpooling 

func (x *Collector) GetIsSpooling() bool

func (*Collector) GetOppositeMajorFragmentId 

func (x *Collector) GetOppositeMajorFragmentId() int32

func (*Collector) GetSupportsOutOfOrder 

func (x *Collector) GetSupportsOutOfOrder() bool

func (*Collector) ProtoMessage 

func (*Collector) ProtoMessage()

func (*Collector) ProtoReflect 

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

func (*Collector) Reset 

func (x *Collector) Reset()

func (*Collector) String 

func (x *Collector) String() string

type CustomMessage 

type CustomMessage struct {
	Type    *int32 `protobuf:"varint,1,opt,name=type" json:"type,omitempty"`
	Message []byte `protobuf:"bytes,2,opt,name=message" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*CustomMessage) Descriptor deprecated 

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

Deprecated: Use CustomMessage.ProtoReflect.Descriptor instead.

func (*CustomMessage) GetMessage 

func (x *CustomMessage) GetMessage() []byte

func (*CustomMessage) GetType 

func (x *CustomMessage) GetType() int32

func (*CustomMessage) ProtoMessage 

func (*CustomMessage) ProtoMessage()

func (*CustomMessage) ProtoReflect 

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

func (*CustomMessage) Reset 

func (x *CustomMessage) Reset()

func (*CustomMessage) String 

func (x *CustomMessage) String() string

type FinishedReceiver 

type FinishedReceiver struct {
	Receiver *bit.FragmentHandle `protobuf:"bytes,1,opt,name=receiver" json:"receiver,omitempty"`
	Sender   *bit.FragmentHandle `protobuf:"bytes,2,opt,name=sender" json:"sender,omitempty"`
	// contains filtered or unexported fields
}

func (*FinishedReceiver) Descriptor deprecated 

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

Deprecated: Use FinishedReceiver.ProtoReflect.Descriptor instead.

func (*FinishedReceiver) GetReceiver 

func (x *FinishedReceiver) GetReceiver() *bit.FragmentHandle

func (*FinishedReceiver) GetSender 

func (x *FinishedReceiver) GetSender() *bit.FragmentHandle

func (*FinishedReceiver) ProtoMessage 

func (*FinishedReceiver) ProtoMessage()

func (*FinishedReceiver) ProtoReflect 

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

func (*FinishedReceiver) Reset 

func (x *FinishedReceiver) Reset()

func (*FinishedReceiver) String 

func (x *FinishedReceiver) String() string

type FragmentStatus 

type FragmentStatus struct {
	Profile *shared.MinorFragmentProfile `protobuf:"bytes,1,opt,name=profile" json:"profile,omitempty"`
	Handle  *bit.FragmentHandle          `protobuf:"bytes,2,opt,name=handle" json:"handle,omitempty"`
	// contains filtered or unexported fields
}

func (*FragmentStatus) Descriptor deprecated 

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

Deprecated: Use FragmentStatus.ProtoReflect.Descriptor instead.

func (*FragmentStatus) GetHandle 

func (x *FragmentStatus) GetHandle() *bit.FragmentHandle

func (*FragmentStatus) GetProfile 

func (x *FragmentStatus) GetProfile() *shared.MinorFragmentProfile

func (*FragmentStatus) ProtoMessage 

func (*FragmentStatus) ProtoMessage()

func (*FragmentStatus) ProtoReflect 

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

func (*FragmentStatus) Reset 

func (x *FragmentStatus) Reset()

func (*FragmentStatus) String 

func (x *FragmentStatus) String() string

type InitializeFragments 

type InitializeFragments struct {
	Fragment []*PlanFragment `protobuf:"bytes,1,rep,name=fragment" json:"fragment,omitempty"`
	// contains filtered or unexported fields
}

func (*InitializeFragments) Descriptor deprecated 

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

Deprecated: Use InitializeFragments.ProtoReflect.Descriptor instead.

func (*InitializeFragments) GetFragment 

func (x *InitializeFragments) GetFragment() []*PlanFragment

func (*InitializeFragments) ProtoMessage 

func (*InitializeFragments) ProtoMessage()

func (*InitializeFragments) ProtoReflect 

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

func (*InitializeFragments) Reset 

func (x *InitializeFragments) Reset()

func (*InitializeFragments) String 

func (x *InitializeFragments) String() string

type PlanFragment 

type PlanFragment struct {
	Handle       *bit.FragmentHandle      `protobuf:"bytes,1,opt,name=handle" json:"handle,omitempty"`
	NetworkCost  *float32                 `protobuf:"fixed32,4,opt,name=network_cost,json=networkCost" json:"network_cost,omitempty"`
	CpuCost      *float32                 `protobuf:"fixed32,5,opt,name=cpu_cost,json=cpuCost" json:"cpu_cost,omitempty"`
	DiskCost     *float32                 `protobuf:"fixed32,6,opt,name=disk_cost,json=diskCost" json:"disk_cost,omitempty"`
	MemoryCost   *float32                 `protobuf:"fixed32,7,opt,name=memory_cost,json=memoryCost" json:"memory_cost,omitempty"`
	FragmentJson *string                  `protobuf:"bytes,8,opt,name=fragment_json,json=fragmentJson" json:"fragment_json,omitempty"`
	LeafFragment *bool                    `protobuf:"varint,9,opt,name=leaf_fragment,json=leafFragment" json:"leaf_fragment,omitempty"`
	Assignment   *exec.DrillbitEndpoint   `protobuf:"bytes,10,opt,name=assignment" json:"assignment,omitempty"`
	Foreman      *exec.DrillbitEndpoint   `protobuf:"bytes,11,opt,name=foreman" json:"foreman,omitempty"`
	MemInitial   *int64                   `protobuf:"varint,12,opt,name=mem_initial,json=memInitial,def=20000000" json:"mem_initial,omitempty"` // 20 megs
	MemMax       *int64                   `protobuf:"varint,13,opt,name=mem_max,json=memMax,def=2000000000" json:"mem_max,omitempty"`           // 20 gigs
	Credentials  *shared.UserCredentials  `protobuf:"bytes,14,opt,name=credentials" json:"credentials,omitempty"`
	OptionsJson  *string                  `protobuf:"bytes,15,opt,name=options_json,json=optionsJson" json:"options_json,omitempty"`
	Context      *QueryContextInformation `protobuf:"bytes,16,opt,name=context" json:"context,omitempty"`
	Collector    []*Collector             `protobuf:"bytes,17,rep,name=collector" json:"collector,omitempty"`
	// contains filtered or unexported fields
}

func (*PlanFragment) Descriptor deprecated 

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

Deprecated: Use PlanFragment.ProtoReflect.Descriptor instead.

func (*PlanFragment) GetAssignment 

func (x *PlanFragment) GetAssignment() *exec.DrillbitEndpoint

func (*PlanFragment) GetCollector 

func (x *PlanFragment) GetCollector() []*Collector

func (*PlanFragment) GetContext 

func (x *PlanFragment) GetContext() *QueryContextInformation

func (*PlanFragment) GetCpuCost 

func (x *PlanFragment) GetCpuCost() float32

func (*PlanFragment) GetCredentials 

func (x *PlanFragment) GetCredentials() *shared.UserCredentials

func (*PlanFragment) GetDiskCost 

func (x *PlanFragment) GetDiskCost() float32

func (*PlanFragment) GetForeman 

func (x *PlanFragment) GetForeman() *exec.DrillbitEndpoint

func (*PlanFragment) GetFragmentJson 

func (x *PlanFragment) GetFragmentJson() string

func (*PlanFragment) GetHandle 

func (x *PlanFragment) GetHandle() *bit.FragmentHandle

func (*PlanFragment) GetLeafFragment 

func (x *PlanFragment) GetLeafFragment() bool

func (*PlanFragment) GetMemInitial 

func (x *PlanFragment) GetMemInitial() int64

func (*PlanFragment) GetMemMax 

func (x *PlanFragment) GetMemMax() int64

func (*PlanFragment) GetMemoryCost 

func (x *PlanFragment) GetMemoryCost() float32

func (*PlanFragment) GetNetworkCost 

func (x *PlanFragment) GetNetworkCost() float32

func (*PlanFragment) GetOptionsJson 

func (x *PlanFragment) GetOptionsJson() string

func (*PlanFragment) ProtoMessage 

func (*PlanFragment) ProtoMessage()

func (*PlanFragment) ProtoReflect 

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

func (*PlanFragment) Reset 

func (x *PlanFragment) Reset()

func (*PlanFragment) String 

func (x *PlanFragment) String() string

type QueryContextInformation 

type QueryContextInformation struct {
	QueryStartTime    *int64  `protobuf:"varint,1,opt,name=query_start_time,json=queryStartTime" json:"query_start_time,omitempty"`         // start time of query in milliseconds
	TimeZone          *int32  `protobuf:"varint,2,opt,name=time_zone,json=timeZone" json:"time_zone,omitempty"`                             // timezone of the Drillbit where user is connected
	DefaultSchemaName *string `protobuf:"bytes,3,opt,name=default_schema_name,json=defaultSchemaName" json:"default_schema_name,omitempty"` // default schema in current session when the query is submitted
	SessionId         *string `protobuf:"bytes,4,opt,name=session_id,json=sessionId" json:"session_id,omitempty"`                           // current session id
	// contains filtered or unexported fields
}

func (*QueryContextInformation) Descriptor deprecated 

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

Deprecated: Use QueryContextInformation.ProtoReflect.Descriptor instead.

func (*QueryContextInformation) GetDefaultSchemaName 

func (x *QueryContextInformation) GetDefaultSchemaName() string

func (*QueryContextInformation) GetQueryStartTime 

func (x *QueryContextInformation) GetQueryStartTime() int64

func (*QueryContextInformation) GetSessionId 

func (x *QueryContextInformation) GetSessionId() string

func (*QueryContextInformation) GetTimeZone 

func (x *QueryContextInformation) GetTimeZone() int32

func (*QueryContextInformation) ProtoMessage 

func (*QueryContextInformation) ProtoMessage()

func (*QueryContextInformation) ProtoReflect 

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

func (*QueryContextInformation) Reset 

func (x *QueryContextInformation) Reset()

func (*QueryContextInformation) String 

func (x *QueryContextInformation) String() string

type RpcType 

type RpcType int32

//// BitControl RPC /////// 

const (
	RpcType_HANDSHAKE RpcType = 0
	RpcType_ACK       RpcType = 1
	RpcType_GOODBYE   RpcType = 2
	// bit requests
	RpcType_REQ_INITIALIZE_FRAGMENTS RpcType = 3 // Returns Handle
	RpcType_REQ_CANCEL_FRAGMENT      RpcType = 6 // send a cancellation message for a fragment, returns Ack
	RpcType_REQ_RECEIVER_FINISHED    RpcType = 7
	RpcType_REQ_FRAGMENT_STATUS      RpcType = 8 // send a fragment status, return Ack
	RpcType_REQ_BIT_STATUS           RpcType = 9 // get bit status.
	RpcType_REQ_QUERY_STATUS         RpcType = 10
	RpcType_REQ_QUERY_CANCEL         RpcType = 15
	RpcType_REQ_UNPAUSE_FRAGMENT     RpcType = 16 // send a resume message for a fragment, returns Ack
	RpcType_REQ_CUSTOM               RpcType = 17
	// bit responses
	RpcType_RESP_FRAGMENT_HANDLE RpcType = 11
	RpcType_RESP_FRAGMENT_STATUS RpcType = 12
	RpcType_RESP_BIT_STATUS      RpcType = 13
	RpcType_RESP_QUERY_STATUS    RpcType = 14
	RpcType_RESP_CUSTOM          RpcType = 18
	// both bit request and response
	RpcType_SASL_MESSAGE RpcType = 19
)

func (RpcType) Descriptor 

func (RpcType) Descriptor() protoreflect.EnumDescriptor

func (RpcType) Enum 

func (x RpcType) Enum() *RpcType

func (RpcType) EnumDescriptor deprecated 

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

Deprecated: Use RpcType.Descriptor instead.

func (RpcType) Number 

func (x RpcType) Number() protoreflect.EnumNumber

func (RpcType) String 

func (x RpcType) String() string

func (RpcType) Type 

func (RpcType) Type() protoreflect.EnumType

func (*RpcType) UnmarshalJSON deprecated 

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

Deprecated: Do not use.

type WorkQueueStatus 

type WorkQueueStatus struct {
	Endpoint    *exec.DrillbitEndpoint `protobuf:"bytes,1,opt,name=endpoint" json:"endpoint,omitempty"`
	QueueLength *int32                 `protobuf:"varint,2,opt,name=queue_length,json=queueLength" json:"queue_length,omitempty"`
	ReportTime  *int64                 `protobuf:"varint,3,opt,name=report_time,json=reportTime" json:"report_time,omitempty"`
	// contains filtered or unexported fields
}

func (*WorkQueueStatus) Descriptor deprecated 

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

Deprecated: Use WorkQueueStatus.ProtoReflect.Descriptor instead.

func (*WorkQueueStatus) GetEndpoint 

func (x *WorkQueueStatus) GetEndpoint() *exec.DrillbitEndpoint

func (*WorkQueueStatus) GetQueueLength 

func (x *WorkQueueStatus) GetQueueLength() int32

func (*WorkQueueStatus) GetReportTime 

func (x *WorkQueueStatus) GetReportTime() int64

func (*WorkQueueStatus) ProtoMessage 

func (*WorkQueueStatus) ProtoMessage()

func (*WorkQueueStatus) ProtoReflect 

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

func (*WorkQueueStatus) Reset 

func (x *WorkQueueStatus) Reset()

func (*WorkQueueStatus) String 

func (x *WorkQueueStatus) String() string

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.