scql

package
v0.0.0-...-e0c7ee5 Latest Latest
Warning

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

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

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var (
	InvitationRespond_name = map[int32]string{
		0: "ACCEPT",
		1: "DECLINE",
	}
	InvitationRespond_value = map[string]int32{
		"ACCEPT":  0,
		"DECLINE": 1,
	}
)

Enum value maps for InvitationRespond.

View Source 
var (
	InvitationStatus_name = map[int32]string{
		0: "UNDECIDED",
		1: "ACCEPTED",
		2: "DECLINED",
		3: "INVALID",
	}
	InvitationStatus_value = map[string]int32{
		"UNDECIDED": 0,
		"ACCEPTED":  1,
		"DECLINED":  2,
		"INVALID":   3,
	}
)

Enum value maps for InvitationStatus.

View Source 
var (
	ChecksumCompareResult_name = map[int32]string{
		0: "EQUAL",
		1: "TABLE_SCHEMA_NOT_EQUAL",
		2: "CCL_NOT_EQUAL",
		3: "TABLE_CCL_NOT_EQUAL",
	}
	ChecksumCompareResult_value = map[string]int32{
		"EQUAL":                  0,
		"TABLE_SCHEMA_NOT_EQUAL": 1,
		"CCL_NOT_EQUAL":          2,
		"TABLE_CCL_NOT_EQUAL":    3,
	}
)

Enum value maps for ChecksumCompareResult.

View Source 
var (
	BrokerProtocolVersion_name = map[int32]string{
		0: "BROKER_SERVICE_PROTOCOL_V1",
	}
	BrokerProtocolVersion_value = map[string]int32{
		"BROKER_SERVICE_PROTOCOL_V1": 0,
	}
)

Enum value maps for BrokerProtocolVersion.

View Source 
var (
	Constraint_name = map[int32]string{
		0: "UNKNOWN",
		1: "PLAINTEXT",
		2: "ENCRYPTED_ONLY",
		3: "PLAINTEXT_AFTER_JOIN",
		4: "PLAINTEXT_AFTER_GROUP_BY",
		5: "PLAINTEXT_AFTER_COMPARE",
		6: "PLAINTEXT_AFTER_AGGREGATE",
	}
	Constraint_value = map[string]int32{
		"UNKNOWN":                   0,
		"PLAINTEXT":                 1,
		"ENCRYPTED_ONLY":            2,
		"PLAINTEXT_AFTER_JOIN":      3,
		"PLAINTEXT_AFTER_GROUP_BY":  4,
		"PLAINTEXT_AFTER_COMPARE":   5,
		"PLAINTEXT_AFTER_AGGREGATE": 6,
	}
)

Enum value maps for Constraint.

View Source 
var (
	InviteMemberRequest_InvitationMethod_name = map[int32]string{
		0: "PUSH",
		1: "PULL",
	}
	InviteMemberRequest_InvitationMethod_value = map[string]int32{
		"PUSH": 0,
		"PULL": 1,
	}
)

Enum value maps for InviteMemberRequest_InvitationMethod.

View Source 
var (
	ChangeEntry_Action_name = map[int32]string{
		0: "CreateTable",
		1: "DropTable",
		2: "GrantCCL",
		3: "RevokeCCL",
		4: "AddProjectMember",
		5: "UpdateProjectConf",
		6: "ArchiveProject",
	}
	ChangeEntry_Action_value = map[string]int32{
		"CreateTable":       0,
		"DropTable":         1,
		"GrantCCL":          2,
		"RevokeCCL":         3,
		"AddProjectMember":  4,
		"UpdateProjectConf": 5,
		"ArchiveProject":    6,
	}
)

Enum value maps for ChangeEntry_Action.

View Source 
var (
	ResourceSpec_ResourceKind_name = map[int32]string{
		0: "Project",
		1: "Table",
		2: "CCL",
		3: "All",
	}
	ResourceSpec_ResourceKind_value = map[string]int32{
		"Project": 0,
		"Table":   1,
		"CCL":     2,
		"All":     3,
	}
)

Enum value maps for ResourceSpec_ResourceKind.

View Source 
var (
	SecurityConfig_ColumnControl_Visibility_name = map[int32]string{
		0: "UNKNOWN",
		1: "PLAINTEXT",
		2: "ENCRYPTED_ONLY",
		3: "PLAINTEXT_AFTER_JOIN",
		4: "PLAINTEXT_AFTER_GROUP_BY",
		5: "PLAINTEXT_AFTER_COMPARE",
		6: "PLAINTEXT_AFTER_AGGREGATE",
	}
	SecurityConfig_ColumnControl_Visibility_value = map[string]int32{
		"UNKNOWN":                   0,
		"PLAINTEXT":                 1,
		"ENCRYPTED_ONLY":            2,
		"PLAINTEXT_AFTER_JOIN":      3,
		"PLAINTEXT_AFTER_GROUP_BY":  4,
		"PLAINTEXT_AFTER_COMPARE":   5,
		"PLAINTEXT_AFTER_AGGREGATE": 6,
	}
)

Enum value maps for SecurityConfig_ColumnControl_Visibility.

View Source 
var (
	PrimitiveDataType_name = map[int32]string{
		0:  "PrimitiveDataType_UNDEFINED",
		1:  "INT8",
		2:  "INT16",
		3:  "INT32",
		4:  "INT64",
		5:  "FLOAT32",
		6:  "FLOAT64",
		7:  "BOOL",
		8:  "STRING",
		9:  "DATETIME",
		10: "TIMESTAMP",
	}
	PrimitiveDataType_value = map[string]int32{
		"PrimitiveDataType_UNDEFINED": 0,
		"INT8":                        1,
		"INT16":                       2,
		"INT32":                       3,
		"INT64":                       4,
		"FLOAT32":                     5,
		"FLOAT64":                     6,
		"BOOL":                        7,
		"STRING":                      8,
		"DATETIME":                    9,
		"TIMESTAMP":                   10,
	}
)

Enum value maps for PrimitiveDataType.

View Source 
var (
	TensorOptions_name = map[int32]string{
		0: "VALUE",
		1: "REFERENCE",
		2: "VARIABLE",
	}
	TensorOptions_value = map[string]int32{
		"VALUE":     0,
		"REFERENCE": 1,
		"VARIABLE":  2,
	}
)

Enum value maps for TensorOptions.

View Source 
var (
	TensorStatus_name = map[int32]string{
		0: "TENSORSTATUS_UNKNOWN",
		1: "TENSORSTATUS_PRIVATE",
		2: "TENSORSTATUS_SECRET",
		3: "TENSORSTATUS_CIPHER",
		4: "TENSORSTATUS_PUBLIC",
	}
	TensorStatus_value = map[string]int32{
		"TENSORSTATUS_UNKNOWN": 0,
		"TENSORSTATUS_PRIVATE": 1,
		"TENSORSTATUS_SECRET":  2,
		"TENSORSTATUS_CIPHER":  3,
		"TENSORSTATUS_PUBLIC":  4,
	}
)

Enum value maps for TensorStatus.

View Source 
var (
	FormalParameterOptions_name = map[int32]string{
		0: "FORMALPARAMETEROPTIONS_UNDEFINED",
		1: "FORMALPARAMETEROPTIONS_SINGLE",
		2: "FORMALPARAMETEROPTIONS_OPTIONAL",
		3: "FORMALPARAMETEROPTIONS_VARIADIC",
	}
	FormalParameterOptions_value = map[string]int32{
		"FORMALPARAMETEROPTIONS_UNDEFINED": 0,
		"FORMALPARAMETEROPTIONS_SINGLE":    1,
		"FORMALPARAMETEROPTIONS_OPTIONAL":  2,
		"FORMALPARAMETEROPTIONS_VARIADIC":  3,
	}
)

Enum value maps for FormalParameterOptions.

View Source 
var (
	PsiAlgorithmType_name = map[int32]string{
		0: "AUTO",
		1: "ECDH",
		2: "OPRF",
	}
	PsiAlgorithmType_value = map[string]int32{
		"AUTO": 0,
		"ECDH": 1,
		"OPRF": 2,
	}
)

Enum value maps for PsiAlgorithmType.

View Source 
var (
	User_AccountSystemType_name = map[int32]string{
		0: "UNKNOWN",
		1: "NATIVE_USER",
	}
	User_AccountSystemType_value = map[string]int32{
		"UNKNOWN":     0,
		"NATIVE_USER": 1,
	}
)

Enum value maps for User_AccountSystemType.

View Source 
var (
	Code_name = map[int32]string{
		0:   "OK",
		100: "BAD_REQUEST",
		101: "UNAUTHENTICATED",
		102: "SQL_PARSE_ERROR",
		103: "INVALID_ARGUMENT",
		104: "NOT_READY",
		131: "DDL_PERMISSION_DENIED",
		140: "NOT_FOUND",
		141: "SESSION_NOT_FOUND",
		160: "CCL_CHECK_FAILED",
		170: "DATA_INCONSISTENCY",
		171: "PROJECT_CONFLICT",
		201: "STORAGE_ERROR",
		300: "INTERNAL",
		320: "UNKNOWN_ENGINE_ERROR",
		332: "ENGINE_RUNSQL_ERROR",
		340: "NOT_SUPPORTED",
	}
	Code_value = map[string]int32{
		"OK":                    0,
		"BAD_REQUEST":           100,
		"UNAUTHENTICATED":       101,
		"SQL_PARSE_ERROR":       102,
		"INVALID_ARGUMENT":      103,
		"NOT_READY":             104,
		"DDL_PERMISSION_DENIED": 131,
		"NOT_FOUND":             140,
		"SESSION_NOT_FOUND":     141,
		"CCL_CHECK_FAILED":      160,
		"DATA_INCONSISTENCY":    170,
		"PROJECT_CONFLICT":      171,
		"STORAGE_ERROR":         201,
		"INTERNAL":              300,
		"UNKNOWN_ENGINE_ERROR":  320,
		"ENGINE_RUNSQL_ERROR":   332,
		"NOT_SUPPORTED":         340,
	}
)

Enum value maps for Code.

View Source 
var File_api_broker_proto protoreflect.FileDescriptor
View Source 
var File_api_ccl_proto protoreflect.FileDescriptor
View Source 
var File_api_common_proto protoreflect.FileDescriptor
View Source 
var File_api_core_proto protoreflect.FileDescriptor
View Source 
var File_api_engine_proto protoreflect.FileDescriptor
View Source 
var File_api_interpreter_proto protoreflect.FileDescriptor
View Source 
var File_api_scdb_api_proto protoreflect.FileDescriptor
View Source 
var File_api_status_code_proto protoreflect.FileDescriptor
View Source 
var File_api_status_proto protoreflect.FileDescriptor
View Source 
var File_api_subgraph_proto protoreflect.FileDescriptor

Functions

func RegisterEngineResultCallbackServer 

func RegisterEngineResultCallbackServer(s *grpc.Server, srv EngineResultCallbackServer)

func RegisterInterBrokerServiceServer 

func RegisterInterBrokerServiceServer(s *grpc.Server, srv InterBrokerServiceServer)

func RegisterInterpreterServiceServer 

func RegisterInterpreterServiceServer(s *grpc.Server, srv InterpreterServiceServer)

func RegisterIntraBrokerServiceServer 

func RegisterIntraBrokerServiceServer(s *grpc.Server, srv IntraBrokerServiceServer)

func RegisterSCDBQueryResultCallbackServer 

func RegisterSCDBQueryResultCallbackServer(s *grpc.Server, srv SCDBQueryResultCallbackServer)

func RegisterSCDBServiceServer 

func RegisterSCDBServiceServer(s *grpc.Server, srv SCDBServiceServer)

func RegisterSCQLEngineServiceServer 

func RegisterSCQLEngineServiceServer(s *grpc.Server, srv SCQLEngineServiceServer)

Types

type ArchiveProjectRequest 

type ArchiveProjectRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Comment   string `protobuf:"bytes,2,opt,name=comment,proto3" json:"comment,omitempty"`
	// contains filtered or unexported fields
}

func (*ArchiveProjectRequest) Descriptor deprecated 

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

Deprecated: Use ArchiveProjectRequest.ProtoReflect.Descriptor instead.

func (*ArchiveProjectRequest) GetComment 

func (x *ArchiveProjectRequest) GetComment() string

func (*ArchiveProjectRequest) GetProjectId 

func (x *ArchiveProjectRequest) GetProjectId() string

func (*ArchiveProjectRequest) ProtoMessage 

func (*ArchiveProjectRequest) ProtoMessage()

func (*ArchiveProjectRequest) ProtoReflect 

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

func (*ArchiveProjectRequest) Reset 

func (x *ArchiveProjectRequest) Reset()

func (*ArchiveProjectRequest) String 

func (x *ArchiveProjectRequest) String() string

type ArchiveProjectResponse 

type ArchiveProjectResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ArchiveProjectResponse) Descriptor deprecated 

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

Deprecated: Use ArchiveProjectResponse.ProtoReflect.Descriptor instead.

func (*ArchiveProjectResponse) GetStatus 

func (x *ArchiveProjectResponse) GetStatus() *Status

func (*ArchiveProjectResponse) ProtoMessage 

func (*ArchiveProjectResponse) ProtoMessage()

func (*ArchiveProjectResponse) ProtoReflect 

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

func (*ArchiveProjectResponse) Reset 

func (x *ArchiveProjectResponse) Reset()

func (*ArchiveProjectResponse) String 

func (x *ArchiveProjectResponse) String() string

type AskInfoRequest 

type AskInfoRequest struct {
	ClientId      *PartyId        `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Signature     []byte          `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	ResourceSpecs []*ResourceSpec `protobuf:"bytes,3,rep,name=resource_specs,json=resourceSpecs,proto3" json:"resource_specs,omitempty"`
	// contains filtered or unexported fields
}

func (*AskInfoRequest) Descriptor deprecated 

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

Deprecated: Use AskInfoRequest.ProtoReflect.Descriptor instead.

func (*AskInfoRequest) GetClientId 

func (x *AskInfoRequest) GetClientId() *PartyId

func (*AskInfoRequest) GetResourceSpecs 

func (x *AskInfoRequest) GetResourceSpecs() []*ResourceSpec

func (*AskInfoRequest) GetSignature 

func (x *AskInfoRequest) GetSignature() []byte

func (*AskInfoRequest) ProtoMessage 

func (*AskInfoRequest) ProtoMessage()

func (*AskInfoRequest) ProtoReflect 

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

func (*AskInfoRequest) Reset 

func (x *AskInfoRequest) Reset()

func (*AskInfoRequest) String 

func (x *AskInfoRequest) String() string

type AskInfoResponse 

type AskInfoResponse struct {
	Status *Status  `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Datas  [][]byte `protobuf:"bytes,2,rep,name=datas,proto3" json:"datas,omitempty"`
	// contains filtered or unexported fields
}

func (*AskInfoResponse) Descriptor deprecated 

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

Deprecated: Use AskInfoResponse.ProtoReflect.Descriptor instead.

func (*AskInfoResponse) GetDatas 

func (x *AskInfoResponse) GetDatas() [][]byte

func (*AskInfoResponse) GetStatus 

func (x *AskInfoResponse) GetStatus() *Status

func (*AskInfoResponse) ProtoMessage 

func (*AskInfoResponse) ProtoMessage()

func (*AskInfoResponse) ProtoReflect 

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

func (*AskInfoResponse) Reset 

func (x *AskInfoResponse) Reset()

func (*AskInfoResponse) String 

func (x *AskInfoResponse) String() string

type AttributeValue 

type AttributeValue struct {

	// Types that are assignable to Value:
	//	*AttributeValue_T
	Value isAttributeValue_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*AttributeValue) Descriptor deprecated 

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

Deprecated: Use AttributeValue.ProtoReflect.Descriptor instead.

func (*AttributeValue) GetT 

func (x *AttributeValue) GetT() *Tensor

func (*AttributeValue) GetValue 

func (m *AttributeValue) GetValue() isAttributeValue_Value

func (*AttributeValue) ProtoMessage 

func (*AttributeValue) ProtoMessage()

func (*AttributeValue) ProtoReflect 

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

func (*AttributeValue) Reset 

func (x *AttributeValue) Reset()

func (*AttributeValue) String 

func (x *AttributeValue) String() string

type AttributeValue_T 

type AttributeValue_T struct {
	T *Tensor `protobuf:"bytes,1,opt,name=t,proto3,oneof"`
}

type BrokerProtocolVersion 

type BrokerProtocolVersion int32
const (
	BrokerProtocolVersion_BROKER_SERVICE_PROTOCOL_V1 BrokerProtocolVersion = 0
)

func (BrokerProtocolVersion) Descriptor 

func (BrokerProtocolVersion) Descriptor() protoreflect.EnumDescriptor

func (BrokerProtocolVersion) Enum 

func (x BrokerProtocolVersion) Enum() *BrokerProtocolVersion

func (BrokerProtocolVersion) EnumDescriptor deprecated 

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

Deprecated: Use BrokerProtocolVersion.Descriptor instead.

func (BrokerProtocolVersion) Number 

func (x BrokerProtocolVersion) Number() protoreflect.EnumNumber

func (BrokerProtocolVersion) String 

func (x BrokerProtocolVersion) String() string

func (BrokerProtocolVersion) Type 

func (BrokerProtocolVersion) Type() protoreflect.EnumType

type CancelQueryJobRequest 

type CancelQueryJobRequest struct {
	ClientId  *PartyId `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Signature []byte   `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	JobId     string   `protobuf:"bytes,3,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Reason    string   `protobuf:"bytes,4,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelQueryJobRequest) Descriptor deprecated 

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

Deprecated: Use CancelQueryJobRequest.ProtoReflect.Descriptor instead.

func (*CancelQueryJobRequest) GetClientId 

func (x *CancelQueryJobRequest) GetClientId() *PartyId

func (*CancelQueryJobRequest) GetJobId 

func (x *CancelQueryJobRequest) GetJobId() string

func (*CancelQueryJobRequest) GetReason 

func (x *CancelQueryJobRequest) GetReason() string

func (*CancelQueryJobRequest) GetSignature 

func (x *CancelQueryJobRequest) GetSignature() []byte

func (*CancelQueryJobRequest) ProtoMessage 

func (*CancelQueryJobRequest) ProtoMessage()

func (*CancelQueryJobRequest) ProtoReflect 

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

func (*CancelQueryJobRequest) Reset 

func (x *CancelQueryJobRequest) Reset()

func (*CancelQueryJobRequest) String 

func (x *CancelQueryJobRequest) String() string

type CancelQueryJobResponse 

type CancelQueryJobResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelQueryJobResponse) Descriptor deprecated 

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

Deprecated: Use CancelQueryJobResponse.ProtoReflect.Descriptor instead.

func (*CancelQueryJobResponse) GetStatus 

func (x *CancelQueryJobResponse) GetStatus() *Status

func (*CancelQueryJobResponse) ProtoMessage 

func (*CancelQueryJobResponse) ProtoMessage()

func (*CancelQueryJobResponse) ProtoReflect 

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

func (*CancelQueryJobResponse) Reset 

func (x *CancelQueryJobResponse) Reset()

func (*CancelQueryJobResponse) String 

func (x *CancelQueryJobResponse) String() string

type CancelQueryRequest 

type CancelQueryRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelQueryRequest) Descriptor deprecated 

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

Deprecated: Use CancelQueryRequest.ProtoReflect.Descriptor instead.

func (*CancelQueryRequest) GetJobId 

func (x *CancelQueryRequest) GetJobId() string

func (*CancelQueryRequest) ProtoMessage 

func (*CancelQueryRequest) ProtoMessage()

func (*CancelQueryRequest) ProtoReflect 

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

func (*CancelQueryRequest) Reset 

func (x *CancelQueryRequest) Reset()

func (*CancelQueryRequest) String 

func (x *CancelQueryRequest) String() string

type CancelQueryResponse 

type CancelQueryResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CancelQueryResponse) Descriptor deprecated 

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

Deprecated: Use CancelQueryResponse.ProtoReflect.Descriptor instead.

func (*CancelQueryResponse) GetStatus 

func (x *CancelQueryResponse) GetStatus() *Status

func (*CancelQueryResponse) ProtoMessage 

func (*CancelQueryResponse) ProtoMessage()

func (*CancelQueryResponse) ProtoReflect 

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

func (*CancelQueryResponse) Reset 

func (x *CancelQueryResponse) Reset()

func (*CancelQueryResponse) String 

func (x *CancelQueryResponse) String() string

type Catalog 

type Catalog struct {
	Tables []*TableEntry `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*Catalog) Descriptor deprecated 

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

Deprecated: Use Catalog.ProtoReflect.Descriptor instead.

func (*Catalog) GetTables 

func (x *Catalog) GetTables() []*TableEntry

func (*Catalog) ProtoMessage 

func (*Catalog) ProtoMessage()

func (*Catalog) ProtoReflect 

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

func (*Catalog) Reset 

func (x *Catalog) Reset()

func (*Catalog) String 

func (x *Catalog) String() string

type ChangeEntry 

type ChangeEntry struct {
	Action ChangeEntry_Action `protobuf:"varint,1,opt,name=action,proto3,enum=scql.pb.ChangeEntry_Action" json:"action,omitempty"`
	Data   []byte             `protobuf:"bytes,2,opt,name=data,proto3" json:"data,omitempty"`
	// contains filtered or unexported fields
}

func (*ChangeEntry) Descriptor deprecated 

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

Deprecated: Use ChangeEntry.ProtoReflect.Descriptor instead.

func (*ChangeEntry) GetAction 

func (x *ChangeEntry) GetAction() ChangeEntry_Action

func (*ChangeEntry) GetData 

func (x *ChangeEntry) GetData() []byte

func (*ChangeEntry) ProtoMessage 

func (*ChangeEntry) ProtoMessage()

func (*ChangeEntry) ProtoReflect 

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

func (*ChangeEntry) Reset 

func (x *ChangeEntry) Reset()

func (*ChangeEntry) String 

func (x *ChangeEntry) String() string

type ChangeEntry_Action 

type ChangeEntry_Action int32
const (
	ChangeEntry_CreateTable       ChangeEntry_Action = 0
	ChangeEntry_DropTable         ChangeEntry_Action = 1
	ChangeEntry_GrantCCL          ChangeEntry_Action = 2
	ChangeEntry_RevokeCCL         ChangeEntry_Action = 3
	ChangeEntry_AddProjectMember  ChangeEntry_Action = 4
	ChangeEntry_UpdateProjectConf ChangeEntry_Action = 5
	ChangeEntry_ArchiveProject    ChangeEntry_Action = 6
)

func (ChangeEntry_Action) Descriptor 

func (ChangeEntry_Action) Descriptor() protoreflect.EnumDescriptor

func (ChangeEntry_Action) Enum 

func (x ChangeEntry_Action) Enum() *ChangeEntry_Action

func (ChangeEntry_Action) EnumDescriptor deprecated 

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

Deprecated: Use ChangeEntry_Action.Descriptor instead.

func (ChangeEntry_Action) Number 

func (x ChangeEntry_Action) Number() protoreflect.EnumNumber

func (ChangeEntry_Action) String 

func (x ChangeEntry_Action) String() string

func (ChangeEntry_Action) Type 

func (ChangeEntry_Action) Type() protoreflect.EnumType

type CheckAndUpdateStatusRequest 

type CheckAndUpdateStatusRequest struct {
	ProjectIds []string `protobuf:"bytes,1,rep,name=project_ids,json=projectIds,proto3" json:"project_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*CheckAndUpdateStatusRequest) Descriptor deprecated 

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

Deprecated: Use CheckAndUpdateStatusRequest.ProtoReflect.Descriptor instead.

func (*CheckAndUpdateStatusRequest) GetProjectIds 

func (x *CheckAndUpdateStatusRequest) GetProjectIds() []string

func (*CheckAndUpdateStatusRequest) ProtoMessage 

func (*CheckAndUpdateStatusRequest) ProtoMessage()

func (*CheckAndUpdateStatusRequest) ProtoReflect 

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

func (*CheckAndUpdateStatusRequest) Reset 

func (x *CheckAndUpdateStatusRequest) Reset()

func (*CheckAndUpdateStatusRequest) String 

func (x *CheckAndUpdateStatusRequest) String() string

type CheckAndUpdateStatusResponse 

type CheckAndUpdateStatusResponse struct {
	Status   *Status                     `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Conficts map[string]*ProjectConflict `` /* 157-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*CheckAndUpdateStatusResponse) Descriptor deprecated 

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

Deprecated: Use CheckAndUpdateStatusResponse.ProtoReflect.Descriptor instead.

func (*CheckAndUpdateStatusResponse) GetConficts 

func (x *CheckAndUpdateStatusResponse) GetConficts() map[string]*ProjectConflict

func (*CheckAndUpdateStatusResponse) GetStatus 

func (x *CheckAndUpdateStatusResponse) GetStatus() *Status

func (*CheckAndUpdateStatusResponse) ProtoMessage 

func (*CheckAndUpdateStatusResponse) ProtoMessage()

func (*CheckAndUpdateStatusResponse) ProtoReflect 

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

func (*CheckAndUpdateStatusResponse) Reset 

func (x *CheckAndUpdateStatusResponse) Reset()

func (*CheckAndUpdateStatusResponse) String 

func (x *CheckAndUpdateStatusResponse) String() string

type Checksum 

type Checksum struct {
	TableSchema []byte `protobuf:"bytes,1,opt,name=table_schema,json=tableSchema,proto3" json:"table_schema,omitempty"`
	Ccl         []byte `protobuf:"bytes,2,opt,name=ccl,proto3" json:"ccl,omitempty"`
	// contains filtered or unexported fields
}

func (*Checksum) Descriptor deprecated 

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

Deprecated: Use Checksum.ProtoReflect.Descriptor instead.

func (*Checksum) GetCcl 

func (x *Checksum) GetCcl() []byte

func (*Checksum) GetTableSchema 

func (x *Checksum) GetTableSchema() []byte

func (*Checksum) ProtoMessage 

func (*Checksum) ProtoMessage()

func (*Checksum) ProtoReflect 

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

func (*Checksum) Reset 

func (x *Checksum) Reset()

func (*Checksum) String 

func (x *Checksum) String() string

type ChecksumCompareResult 

type ChecksumCompareResult int32
const (
	ChecksumCompareResult_EQUAL                  ChecksumCompareResult = 0
	ChecksumCompareResult_TABLE_SCHEMA_NOT_EQUAL ChecksumCompareResult = 1
	ChecksumCompareResult_CCL_NOT_EQUAL          ChecksumCompareResult = 2
	ChecksumCompareResult_TABLE_CCL_NOT_EQUAL    ChecksumCompareResult = 3
)

func (ChecksumCompareResult) Descriptor 

func (ChecksumCompareResult) Descriptor() protoreflect.EnumDescriptor

func (ChecksumCompareResult) Enum 

func (x ChecksumCompareResult) Enum() *ChecksumCompareResult

func (ChecksumCompareResult) EnumDescriptor deprecated 

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

Deprecated: Use ChecksumCompareResult.Descriptor instead.

func (ChecksumCompareResult) Number 

func (x ChecksumCompareResult) Number() protoreflect.EnumNumber

func (ChecksumCompareResult) String 

func (x ChecksumCompareResult) String() string

func (ChecksumCompareResult) Type 

func (ChecksumCompareResult) Type() protoreflect.EnumType

type Code 

type Code int32
const (
	Code_OK                    Code = 0
	Code_BAD_REQUEST           Code = 100
	Code_UNAUTHENTICATED       Code = 101
	Code_SQL_PARSE_ERROR       Code = 102
	Code_INVALID_ARGUMENT      Code = 103
	Code_NOT_READY             Code = 104
	Code_DDL_PERMISSION_DENIED Code = 131
	Code_NOT_FOUND             Code = 140
	Code_SESSION_NOT_FOUND     Code = 141
	Code_CCL_CHECK_FAILED      Code = 160
	Code_DATA_INCONSISTENCY    Code = 170
	Code_PROJECT_CONFLICT      Code = 171
	Code_STORAGE_ERROR         Code = 201
	Code_INTERNAL              Code = 300
	Code_UNKNOWN_ENGINE_ERROR  Code = 320
	Code_ENGINE_RUNSQL_ERROR   Code = 332
	Code_NOT_SUPPORTED         Code = 340
)

func (Code) Descriptor 

func (Code) Descriptor() protoreflect.EnumDescriptor

func (Code) Enum 

func (x Code) Enum() *Code

func (Code) EnumDescriptor deprecated 

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

Deprecated: Use Code.Descriptor instead.

func (Code) Number 

func (x Code) Number() protoreflect.EnumNumber

func (Code) String 

func (x Code) String() string

func (Code) Type 

func (Code) Type() protoreflect.EnumType

type ColumnControl 

type ColumnControl struct {
	Col        *ColumnDef `protobuf:"bytes,1,opt,name=col,proto3" json:"col,omitempty"`
	PartyCode  string     `protobuf:"bytes,2,opt,name=party_code,json=partyCode,proto3" json:"party_code,omitempty"`
	Constraint Constraint `protobuf:"varint,3,opt,name=constraint,proto3,enum=scql.pb.Constraint" json:"constraint,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnControl) Descriptor deprecated 

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

Deprecated: Use ColumnControl.ProtoReflect.Descriptor instead.

func (*ColumnControl) GetCol 

func (x *ColumnControl) GetCol() *ColumnDef

func (*ColumnControl) GetConstraint 

func (x *ColumnControl) GetConstraint() Constraint

func (*ColumnControl) GetPartyCode 

func (x *ColumnControl) GetPartyCode() string

func (*ColumnControl) ProtoMessage 

func (*ColumnControl) ProtoMessage()

func (*ColumnControl) ProtoReflect 

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

func (*ColumnControl) Reset 

func (x *ColumnControl) Reset()

func (*ColumnControl) String 

func (x *ColumnControl) String() string

type ColumnDef 

type ColumnDef struct {
	ColumnName string `protobuf:"bytes,1,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	TableName  string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnDef) Descriptor deprecated 

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

Deprecated: Use ColumnDef.ProtoReflect.Descriptor instead.

func (*ColumnDef) GetColumnName 

func (x *ColumnDef) GetColumnName() string

func (*ColumnDef) GetTableName 

func (x *ColumnDef) GetTableName() string

func (*ColumnDef) ProtoMessage 

func (*ColumnDef) ProtoMessage()

func (*ColumnDef) ProtoReflect 

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

func (*ColumnDef) Reset 

func (x *ColumnDef) Reset()

func (*ColumnDef) String 

func (x *ColumnDef) String() string

type ColumnDesc 

type ColumnDesc struct {
	Name string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	// contains filtered or unexported fields
}

func (*ColumnDesc) Descriptor deprecated 

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

Deprecated: Use ColumnDesc.ProtoReflect.Descriptor instead.

func (*ColumnDesc) GetName 

func (x *ColumnDesc) GetName() string

func (*ColumnDesc) GetType 

func (x *ColumnDesc) GetType() string

func (*ColumnDesc) ProtoMessage 

func (*ColumnDesc) ProtoMessage()

func (*ColumnDesc) ProtoReflect 

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

func (*ColumnDesc) Reset 

func (x *ColumnDesc) Reset()

func (*ColumnDesc) String 

func (x *ColumnDesc) String() string

type CompileOptions 

type CompileOptions struct {
	SpuConf            *spu.RuntimeConfig        `protobuf:"bytes,1,opt,name=spu_conf,json=spuConf,proto3" json:"spu_conf,omitempty"`
	SecurityCompromise *SecurityCompromiseConfig `protobuf:"bytes,2,opt,name=security_compromise,json=securityCompromise,proto3" json:"security_compromise,omitempty"`
	DumpExeGraph       bool                      `protobuf:"varint,3,opt,name=dump_exe_graph,json=dumpExeGraph,proto3" json:"dump_exe_graph,omitempty"`
	OptimizerHints     *OptimizerHints           `protobuf:"bytes,4,opt,name=optimizer_hints,json=optimizerHints,proto3" json:"optimizer_hints,omitempty"`
	// contains filtered or unexported fields
}

func (*CompileOptions) Descriptor deprecated 

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

Deprecated: Use CompileOptions.ProtoReflect.Descriptor instead.

func (*CompileOptions) GetDumpExeGraph 

func (x *CompileOptions) GetDumpExeGraph() bool

func (*CompileOptions) GetOptimizerHints 

func (x *CompileOptions) GetOptimizerHints() *OptimizerHints

func (*CompileOptions) GetSecurityCompromise 

func (x *CompileOptions) GetSecurityCompromise() *SecurityCompromiseConfig

func (*CompileOptions) GetSpuConf 

func (x *CompileOptions) GetSpuConf() *spu.RuntimeConfig

func (*CompileOptions) ProtoMessage 

func (*CompileOptions) ProtoMessage()

func (*CompileOptions) ProtoReflect 

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

func (*CompileOptions) Reset 

func (x *CompileOptions) Reset()

func (*CompileOptions) String 

func (x *CompileOptions) String() string

type CompileQueryRequest 

type CompileQueryRequest struct {
	Query               string          `protobuf:"bytes,1,opt,name=query,proto3" json:"query,omitempty"`
	DbName              string          `protobuf:"bytes,2,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	Issuer              *PartyId        `protobuf:"bytes,3,opt,name=issuer,proto3" json:"issuer,omitempty"`
	IssuerAsParticipant bool            `protobuf:"varint,4,opt,name=issuer_as_participant,json=issuerAsParticipant,proto3" json:"issuer_as_participant,omitempty"`
	SecurityConf        *SecurityConfig `protobuf:"bytes,5,opt,name=security_conf,json=securityConf,proto3" json:"security_conf,omitempty"`
	Catalog             *Catalog        `protobuf:"bytes,6,opt,name=catalog,proto3" json:"catalog,omitempty"`
	CompileOpts         *CompileOptions `protobuf:"bytes,7,opt,name=compile_opts,json=compileOpts,proto3" json:"compile_opts,omitempty"`
	// contains filtered or unexported fields
}

func (*CompileQueryRequest) Descriptor deprecated 

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

Deprecated: Use CompileQueryRequest.ProtoReflect.Descriptor instead.

func (*CompileQueryRequest) GetCatalog 

func (x *CompileQueryRequest) GetCatalog() *Catalog

func (*CompileQueryRequest) GetCompileOpts 

func (x *CompileQueryRequest) GetCompileOpts() *CompileOptions

func (*CompileQueryRequest) GetDbName 

func (x *CompileQueryRequest) GetDbName() string

func (*CompileQueryRequest) GetIssuer 

func (x *CompileQueryRequest) GetIssuer() *PartyId

func (*CompileQueryRequest) GetIssuerAsParticipant 

func (x *CompileQueryRequest) GetIssuerAsParticipant() bool

func (*CompileQueryRequest) GetQuery 

func (x *CompileQueryRequest) GetQuery() string

func (*CompileQueryRequest) GetSecurityConf 

func (x *CompileQueryRequest) GetSecurityConf() *SecurityConfig

func (*CompileQueryRequest) ProtoMessage 

func (*CompileQueryRequest) ProtoMessage()

func (*CompileQueryRequest) ProtoReflect 

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

func (*CompileQueryRequest) Reset 

func (x *CompileQueryRequest) Reset()

func (*CompileQueryRequest) String 

func (x *CompileQueryRequest) String() string

type CompileQueryResponse 

type CompileQueryResponse struct {
	Status *Status       `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Plan   *CompiledPlan `protobuf:"bytes,2,opt,name=plan,proto3" json:"plan,omitempty"`
	// contains filtered or unexported fields
}

func (*CompileQueryResponse) Descriptor deprecated 

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

Deprecated: Use CompileQueryResponse.ProtoReflect.Descriptor instead.

func (*CompileQueryResponse) GetPlan 

func (x *CompileQueryResponse) GetPlan() *CompiledPlan

func (*CompileQueryResponse) GetStatus 

func (x *CompileQueryResponse) GetStatus() *Status

func (*CompileQueryResponse) ProtoMessage 

func (*CompileQueryResponse) ProtoMessage()

func (*CompileQueryResponse) ProtoReflect 

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

func (*CompileQueryResponse) Reset 

func (x *CompileQueryResponse) Reset()

func (*CompileQueryResponse) String 

func (x *CompileQueryResponse) String() string

type CompiledPlan 

type CompiledPlan struct {
	Schema         *TableSchema         `protobuf:"bytes,1,opt,name=schema,proto3" json:"schema,omitempty"`
	Warning        *Warning             `protobuf:"bytes,2,opt,name=warning,proto3" json:"warning,omitempty"`
	SpuRuntimeConf *spu.RuntimeConfig   `protobuf:"bytes,3,opt,name=spu_runtime_conf,json=spuRuntimeConf,proto3" json:"spu_runtime_conf,omitempty"`
	Parties        []*PartyId           `protobuf:"bytes,4,rep,name=parties,proto3" json:"parties,omitempty"`
	SubGraphs      map[string]*SubGraph `` /* 176-byte string literal not displayed */
	Explain        *ExplainInfo         `protobuf:"bytes,1000,opt,name=explain,proto3" json:"explain,omitempty"`
	// contains filtered or unexported fields
}

func (*CompiledPlan) Descriptor deprecated 

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

Deprecated: Use CompiledPlan.ProtoReflect.Descriptor instead.

func (*CompiledPlan) GetExplain 

func (x *CompiledPlan) GetExplain() *ExplainInfo

func (*CompiledPlan) GetParties 

func (x *CompiledPlan) GetParties() []*PartyId

func (*CompiledPlan) GetSchema 

func (x *CompiledPlan) GetSchema() *TableSchema

func (*CompiledPlan) GetSpuRuntimeConf 

func (x *CompiledPlan) GetSpuRuntimeConf() *spu.RuntimeConfig

func (*CompiledPlan) GetSubGraphs 

func (x *CompiledPlan) GetSubGraphs() map[string]*SubGraph

func (*CompiledPlan) GetWarning 

func (x *CompiledPlan) GetWarning() *Warning

func (*CompiledPlan) ProtoMessage 

func (*CompiledPlan) ProtoMessage()

func (*CompiledPlan) ProtoReflect 

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

func (*CompiledPlan) Reset 

func (x *CompiledPlan) Reset()

func (*CompiledPlan) String 

func (x *CompiledPlan) String() string

type Constraint 

type Constraint int32
const (
	Constraint_UNKNOWN                   Constraint = 0
	Constraint_PLAINTEXT                 Constraint = 1
	Constraint_ENCRYPTED_ONLY            Constraint = 2
	Constraint_PLAINTEXT_AFTER_JOIN      Constraint = 3
	Constraint_PLAINTEXT_AFTER_GROUP_BY  Constraint = 4
	Constraint_PLAINTEXT_AFTER_COMPARE   Constraint = 5
	Constraint_PLAINTEXT_AFTER_AGGREGATE Constraint = 6
)

func (Constraint) Descriptor 

func (Constraint) Descriptor() protoreflect.EnumDescriptor

func (Constraint) Enum 

func (x Constraint) Enum() *Constraint

func (Constraint) EnumDescriptor deprecated 

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

Deprecated: Use Constraint.Descriptor instead.

func (Constraint) Number 

func (x Constraint) Number() protoreflect.EnumNumber

func (Constraint) String 

func (x Constraint) String() string

func (Constraint) Type 

func (Constraint) Type() protoreflect.EnumType

type CreateProjectRequest 

type CreateProjectRequest struct {
	ProjectId   string         `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Name        string         `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string         `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Conf        *ProjectConfig `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateProjectRequest) Descriptor deprecated 

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

Deprecated: Use CreateProjectRequest.ProtoReflect.Descriptor instead.

func (*CreateProjectRequest) GetConf 

func (x *CreateProjectRequest) GetConf() *ProjectConfig

func (*CreateProjectRequest) GetDescription 

func (x *CreateProjectRequest) GetDescription() string

func (*CreateProjectRequest) GetName 

func (x *CreateProjectRequest) GetName() string

func (*CreateProjectRequest) GetProjectId 

func (x *CreateProjectRequest) GetProjectId() string

func (*CreateProjectRequest) ProtoMessage 

func (*CreateProjectRequest) ProtoMessage()

func (*CreateProjectRequest) ProtoReflect 

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

func (*CreateProjectRequest) Reset 

func (x *CreateProjectRequest) Reset()

func (*CreateProjectRequest) String 

func (x *CreateProjectRequest) String() string

type CreateProjectResponse 

type CreateProjectResponse struct {
	Status    *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ProjectId string  `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateProjectResponse) Descriptor deprecated 

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

Deprecated: Use CreateProjectResponse.ProtoReflect.Descriptor instead.

func (*CreateProjectResponse) GetProjectId 

func (x *CreateProjectResponse) GetProjectId() string

func (*CreateProjectResponse) GetStatus 

func (x *CreateProjectResponse) GetStatus() *Status

func (*CreateProjectResponse) ProtoMessage 

func (*CreateProjectResponse) ProtoMessage()

func (*CreateProjectResponse) ProtoReflect 

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

func (*CreateProjectResponse) Reset 

func (x *CreateProjectResponse) Reset()

func (*CreateProjectResponse) String 

func (x *CreateProjectResponse) String() string

type CreateTableRequest 

type CreateTableRequest struct {
	ProjectId string                           `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	TableName string                           `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	RefTable  string                           `protobuf:"bytes,3,opt,name=ref_table,json=refTable,proto3" json:"ref_table,omitempty"`
	DbType    string                           `protobuf:"bytes,4,opt,name=db_type,json=dbType,proto3" json:"db_type,omitempty"`
	Columns   []*CreateTableRequest_ColumnDesc `protobuf:"bytes,5,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTableRequest) Descriptor deprecated 

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

Deprecated: Use CreateTableRequest.ProtoReflect.Descriptor instead.

func (*CreateTableRequest) GetColumns 

func (x *CreateTableRequest) GetColumns() []*CreateTableRequest_ColumnDesc

func (*CreateTableRequest) GetDbType 

func (x *CreateTableRequest) GetDbType() string

func (*CreateTableRequest) GetProjectId 

func (x *CreateTableRequest) GetProjectId() string

func (*CreateTableRequest) GetRefTable 

func (x *CreateTableRequest) GetRefTable() string

func (*CreateTableRequest) GetTableName 

func (x *CreateTableRequest) GetTableName() string

func (*CreateTableRequest) ProtoMessage 

func (*CreateTableRequest) ProtoMessage()

func (*CreateTableRequest) ProtoReflect 

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

func (*CreateTableRequest) Reset 

func (x *CreateTableRequest) Reset()

func (*CreateTableRequest) String 

func (x *CreateTableRequest) String() string

type CreateTableRequest_ColumnDesc 

type CreateTableRequest_ColumnDesc struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Dtype string `protobuf:"bytes,2,opt,name=dtype,proto3" json:"dtype,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTableRequest_ColumnDesc) Descriptor deprecated 

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

Deprecated: Use CreateTableRequest_ColumnDesc.ProtoReflect.Descriptor instead.

func (*CreateTableRequest_ColumnDesc) GetDtype 

func (x *CreateTableRequest_ColumnDesc) GetDtype() string

func (*CreateTableRequest_ColumnDesc) GetName 

func (x *CreateTableRequest_ColumnDesc) GetName() string

func (*CreateTableRequest_ColumnDesc) ProtoMessage 

func (*CreateTableRequest_ColumnDesc) ProtoMessage()

func (*CreateTableRequest_ColumnDesc) ProtoReflect 

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

func (*CreateTableRequest_ColumnDesc) Reset 

func (x *CreateTableRequest_ColumnDesc) Reset()

func (*CreateTableRequest_ColumnDesc) String 

func (x *CreateTableRequest_ColumnDesc) String() string

type CreateTableResponse 

type CreateTableResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*CreateTableResponse) Descriptor deprecated 

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

Deprecated: Use CreateTableResponse.ProtoReflect.Descriptor instead.

func (*CreateTableResponse) GetStatus 

func (x *CreateTableResponse) GetStatus() *Status

func (*CreateTableResponse) ProtoMessage 

func (*CreateTableResponse) ProtoMessage()

func (*CreateTableResponse) ProtoReflect 

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

func (*CreateTableResponse) Reset 

func (x *CreateTableResponse) Reset()

func (*CreateTableResponse) String 

func (x *CreateTableResponse) String() string

type DebugOptions 

type DebugOptions struct {
	EnablePsiDetailLog bool `protobuf:"varint,1,opt,name=enable_psi_detail_log,json=enablePsiDetailLog,proto3" json:"enable_psi_detail_log,omitempty"`
	// contains filtered or unexported fields
}

func (*DebugOptions) Descriptor deprecated 

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

Deprecated: Use DebugOptions.ProtoReflect.Descriptor instead.

func (*DebugOptions) GetEnablePsiDetailLog 

func (x *DebugOptions) GetEnablePsiDetailLog() bool

func (*DebugOptions) ProtoMessage 

func (*DebugOptions) ProtoMessage()

func (*DebugOptions) ProtoReflect 

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

func (*DebugOptions) Reset 

func (x *DebugOptions) Reset()

func (*DebugOptions) String 

func (x *DebugOptions) String() string

type DistributeQueryRequest 

type DistributeQueryRequest struct {
	Header         *RequestHeader        `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ClientProtocol BrokerProtocolVersion `` /* 139-byte string literal not displayed */
	ClientId       *PartyId              `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Signature      []byte                `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	ProjectId      string                `protobuf:"bytes,5,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	JobId          string                `protobuf:"bytes,6,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	Query          string                `protobuf:"bytes,7,opt,name=query,proto3" json:"query,omitempty"`
	EngineEndpoint string                `protobuf:"bytes,8,opt,name=engine_endpoint,json=engineEndpoint,proto3" json:"engine_endpoint,omitempty"`
	ClientChecksum *Checksum             `protobuf:"bytes,9,opt,name=client_checksum,json=clientChecksum,proto3" json:"client_checksum,omitempty"`
	ServerChecksum *Checksum             `protobuf:"bytes,10,opt,name=server_checksum,json=serverChecksum,proto3" json:"server_checksum,omitempty"`
	IsAsync        bool                  `protobuf:"varint,11,opt,name=is_async,json=isAsync,proto3" json:"is_async,omitempty"`
	DebugOpts      *DebugOptions         `protobuf:"bytes,12,opt,name=debug_opts,json=debugOpts,proto3" json:"debug_opts,omitempty"`
	DryRun         bool                  `protobuf:"varint,13,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

func (*DistributeQueryRequest) Descriptor deprecated 

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

Deprecated: Use DistributeQueryRequest.ProtoReflect.Descriptor instead.

func (*DistributeQueryRequest) GetClientChecksum 

func (x *DistributeQueryRequest) GetClientChecksum() *Checksum

func (*DistributeQueryRequest) GetClientId 

func (x *DistributeQueryRequest) GetClientId() *PartyId

func (*DistributeQueryRequest) GetClientProtocol 

func (x *DistributeQueryRequest) GetClientProtocol() BrokerProtocolVersion

func (*DistributeQueryRequest) GetDebugOpts 

func (x *DistributeQueryRequest) GetDebugOpts() *DebugOptions

func (*DistributeQueryRequest) GetDryRun 

func (x *DistributeQueryRequest) GetDryRun() bool

func (*DistributeQueryRequest) GetEngineEndpoint 

func (x *DistributeQueryRequest) GetEngineEndpoint() string

func (*DistributeQueryRequest) GetHeader 

func (x *DistributeQueryRequest) GetHeader() *RequestHeader

func (*DistributeQueryRequest) GetIsAsync 

func (x *DistributeQueryRequest) GetIsAsync() bool

func (*DistributeQueryRequest) GetJobId 

func (x *DistributeQueryRequest) GetJobId() string

func (*DistributeQueryRequest) GetProjectId 

func (x *DistributeQueryRequest) GetProjectId() string

func (*DistributeQueryRequest) GetQuery 

func (x *DistributeQueryRequest) GetQuery() string

func (*DistributeQueryRequest) GetServerChecksum 

func (x *DistributeQueryRequest) GetServerChecksum() *Checksum

func (*DistributeQueryRequest) GetSignature 

func (x *DistributeQueryRequest) GetSignature() []byte

func (*DistributeQueryRequest) ProtoMessage 

func (*DistributeQueryRequest) ProtoMessage()

func (*DistributeQueryRequest) ProtoReflect 

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

func (*DistributeQueryRequest) Reset 

func (x *DistributeQueryRequest) Reset()

func (*DistributeQueryRequest) String 

func (x *DistributeQueryRequest) String() string

type DistributeQueryResponse 

type DistributeQueryResponse struct {
	Status                 *Status               `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ServerProtocol         BrokerProtocolVersion `` /* 139-byte string literal not displayed */
	EngineEndpoint         string                `protobuf:"bytes,3,opt,name=engine_endpoint,json=engineEndpoint,proto3" json:"engine_endpoint,omitempty"`
	ClientChecksumResult   ChecksumCompareResult `` /* 159-byte string literal not displayed */
	ServerChecksumResult   ChecksumCompareResult `` /* 159-byte string literal not displayed */
	ExpectedServerChecksum *Checksum             `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*DistributeQueryResponse) Descriptor deprecated 

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

Deprecated: Use DistributeQueryResponse.ProtoReflect.Descriptor instead.

func (*DistributeQueryResponse) GetClientChecksumResult 

func (x *DistributeQueryResponse) GetClientChecksumResult() ChecksumCompareResult

func (*DistributeQueryResponse) GetEngineEndpoint 

func (x *DistributeQueryResponse) GetEngineEndpoint() string

func (*DistributeQueryResponse) GetExpectedServerChecksum 

func (x *DistributeQueryResponse) GetExpectedServerChecksum() *Checksum

func (*DistributeQueryResponse) GetServerChecksumResult 

func (x *DistributeQueryResponse) GetServerChecksumResult() ChecksumCompareResult

func (*DistributeQueryResponse) GetServerProtocol 

func (x *DistributeQueryResponse) GetServerProtocol() BrokerProtocolVersion

func (*DistributeQueryResponse) GetStatus 

func (x *DistributeQueryResponse) GetStatus() *Status

func (*DistributeQueryResponse) ProtoMessage 

func (*DistributeQueryResponse) ProtoMessage()

func (*DistributeQueryResponse) ProtoReflect 

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

func (*DistributeQueryResponse) Reset 

func (x *DistributeQueryResponse) Reset()

func (*DistributeQueryResponse) String 

func (x *DistributeQueryResponse) String() string

type DropTableRequest 

type DropTableRequest struct {
	ProjectId string `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	TableName string `protobuf:"bytes,2,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	// contains filtered or unexported fields
}

func (*DropTableRequest) Descriptor deprecated 

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

Deprecated: Use DropTableRequest.ProtoReflect.Descriptor instead.

func (*DropTableRequest) GetProjectId 

func (x *DropTableRequest) GetProjectId() string

func (*DropTableRequest) GetTableName 

func (x *DropTableRequest) GetTableName() string

func (*DropTableRequest) ProtoMessage 

func (*DropTableRequest) ProtoMessage()

func (*DropTableRequest) ProtoReflect 

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

func (*DropTableRequest) Reset 

func (x *DropTableRequest) Reset()

func (*DropTableRequest) String 

func (x *DropTableRequest) String() string

type DropTableResponse 

type DropTableResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*DropTableResponse) Descriptor deprecated 

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

Deprecated: Use DropTableResponse.ProtoReflect.Descriptor instead.

func (*DropTableResponse) GetStatus 

func (x *DropTableResponse) GetStatus() *Status

func (*DropTableResponse) ProtoMessage 

func (*DropTableResponse) ProtoMessage()

func (*DropTableResponse) ProtoReflect 

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

func (*DropTableResponse) Reset 

func (x *DropTableResponse) Reset()

func (*DropTableResponse) String 

func (x *DropTableResponse) String() string

type EngineResultCallbackClient 

type EngineResultCallbackClient interface {
	Report(ctx context.Context, in *ReportRequest, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

EngineResultCallbackClient is the client API for EngineResultCallback service.

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

func NewEngineResultCallbackClient 

func NewEngineResultCallbackClient(cc grpc.ClientConnInterface) EngineResultCallbackClient

type EngineResultCallbackServer 

type EngineResultCallbackServer interface {
	Report(context.Context, *ReportRequest) (*emptypb.Empty, error)
}

EngineResultCallbackServer is the server API for EngineResultCallback service.

type ExchangeJobInfoRequest 

type ExchangeJobInfoRequest struct {
	ProjectId      string    `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	JobId          string    `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	ClientId       *PartyId  `protobuf:"bytes,3,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Signature      []byte    `protobuf:"bytes,4,opt,name=signature,proto3" json:"signature,omitempty"`
	ServerChecksum *Checksum `protobuf:"bytes,5,opt,name=server_checksum,json=serverChecksum,proto3" json:"server_checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*ExchangeJobInfoRequest) Descriptor deprecated 

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

Deprecated: Use ExchangeJobInfoRequest.ProtoReflect.Descriptor instead.

func (*ExchangeJobInfoRequest) GetClientId 

func (x *ExchangeJobInfoRequest) GetClientId() *PartyId

func (*ExchangeJobInfoRequest) GetJobId 

func (x *ExchangeJobInfoRequest) GetJobId() string

func (*ExchangeJobInfoRequest) GetProjectId 

func (x *ExchangeJobInfoRequest) GetProjectId() string

func (*ExchangeJobInfoRequest) GetServerChecksum 

func (x *ExchangeJobInfoRequest) GetServerChecksum() *Checksum

func (*ExchangeJobInfoRequest) GetSignature 

func (x *ExchangeJobInfoRequest) GetSignature() []byte

func (*ExchangeJobInfoRequest) ProtoMessage 

func (*ExchangeJobInfoRequest) ProtoMessage()

func (*ExchangeJobInfoRequest) ProtoReflect 

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

func (*ExchangeJobInfoRequest) Reset 

func (x *ExchangeJobInfoRequest) Reset()

func (*ExchangeJobInfoRequest) String 

func (x *ExchangeJobInfoRequest) String() string

type ExchangeJobInfoResponse 

type ExchangeJobInfoResponse struct {
	Status                 *Status               `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Endpoint               string                `protobuf:"bytes,2,opt,name=endpoint,proto3" json:"endpoint,omitempty"`
	ServerChecksumResult   ChecksumCompareResult `` /* 159-byte string literal not displayed */
	ExpectedServerChecksum *Checksum             `` /* 129-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExchangeJobInfoResponse) Descriptor deprecated 

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

Deprecated: Use ExchangeJobInfoResponse.ProtoReflect.Descriptor instead.

func (*ExchangeJobInfoResponse) GetEndpoint 

func (x *ExchangeJobInfoResponse) GetEndpoint() string

func (*ExchangeJobInfoResponse) GetExpectedServerChecksum 

func (x *ExchangeJobInfoResponse) GetExpectedServerChecksum() *Checksum

func (*ExchangeJobInfoResponse) GetServerChecksumResult 

func (x *ExchangeJobInfoResponse) GetServerChecksumResult() ChecksumCompareResult

func (*ExchangeJobInfoResponse) GetStatus 

func (x *ExchangeJobInfoResponse) GetStatus() *Status

func (*ExchangeJobInfoResponse) ProtoMessage 

func (*ExchangeJobInfoResponse) ProtoMessage()

func (*ExchangeJobInfoResponse) ProtoReflect 

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

func (*ExchangeJobInfoResponse) Reset 

func (x *ExchangeJobInfoResponse) Reset()

func (*ExchangeJobInfoResponse) String 

func (x *ExchangeJobInfoResponse) String() string

type ExecNode 

type ExecNode struct {
	NodeName   string                     `protobuf:"bytes,1,opt,name=node_name,json=nodeName,proto3" json:"node_name,omitempty"`
	OpType     string                     `protobuf:"bytes,2,opt,name=op_type,json=opType,proto3" json:"op_type,omitempty"`
	Inputs     map[string]*TensorList     `` /* 153-byte string literal not displayed */
	Outputs    map[string]*TensorList     `` /* 155-byte string literal not displayed */
	Attributes map[string]*AttributeValue `` /* 161-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*ExecNode) Descriptor deprecated 

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

Deprecated: Use ExecNode.ProtoReflect.Descriptor instead.

func (*ExecNode) GetAttributes 

func (x *ExecNode) GetAttributes() map[string]*AttributeValue

func (*ExecNode) GetInputs 

func (x *ExecNode) GetInputs() map[string]*TensorList

func (*ExecNode) GetNodeName 

func (x *ExecNode) GetNodeName() string

func (*ExecNode) GetOpType 

func (x *ExecNode) GetOpType() string

func (*ExecNode) GetOutputs 

func (x *ExecNode) GetOutputs() map[string]*TensorList

func (*ExecNode) ProtoMessage 

func (*ExecNode) ProtoMessage()

func (*ExecNode) ProtoReflect 

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

func (*ExecNode) Reset 

func (x *ExecNode) Reset()

func (*ExecNode) String 

func (x *ExecNode) String() string

type ExplainInfo 

type ExplainInfo struct {
	ExeGraphDot string `protobuf:"bytes,1,opt,name=exe_graph_dot,json=exeGraphDot,proto3" json:"exe_graph_dot,omitempty"`
	// contains filtered or unexported fields
}

func (*ExplainInfo) Descriptor deprecated 

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

Deprecated: Use ExplainInfo.ProtoReflect.Descriptor instead.

func (*ExplainInfo) GetExeGraphDot 

func (x *ExplainInfo) GetExeGraphDot() string

func (*ExplainInfo) ProtoMessage 

func (*ExplainInfo) ProtoMessage()

func (*ExplainInfo) ProtoReflect 

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

func (*ExplainInfo) Reset 

func (x *ExplainInfo) Reset()

func (*ExplainInfo) String 

func (x *ExplainInfo) String() string

type FetchResultRequest 

type FetchResultRequest struct {
	JobId string `protobuf:"bytes,1,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchResultRequest) Descriptor deprecated 

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

Deprecated: Use FetchResultRequest.ProtoReflect.Descriptor instead.

func (*FetchResultRequest) GetJobId 

func (x *FetchResultRequest) GetJobId() string

func (*FetchResultRequest) ProtoMessage 

func (*FetchResultRequest) ProtoMessage()

func (*FetchResultRequest) ProtoReflect 

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

func (*FetchResultRequest) Reset 

func (x *FetchResultRequest) Reset()

func (*FetchResultRequest) String 

func (x *FetchResultRequest) String() string

type FormalAttribute 

type FormalAttribute struct {
	Name       string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Definition string `protobuf:"bytes,2,opt,name=definition,proto3" json:"definition,omitempty"`
	// contains filtered or unexported fields
}

func (*FormalAttribute) Descriptor deprecated 

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

Deprecated: Use FormalAttribute.ProtoReflect.Descriptor instead.

func (*FormalAttribute) GetDefinition 

func (x *FormalAttribute) GetDefinition() string

func (*FormalAttribute) GetName 

func (x *FormalAttribute) GetName() string

func (*FormalAttribute) ProtoMessage 

func (*FormalAttribute) ProtoMessage()

func (*FormalAttribute) ProtoReflect 

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

func (*FormalAttribute) Reset 

func (x *FormalAttribute) Reset()

func (*FormalAttribute) String 

func (x *FormalAttribute) String() string

type FormalParameter 

type FormalParameter struct {
	ParamName                     string                 `protobuf:"bytes,1,opt,name=param_name,json=paramName,proto3" json:"param_name,omitempty"`
	Option                        FormalParameterOptions `protobuf:"varint,2,opt,name=option,proto3,enum=scql.pb.FormalParameterOptions" json:"option,omitempty"`
	ParamShape                    *TensorShape           `protobuf:"bytes,3,opt,name=param_shape,json=paramShape,proto3" json:"param_shape,omitempty"`
	Definition                    string                 `protobuf:"bytes,4,opt,name=definition,proto3" json:"definition,omitempty"`
	ParameterStatusConstraintName string                 `` /* 152-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*FormalParameter) Descriptor deprecated 

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

Deprecated: Use FormalParameter.ProtoReflect.Descriptor instead.

func (*FormalParameter) GetDefinition 

func (x *FormalParameter) GetDefinition() string

func (*FormalParameter) GetOption 

func (x *FormalParameter) GetOption() FormalParameterOptions

func (*FormalParameter) GetParamName 

func (x *FormalParameter) GetParamName() string

func (*FormalParameter) GetParamShape 

func (x *FormalParameter) GetParamShape() *TensorShape

func (*FormalParameter) GetParameterStatusConstraintName 

func (x *FormalParameter) GetParameterStatusConstraintName() string

func (*FormalParameter) ProtoMessage 

func (*FormalParameter) ProtoMessage()

func (*FormalParameter) ProtoReflect 

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

func (*FormalParameter) Reset 

func (x *FormalParameter) Reset()

func (*FormalParameter) String 

func (x *FormalParameter) String() string

type FormalParameterOptions 

type FormalParameterOptions int32
const (
	FormalParameterOptions_FORMALPARAMETEROPTIONS_UNDEFINED FormalParameterOptions = 0
	FormalParameterOptions_FORMALPARAMETEROPTIONS_SINGLE    FormalParameterOptions = 1
	FormalParameterOptions_FORMALPARAMETEROPTIONS_OPTIONAL  FormalParameterOptions = 2
	FormalParameterOptions_FORMALPARAMETEROPTIONS_VARIADIC  FormalParameterOptions = 3
)

func (FormalParameterOptions) Descriptor 

func (FormalParameterOptions) Descriptor() protoreflect.EnumDescriptor

func (FormalParameterOptions) Enum 

func (x FormalParameterOptions) Enum() *FormalParameterOptions

func (FormalParameterOptions) EnumDescriptor deprecated 

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

Deprecated: Use FormalParameterOptions.Descriptor instead.

func (FormalParameterOptions) Number 

func (x FormalParameterOptions) Number() protoreflect.EnumNumber

func (FormalParameterOptions) String 

func (x FormalParameterOptions) String() string

func (FormalParameterOptions) Type 

func (FormalParameterOptions) Type() protoreflect.EnumType

type GrantCCLRequest 

type GrantCCLRequest struct {
	ProjectId         string           `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ColumnControlList []*ColumnControl `protobuf:"bytes,2,rep,name=column_control_list,json=columnControlList,proto3" json:"column_control_list,omitempty"`
	// contains filtered or unexported fields
}

func (*GrantCCLRequest) Descriptor deprecated 

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

Deprecated: Use GrantCCLRequest.ProtoReflect.Descriptor instead.

func (*GrantCCLRequest) GetColumnControlList 

func (x *GrantCCLRequest) GetColumnControlList() []*ColumnControl

func (*GrantCCLRequest) GetProjectId 

func (x *GrantCCLRequest) GetProjectId() string

func (*GrantCCLRequest) ProtoMessage 

func (*GrantCCLRequest) ProtoMessage()

func (*GrantCCLRequest) ProtoReflect 

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

func (*GrantCCLRequest) Reset 

func (x *GrantCCLRequest) Reset()

func (*GrantCCLRequest) String 

func (x *GrantCCLRequest) String() string

type GrantCCLResponse 

type GrantCCLResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*GrantCCLResponse) Descriptor deprecated 

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

Deprecated: Use GrantCCLResponse.ProtoReflect.Descriptor instead.

func (*GrantCCLResponse) GetStatus 

func (x *GrantCCLResponse) GetStatus() *Status

func (*GrantCCLResponse) ProtoMessage 

func (*GrantCCLResponse) ProtoMessage()

func (*GrantCCLResponse) ProtoReflect 

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

func (*GrantCCLResponse) Reset 

func (x *GrantCCLResponse) Reset()

func (*GrantCCLResponse) String 

func (x *GrantCCLResponse) String() string

type InterBrokerServiceClient 

type InterBrokerServiceClient interface {
	DistributeQuery(ctx context.Context, in *DistributeQueryRequest, opts ...grpc.CallOption) (*DistributeQueryResponse, error)
	CancelQueryJob(ctx context.Context, in *CancelQueryJobRequest, opts ...grpc.CallOption) (*CancelQueryJobResponse, error)
	InviteToProject(ctx context.Context, in *InviteToProjectRequest, opts ...grpc.CallOption) (*InviteToProjectResponse, error)
	ReplyInvitation(ctx context.Context, in *ReplyInvitationRequest, opts ...grpc.CallOption) (*ReplyInvitationResponse, error)
	SyncInfo(ctx context.Context, in *SyncInfoRequest, opts ...grpc.CallOption) (*SyncInfoResponse, error)
	AskInfo(ctx context.Context, in *AskInfoRequest, opts ...grpc.CallOption) (*AskInfoResponse, error)
	ExchangeJobInfo(ctx context.Context, in *ExchangeJobInfoRequest, opts ...grpc.CallOption) (*ExchangeJobInfoResponse, error)
}

InterBrokerServiceClient is the client API for InterBrokerService service.

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

func NewInterBrokerServiceClient 

func NewInterBrokerServiceClient(cc grpc.ClientConnInterface) InterBrokerServiceClient

type InterBrokerServiceServer 

type InterBrokerServiceServer interface {
	DistributeQuery(context.Context, *DistributeQueryRequest) (*DistributeQueryResponse, error)
	CancelQueryJob(context.Context, *CancelQueryJobRequest) (*CancelQueryJobResponse, error)
	InviteToProject(context.Context, *InviteToProjectRequest) (*InviteToProjectResponse, error)
	ReplyInvitation(context.Context, *ReplyInvitationRequest) (*ReplyInvitationResponse, error)
	SyncInfo(context.Context, *SyncInfoRequest) (*SyncInfoResponse, error)
	AskInfo(context.Context, *AskInfoRequest) (*AskInfoResponse, error)
	ExchangeJobInfo(context.Context, *ExchangeJobInfoRequest) (*ExchangeJobInfoResponse, error)
}

InterBrokerServiceServer is the server API for InterBrokerService service.

type InterpreterServiceClient 

type InterpreterServiceClient interface {
	CompileQuery(ctx context.Context, in *CompileQueryRequest, opts ...grpc.CallOption) (*CompileQueryResponse, error)
}

InterpreterServiceClient is the client API for InterpreterService service.

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

func NewInterpreterServiceClient 

func NewInterpreterServiceClient(cc grpc.ClientConnInterface) InterpreterServiceClient

type InterpreterServiceServer 

type InterpreterServiceServer interface {
	CompileQuery(context.Context, *CompileQueryRequest) (*CompileQueryResponse, error)
}

InterpreterServiceServer is the server API for InterpreterService service.

type IntraBrokerServiceClient 

type IntraBrokerServiceClient interface {
	DoQuery(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	SubmitQuery(ctx context.Context, in *QueryRequest, opts ...grpc.CallOption) (*SubmitResponse, error)
	FetchResult(ctx context.Context, in *FetchResultRequest, opts ...grpc.CallOption) (*QueryResponse, error)
	CancelQuery(ctx context.Context, in *CancelQueryRequest, opts ...grpc.CallOption) (*CancelQueryResponse, error)
	CreateProject(ctx context.Context, in *CreateProjectRequest, opts ...grpc.CallOption) (*CreateProjectResponse, error)
	UpdateProject(ctx context.Context, in *UpdateProjectRequest, opts ...grpc.CallOption) (*UpdateProjectResponse, error)
	ListProjects(ctx context.Context, in *ListProjectsRequest, opts ...grpc.CallOption) (*ListProjectsResponse, error)
	ArchiveProject(ctx context.Context, in *ArchiveProjectRequest, opts ...grpc.CallOption) (*ArchiveProjectResponse, error)
	InviteMember(ctx context.Context, in *InviteMemberRequest, opts ...grpc.CallOption) (*InviteMemberResponse, error)
	ListInvitations(ctx context.Context, in *ListInvitationsRequest, opts ...grpc.CallOption) (*ListInvitationsResponse, error)
	ProcessInvitation(ctx context.Context, in *ProcessInvitationRequest, opts ...grpc.CallOption) (*ProcessInvitationResponse, error)
	CreateTable(ctx context.Context, in *CreateTableRequest, opts ...grpc.CallOption) (*CreateTableResponse, error)
	ListTables(ctx context.Context, in *ListTablesRequest, opts ...grpc.CallOption) (*ListTablesResponse, error)
	DropTable(ctx context.Context, in *DropTableRequest, opts ...grpc.CallOption) (*DropTableResponse, error)
	GrantCCL(ctx context.Context, in *GrantCCLRequest, opts ...grpc.CallOption) (*GrantCCLResponse, error)
	RevokeCCL(ctx context.Context, in *RevokeCCLRequest, opts ...grpc.CallOption) (*RevokeCCLResponse, error)
	ShowCCL(ctx context.Context, in *ShowCCLRequest, opts ...grpc.CallOption) (*ShowCCLResponse, error)
	CheckAndUpdateStatus(ctx context.Context, in *CheckAndUpdateStatusRequest, opts ...grpc.CallOption) (*CheckAndUpdateStatusResponse, error)
}

IntraBrokerServiceClient is the client API for IntraBrokerService service.

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

func NewIntraBrokerServiceClient 

func NewIntraBrokerServiceClient(cc grpc.ClientConnInterface) IntraBrokerServiceClient

type IntraBrokerServiceServer 

type IntraBrokerServiceServer interface {
	DoQuery(context.Context, *QueryRequest) (*QueryResponse, error)
	SubmitQuery(context.Context, *QueryRequest) (*SubmitResponse, error)
	FetchResult(context.Context, *FetchResultRequest) (*QueryResponse, error)
	CancelQuery(context.Context, *CancelQueryRequest) (*CancelQueryResponse, error)
	CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error)
	UpdateProject(context.Context, *UpdateProjectRequest) (*UpdateProjectResponse, error)
	ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)
	ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error)
	InviteMember(context.Context, *InviteMemberRequest) (*InviteMemberResponse, error)
	ListInvitations(context.Context, *ListInvitationsRequest) (*ListInvitationsResponse, error)
	ProcessInvitation(context.Context, *ProcessInvitationRequest) (*ProcessInvitationResponse, error)
	CreateTable(context.Context, *CreateTableRequest) (*CreateTableResponse, error)
	ListTables(context.Context, *ListTablesRequest) (*ListTablesResponse, error)
	DropTable(context.Context, *DropTableRequest) (*DropTableResponse, error)
	GrantCCL(context.Context, *GrantCCLRequest) (*GrantCCLResponse, error)
	RevokeCCL(context.Context, *RevokeCCLRequest) (*RevokeCCLResponse, error)
	ShowCCL(context.Context, *ShowCCLRequest) (*ShowCCLResponse, error)
	CheckAndUpdateStatus(context.Context, *CheckAndUpdateStatusRequest) (*CheckAndUpdateStatusResponse, error)
}

IntraBrokerServiceServer is the server API for IntraBrokerService service.

type InvitationRespond 

type InvitationRespond int32
const (
	InvitationRespond_ACCEPT  InvitationRespond = 0
	InvitationRespond_DECLINE InvitationRespond = 1
)

func (InvitationRespond) Descriptor 

func (InvitationRespond) Descriptor() protoreflect.EnumDescriptor

func (InvitationRespond) Enum 

func (x InvitationRespond) Enum() *InvitationRespond

func (InvitationRespond) EnumDescriptor deprecated 

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

Deprecated: Use InvitationRespond.Descriptor instead.

func (InvitationRespond) Number 

func (x InvitationRespond) Number() protoreflect.EnumNumber

func (InvitationRespond) String 

func (x InvitationRespond) String() string

func (InvitationRespond) Type 

func (InvitationRespond) Type() protoreflect.EnumType

type InvitationStatus 

type InvitationStatus int32
const (
	InvitationStatus_UNDECIDED InvitationStatus = 0
	InvitationStatus_ACCEPTED  InvitationStatus = 1
	InvitationStatus_DECLINED  InvitationStatus = 2
	InvitationStatus_INVALID   InvitationStatus = 3
)

func (InvitationStatus) Descriptor 

func (InvitationStatus) Descriptor() protoreflect.EnumDescriptor

func (InvitationStatus) Enum 

func (x InvitationStatus) Enum() *InvitationStatus

func (InvitationStatus) EnumDescriptor deprecated 

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

Deprecated: Use InvitationStatus.Descriptor instead.

func (InvitationStatus) Number 

func (x InvitationStatus) Number() protoreflect.EnumNumber

func (InvitationStatus) String 

func (x InvitationStatus) String() string

func (InvitationStatus) Type 

func (InvitationStatus) Type() protoreflect.EnumType

type InviteMemberRequest 

type InviteMemberRequest struct {
	ProjectId  string                               `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Invitee    string                               `protobuf:"bytes,2,opt,name=invitee,proto3" json:"invitee,omitempty"`
	Postscript string                               `protobuf:"bytes,3,opt,name=postscript,proto3" json:"postscript,omitempty"`
	Method     InviteMemberRequest_InvitationMethod `protobuf:"varint,4,opt,name=method,proto3,enum=scql.pb.InviteMemberRequest_InvitationMethod" json:"method,omitempty"`
	// contains filtered or unexported fields
}

func (*InviteMemberRequest) Descriptor deprecated 

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

Deprecated: Use InviteMemberRequest.ProtoReflect.Descriptor instead.

func (*InviteMemberRequest) GetInvitee 

func (x *InviteMemberRequest) GetInvitee() string

func (*InviteMemberRequest) GetMethod 

func (x *InviteMemberRequest) GetMethod() InviteMemberRequest_InvitationMethod

func (*InviteMemberRequest) GetPostscript 

func (x *InviteMemberRequest) GetPostscript() string

func (*InviteMemberRequest) GetProjectId 

func (x *InviteMemberRequest) GetProjectId() string

func (*InviteMemberRequest) ProtoMessage 

func (*InviteMemberRequest) ProtoMessage()

func (*InviteMemberRequest) ProtoReflect 

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

func (*InviteMemberRequest) Reset 

func (x *InviteMemberRequest) Reset()

func (*InviteMemberRequest) String 

func (x *InviteMemberRequest) String() string

type InviteMemberRequest_InvitationMethod 

type InviteMemberRequest_InvitationMethod int32
const (
	InviteMemberRequest_PUSH InviteMemberRequest_InvitationMethod = 0
	InviteMemberRequest_PULL InviteMemberRequest_InvitationMethod = 1
)

func (InviteMemberRequest_InvitationMethod) Descriptor 

func (InviteMemberRequest_InvitationMethod) Descriptor() protoreflect.EnumDescriptor

func (InviteMemberRequest_InvitationMethod) Enum 

func (x InviteMemberRequest_InvitationMethod) Enum() *InviteMemberRequest_InvitationMethod

func (InviteMemberRequest_InvitationMethod) EnumDescriptor deprecated 

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

Deprecated: Use InviteMemberRequest_InvitationMethod.Descriptor instead.

func (InviteMemberRequest_InvitationMethod) Number 

func (x InviteMemberRequest_InvitationMethod) Number() protoreflect.EnumNumber

func (InviteMemberRequest_InvitationMethod) String 

func (x InviteMemberRequest_InvitationMethod) String() string

func (InviteMemberRequest_InvitationMethod) Type 

func (InviteMemberRequest_InvitationMethod) Type() protoreflect.EnumType

type InviteMemberResponse 

type InviteMemberResponse struct {
	Status         *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	InvitationCode string  `protobuf:"bytes,2,opt,name=invitation_code,json=invitationCode,proto3" json:"invitation_code,omitempty"`
	// contains filtered or unexported fields
}

func (*InviteMemberResponse) Descriptor deprecated 

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

Deprecated: Use InviteMemberResponse.ProtoReflect.Descriptor instead.

func (*InviteMemberResponse) GetInvitationCode 

func (x *InviteMemberResponse) GetInvitationCode() string

func (*InviteMemberResponse) GetStatus 

func (x *InviteMemberResponse) GetStatus() *Status

func (*InviteMemberResponse) ProtoMessage 

func (*InviteMemberResponse) ProtoMessage()

func (*InviteMemberResponse) ProtoReflect 

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

func (*InviteMemberResponse) Reset 

func (x *InviteMemberResponse) Reset()

func (*InviteMemberResponse) String 

func (x *InviteMemberResponse) String() string

type InviteToProjectRequest 

type InviteToProjectRequest struct {
	ClientId       *PartyId     `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Signature      []byte       `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	Project        *ProjectDesc `protobuf:"bytes,3,opt,name=project,proto3" json:"project,omitempty"`
	Inviter        string       `protobuf:"bytes,4,opt,name=inviter,proto3" json:"inviter,omitempty"`
	InvitationCode string       `protobuf:"bytes,5,opt,name=invitation_code,json=invitationCode,proto3" json:"invitation_code,omitempty"`
	// contains filtered or unexported fields
}

func (*InviteToProjectRequest) Descriptor deprecated 

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

Deprecated: Use InviteToProjectRequest.ProtoReflect.Descriptor instead.

func (*InviteToProjectRequest) GetClientId 

func (x *InviteToProjectRequest) GetClientId() *PartyId

func (*InviteToProjectRequest) GetInvitationCode 

func (x *InviteToProjectRequest) GetInvitationCode() string

func (*InviteToProjectRequest) GetInviter 

func (x *InviteToProjectRequest) GetInviter() string

func (*InviteToProjectRequest) GetProject 

func (x *InviteToProjectRequest) GetProject() *ProjectDesc

func (*InviteToProjectRequest) GetSignature 

func (x *InviteToProjectRequest) GetSignature() []byte

func (*InviteToProjectRequest) ProtoMessage 

func (*InviteToProjectRequest) ProtoMessage()

func (*InviteToProjectRequest) ProtoReflect 

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

func (*InviteToProjectRequest) Reset 

func (x *InviteToProjectRequest) Reset()

func (*InviteToProjectRequest) String 

func (x *InviteToProjectRequest) String() string

type InviteToProjectResponse 

type InviteToProjectResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*InviteToProjectResponse) Descriptor deprecated 

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

Deprecated: Use InviteToProjectResponse.ProtoReflect.Descriptor instead.

func (*InviteToProjectResponse) GetStatus 

func (x *InviteToProjectResponse) GetStatus() *Status

func (*InviteToProjectResponse) ProtoMessage 

func (*InviteToProjectResponse) ProtoMessage()

func (*InviteToProjectResponse) ProtoReflect 

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

func (*InviteToProjectResponse) Reset 

func (x *InviteToProjectResponse) Reset()

func (*InviteToProjectResponse) String 

func (x *InviteToProjectResponse) String() string

type ListInvitationsRequest 

type ListInvitationsRequest struct {

	// Types that are assignable to Filter:
	//	*ListInvitationsRequest_Status
	//	*ListInvitationsRequest_Inviter
	Filter isListInvitationsRequest_Filter `protobuf_oneof:"filter"`
	// contains filtered or unexported fields
}

func (*ListInvitationsRequest) Descriptor deprecated 

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

Deprecated: Use ListInvitationsRequest.ProtoReflect.Descriptor instead.

func (*ListInvitationsRequest) GetFilter 

func (m *ListInvitationsRequest) GetFilter() isListInvitationsRequest_Filter

func (*ListInvitationsRequest) GetInviter 

func (x *ListInvitationsRequest) GetInviter() string

func (*ListInvitationsRequest) GetStatus 

func (x *ListInvitationsRequest) GetStatus() InvitationStatus

func (*ListInvitationsRequest) ProtoMessage 

func (*ListInvitationsRequest) ProtoMessage()

func (*ListInvitationsRequest) ProtoReflect 

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

func (*ListInvitationsRequest) Reset 

func (x *ListInvitationsRequest) Reset()

func (*ListInvitationsRequest) String 

func (x *ListInvitationsRequest) String() string

type ListInvitationsRequest_Inviter 

type ListInvitationsRequest_Inviter struct {
	Inviter string `protobuf:"bytes,2,opt,name=inviter,proto3,oneof"`
}

type ListInvitationsRequest_Status 

type ListInvitationsRequest_Status struct {
	Status InvitationStatus `protobuf:"varint,1,opt,name=status,proto3,enum=scql.pb.InvitationStatus,oneof"`
}

type ListInvitationsResponse 

type ListInvitationsResponse struct {
	Status      *Status              `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Invitations []*ProjectInvitation `protobuf:"bytes,2,rep,name=invitations,proto3" json:"invitations,omitempty"`
	// contains filtered or unexported fields
}

func (*ListInvitationsResponse) Descriptor deprecated 

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

Deprecated: Use ListInvitationsResponse.ProtoReflect.Descriptor instead.

func (*ListInvitationsResponse) GetInvitations 

func (x *ListInvitationsResponse) GetInvitations() []*ProjectInvitation

func (*ListInvitationsResponse) GetStatus 

func (x *ListInvitationsResponse) GetStatus() *Status

func (*ListInvitationsResponse) ProtoMessage 

func (*ListInvitationsResponse) ProtoMessage()

func (*ListInvitationsResponse) ProtoReflect 

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

func (*ListInvitationsResponse) Reset 

func (x *ListInvitationsResponse) Reset()

func (*ListInvitationsResponse) String 

func (x *ListInvitationsResponse) String() string

type ListProjectsRequest 

type ListProjectsRequest struct {
	Ids []string `protobuf:"bytes,1,rep,name=ids,proto3" json:"ids,omitempty"`
	// contains filtered or unexported fields
}

func (*ListProjectsRequest) Descriptor deprecated 

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

Deprecated: Use ListProjectsRequest.ProtoReflect.Descriptor instead.

func (*ListProjectsRequest) GetIds 

func (x *ListProjectsRequest) GetIds() []string

func (*ListProjectsRequest) ProtoMessage 

func (*ListProjectsRequest) ProtoMessage()

func (*ListProjectsRequest) ProtoReflect 

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

func (*ListProjectsRequest) Reset 

func (x *ListProjectsRequest) Reset()

func (*ListProjectsRequest) String 

func (x *ListProjectsRequest) String() string

type ListProjectsResponse 

type ListProjectsResponse struct {
	Status   *Status        `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Projects []*ProjectDesc `protobuf:"bytes,2,rep,name=projects,proto3" json:"projects,omitempty"`
	// contains filtered or unexported fields
}

func (*ListProjectsResponse) Descriptor deprecated 

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

Deprecated: Use ListProjectsResponse.ProtoReflect.Descriptor instead.

func (*ListProjectsResponse) GetProjects 

func (x *ListProjectsResponse) GetProjects() []*ProjectDesc

func (*ListProjectsResponse) GetStatus 

func (x *ListProjectsResponse) GetStatus() *Status

func (*ListProjectsResponse) ProtoMessage 

func (*ListProjectsResponse) ProtoMessage()

func (*ListProjectsResponse) ProtoReflect 

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

func (*ListProjectsResponse) Reset 

func (x *ListProjectsResponse) Reset()

func (*ListProjectsResponse) String 

func (x *ListProjectsResponse) String() string

type ListTablesRequest 

type ListTablesRequest struct {
	ProjectId string   `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Names     []string `protobuf:"bytes,2,rep,name=names,proto3" json:"names,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTablesRequest) Descriptor deprecated 

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

Deprecated: Use ListTablesRequest.ProtoReflect.Descriptor instead.

func (*ListTablesRequest) GetNames 

func (x *ListTablesRequest) GetNames() []string

func (*ListTablesRequest) GetProjectId 

func (x *ListTablesRequest) GetProjectId() string

func (*ListTablesRequest) ProtoMessage 

func (*ListTablesRequest) ProtoMessage()

func (*ListTablesRequest) ProtoReflect 

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

func (*ListTablesRequest) Reset 

func (x *ListTablesRequest) Reset()

func (*ListTablesRequest) String 

func (x *ListTablesRequest) String() string

type ListTablesResponse 

type ListTablesResponse struct {
	Status *Status      `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	Tables []*TableMeta `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
	// contains filtered or unexported fields
}

func (*ListTablesResponse) Descriptor deprecated 

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

Deprecated: Use ListTablesResponse.ProtoReflect.Descriptor instead.

func (*ListTablesResponse) GetStatus 

func (x *ListTablesResponse) GetStatus() *Status

func (*ListTablesResponse) GetTables 

func (x *ListTablesResponse) GetTables() []*TableMeta

func (*ListTablesResponse) ProtoMessage 

func (*ListTablesResponse) ProtoMessage()

func (*ListTablesResponse) ProtoReflect 

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

func (*ListTablesResponse) Reset 

func (x *ListTablesResponse) Reset()

func (*ListTablesResponse) String 

func (x *ListTablesResponse) String() string

type OperatorDef 

type OperatorDef struct {
	Name                   string                       `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	InputParams            []*FormalParameter           `protobuf:"bytes,2,rep,name=input_params,json=inputParams,proto3" json:"input_params,omitempty"`
	OutputParams           []*FormalParameter           `protobuf:"bytes,3,rep,name=output_params,json=outputParams,proto3" json:"output_params,omitempty"`
	AttributeParams        []*FormalAttribute           `protobuf:"bytes,4,rep,name=attribute_params,json=attributeParams,proto3" json:"attribute_params,omitempty"`
	DefaultAttributeValues map[string]*AttributeValue   `` /* 217-byte string literal not displayed */
	Definition             string                       `protobuf:"bytes,6,opt,name=definition,proto3" json:"definition,omitempty"`
	ParamStatusConstraints map[string]*TensorStatusList `` /* 217-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OperatorDef) Descriptor deprecated 

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

Deprecated: Use OperatorDef.ProtoReflect.Descriptor instead.

func (*OperatorDef) GetAttributeParams 

func (x *OperatorDef) GetAttributeParams() []*FormalAttribute

func (*OperatorDef) GetDefaultAttributeValues 

func (x *OperatorDef) GetDefaultAttributeValues() map[string]*AttributeValue

func (*OperatorDef) GetDefinition 

func (x *OperatorDef) GetDefinition() string

func (*OperatorDef) GetInputParams 

func (x *OperatorDef) GetInputParams() []*FormalParameter

func (*OperatorDef) GetName 

func (x *OperatorDef) GetName() string

func (*OperatorDef) GetOutputParams 

func (x *OperatorDef) GetOutputParams() []*FormalParameter

func (*OperatorDef) GetParamStatusConstraints 

func (x *OperatorDef) GetParamStatusConstraints() map[string]*TensorStatusList

func (*OperatorDef) ProtoMessage 

func (*OperatorDef) ProtoMessage()

func (*OperatorDef) ProtoReflect 

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

func (*OperatorDef) Reset 

func (x *OperatorDef) Reset()

func (*OperatorDef) String 

func (x *OperatorDef) String() string

type OptimizerHints 

type OptimizerHints struct {
	PsiAlgorithmType PsiAlgorithmType `` /* 142-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*OptimizerHints) Descriptor deprecated 

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

Deprecated: Use OptimizerHints.ProtoReflect.Descriptor instead.

func (*OptimizerHints) GetPsiAlgorithmType 

func (x *OptimizerHints) GetPsiAlgorithmType() PsiAlgorithmType

func (*OptimizerHints) ProtoMessage 

func (*OptimizerHints) ProtoMessage()

func (*OptimizerHints) ProtoReflect 

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

func (*OptimizerHints) Reset 

func (x *OptimizerHints) Reset()

func (*OptimizerHints) String 

func (x *OptimizerHints) String() string

type PartyId 

type PartyId struct {
	Code string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	// contains filtered or unexported fields
}

func (*PartyId) Descriptor deprecated 

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

Deprecated: Use PartyId.ProtoReflect.Descriptor instead.

func (*PartyId) GetCode 

func (x *PartyId) GetCode() string

func (*PartyId) ProtoMessage 

func (*PartyId) ProtoMessage()

func (*PartyId) ProtoReflect 

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

func (*PartyId) Reset 

func (x *PartyId) Reset()

func (*PartyId) String 

func (x *PartyId) String() string

type PrimitiveDataType 

type PrimitiveDataType int32
const (
	PrimitiveDataType_PrimitiveDataType_UNDEFINED PrimitiveDataType = 0
	PrimitiveDataType_INT8                        PrimitiveDataType = 1
	PrimitiveDataType_INT16                       PrimitiveDataType = 2
	PrimitiveDataType_INT32                       PrimitiveDataType = 3
	PrimitiveDataType_INT64                       PrimitiveDataType = 4
	PrimitiveDataType_FLOAT32                     PrimitiveDataType = 5
	PrimitiveDataType_FLOAT64                     PrimitiveDataType = 6
	PrimitiveDataType_BOOL                        PrimitiveDataType = 7
	PrimitiveDataType_STRING                      PrimitiveDataType = 8
	PrimitiveDataType_DATETIME                    PrimitiveDataType = 9
	PrimitiveDataType_TIMESTAMP                   PrimitiveDataType = 10
)

func (PrimitiveDataType) Descriptor 

func (PrimitiveDataType) Descriptor() protoreflect.EnumDescriptor

func (PrimitiveDataType) Enum 

func (x PrimitiveDataType) Enum() *PrimitiveDataType

func (PrimitiveDataType) EnumDescriptor deprecated 

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

Deprecated: Use PrimitiveDataType.Descriptor instead.

func (PrimitiveDataType) Number 

func (x PrimitiveDataType) Number() protoreflect.EnumNumber

func (PrimitiveDataType) String 

func (x PrimitiveDataType) String() string

func (PrimitiveDataType) Type 

func (PrimitiveDataType) Type() protoreflect.EnumType

type PrivacyPolicy 

type PrivacyPolicy struct {
	ColumnControlList []*ColumnControl `protobuf:"bytes,1,rep,name=column_control_list,json=columnControlList,proto3" json:"column_control_list,omitempty"`
	// contains filtered or unexported fields
}

func (*PrivacyPolicy) Descriptor deprecated 

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

Deprecated: Use PrivacyPolicy.ProtoReflect.Descriptor instead.

func (*PrivacyPolicy) GetColumnControlList 

func (x *PrivacyPolicy) GetColumnControlList() []*ColumnControl

func (*PrivacyPolicy) ProtoMessage 

func (*PrivacyPolicy) ProtoMessage()

func (*PrivacyPolicy) ProtoReflect 

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

func (*PrivacyPolicy) Reset 

func (x *PrivacyPolicy) Reset()

func (*PrivacyPolicy) String 

func (x *PrivacyPolicy) String() string

type ProcessInvitationRequest 

type ProcessInvitationRequest struct {
	InvitationId   uint64            `protobuf:"varint,1,opt,name=invitation_id,json=invitationId,proto3" json:"invitation_id,omitempty"`
	Respond        InvitationRespond `protobuf:"varint,2,opt,name=respond,proto3,enum=scql.pb.InvitationRespond" json:"respond,omitempty"`
	RespondComment string            `protobuf:"bytes,3,opt,name=respond_comment,json=respondComment,proto3" json:"respond_comment,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInvitationRequest) Descriptor deprecated 

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

Deprecated: Use ProcessInvitationRequest.ProtoReflect.Descriptor instead.

func (*ProcessInvitationRequest) GetInvitationId 

func (x *ProcessInvitationRequest) GetInvitationId() uint64

func (*ProcessInvitationRequest) GetRespond 

func (x *ProcessInvitationRequest) GetRespond() InvitationRespond

func (*ProcessInvitationRequest) GetRespondComment 

func (x *ProcessInvitationRequest) GetRespondComment() string

func (*ProcessInvitationRequest) ProtoMessage 

func (*ProcessInvitationRequest) ProtoMessage()

func (*ProcessInvitationRequest) ProtoReflect 

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

func (*ProcessInvitationRequest) Reset 

func (x *ProcessInvitationRequest) Reset()

func (*ProcessInvitationRequest) String 

func (x *ProcessInvitationRequest) String() string

type ProcessInvitationResponse 

type ProcessInvitationResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ProcessInvitationResponse) Descriptor deprecated 

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

Deprecated: Use ProcessInvitationResponse.ProtoReflect.Descriptor instead.

func (*ProcessInvitationResponse) GetStatus 

func (x *ProcessInvitationResponse) GetStatus() *Status

func (*ProcessInvitationResponse) ProtoMessage 

func (*ProcessInvitationResponse) ProtoMessage()

func (*ProcessInvitationResponse) ProtoReflect 

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

func (*ProcessInvitationResponse) Reset 

func (x *ProcessInvitationResponse) Reset()

func (*ProcessInvitationResponse) String 

func (x *ProcessInvitationResponse) String() string

type ProjectConfig 

type ProjectConfig struct {
	SpuRuntimeCfg *spu.RuntimeConfig `protobuf:"bytes,1,opt,name=spu_runtime_cfg,json=spuRuntimeCfg,proto3" json:"spu_runtime_cfg,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectConfig) Descriptor deprecated 

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

Deprecated: Use ProjectConfig.ProtoReflect.Descriptor instead.

func (*ProjectConfig) GetSpuRuntimeCfg 

func (x *ProjectConfig) GetSpuRuntimeCfg() *spu.RuntimeConfig

func (*ProjectConfig) ProtoMessage 

func (*ProjectConfig) ProtoMessage()

func (*ProjectConfig) ProtoReflect 

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

func (*ProjectConfig) Reset 

func (x *ProjectConfig) Reset()

func (*ProjectConfig) String 

func (x *ProjectConfig) String() string

type ProjectConflict 

type ProjectConflict struct {
	Items []*ProjectConflict_ConflictItem `protobuf:"bytes,1,rep,name=items,proto3" json:"items,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectConflict) Descriptor deprecated 

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

Deprecated: Use ProjectConflict.ProtoReflect.Descriptor instead.

func (*ProjectConflict) GetItems 

func (x *ProjectConflict) GetItems() []*ProjectConflict_ConflictItem

func (*ProjectConflict) ProtoMessage 

func (*ProjectConflict) ProtoMessage()

func (*ProjectConflict) ProtoReflect 

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

func (*ProjectConflict) Reset 

func (x *ProjectConflict) Reset()

func (*ProjectConflict) String 

func (x *ProjectConflict) String() string

type ProjectConflict_ConflictItem 

type ProjectConflict_ConflictItem struct {
	Message string `protobuf:"bytes,1,opt,name=message,proto3" json:"message,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectConflict_ConflictItem) Descriptor deprecated 

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

Deprecated: Use ProjectConflict_ConflictItem.ProtoReflect.Descriptor instead.

func (*ProjectConflict_ConflictItem) GetMessage 

func (x *ProjectConflict_ConflictItem) GetMessage() string

func (*ProjectConflict_ConflictItem) ProtoMessage 

func (*ProjectConflict_ConflictItem) ProtoMessage()

func (*ProjectConflict_ConflictItem) ProtoReflect 

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

func (*ProjectConflict_ConflictItem) Reset 

func (x *ProjectConflict_ConflictItem) Reset()

func (*ProjectConflict_ConflictItem) String 

func (x *ProjectConflict_ConflictItem) String() string

type ProjectDesc 

type ProjectDesc struct {
	ProjectId   string                 `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Name        string                 `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Description string                 `protobuf:"bytes,3,opt,name=description,proto3" json:"description,omitempty"`
	Conf        *ProjectConfig         `protobuf:"bytes,4,opt,name=conf,proto3" json:"conf,omitempty"`
	Creator     string                 `protobuf:"bytes,5,opt,name=creator,proto3" json:"creator,omitempty"`
	Members     []string               `protobuf:"bytes,6,rep,name=members,proto3" json:"members,omitempty"`
	CreatedAt   *timestamppb.Timestamp `protobuf:"bytes,7,opt,name=created_at,json=createdAt,proto3" json:"created_at,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectDesc) Descriptor deprecated 

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

Deprecated: Use ProjectDesc.ProtoReflect.Descriptor instead.

func (*ProjectDesc) GetConf 

func (x *ProjectDesc) GetConf() *ProjectConfig

func (*ProjectDesc) GetCreatedAt 

func (x *ProjectDesc) GetCreatedAt() *timestamppb.Timestamp

func (*ProjectDesc) GetCreator 

func (x *ProjectDesc) GetCreator() string

func (*ProjectDesc) GetDescription 

func (x *ProjectDesc) GetDescription() string

func (*ProjectDesc) GetMembers 

func (x *ProjectDesc) GetMembers() []string

func (*ProjectDesc) GetName 

func (x *ProjectDesc) GetName() string

func (*ProjectDesc) GetProjectId 

func (x *ProjectDesc) GetProjectId() string

func (*ProjectDesc) ProtoMessage 

func (*ProjectDesc) ProtoMessage()

func (*ProjectDesc) ProtoReflect 

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

func (*ProjectDesc) Reset 

func (x *ProjectDesc) Reset()

func (*ProjectDesc) String 

func (x *ProjectDesc) String() string

type ProjectInvitation 

type ProjectInvitation struct {
	InvitationId uint64           `protobuf:"varint,1,opt,name=invitation_id,json=invitationId,proto3" json:"invitation_id,omitempty"`
	Project      *ProjectDesc     `protobuf:"bytes,2,opt,name=project,proto3" json:"project,omitempty"`
	Inviter      string           `protobuf:"bytes,3,opt,name=inviter,proto3" json:"inviter,omitempty"`
	Invitee      string           `protobuf:"bytes,4,opt,name=invitee,proto3" json:"invitee,omitempty"`
	Postscript   string           `protobuf:"bytes,5,opt,name=postscript,proto3" json:"postscript,omitempty"`
	Status       InvitationStatus `protobuf:"varint,6,opt,name=status,proto3,enum=scql.pb.InvitationStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*ProjectInvitation) Descriptor deprecated 

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

Deprecated: Use ProjectInvitation.ProtoReflect.Descriptor instead.

func (*ProjectInvitation) GetInvitationId 

func (x *ProjectInvitation) GetInvitationId() uint64

func (*ProjectInvitation) GetInvitee 

func (x *ProjectInvitation) GetInvitee() string

func (*ProjectInvitation) GetInviter 

func (x *ProjectInvitation) GetInviter() string

func (*ProjectInvitation) GetPostscript 

func (x *ProjectInvitation) GetPostscript() string

func (*ProjectInvitation) GetProject 

func (x *ProjectInvitation) GetProject() *ProjectDesc

func (*ProjectInvitation) GetStatus 

func (x *ProjectInvitation) GetStatus() InvitationStatus

func (*ProjectInvitation) ProtoMessage 

func (*ProjectInvitation) ProtoMessage()

func (*ProjectInvitation) ProtoReflect 

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

func (*ProjectInvitation) Reset 

func (x *ProjectInvitation) Reset()

func (*ProjectInvitation) String 

func (x *ProjectInvitation) String() string

type PsiAlgorithmType 

type PsiAlgorithmType int32
const (
	PsiAlgorithmType_AUTO PsiAlgorithmType = 0
	PsiAlgorithmType_ECDH PsiAlgorithmType = 1
	PsiAlgorithmType_OPRF PsiAlgorithmType = 2
)

func (PsiAlgorithmType) Descriptor 

func (PsiAlgorithmType) Descriptor() protoreflect.EnumDescriptor

func (PsiAlgorithmType) Enum 

func (x PsiAlgorithmType) Enum() *PsiAlgorithmType

func (PsiAlgorithmType) EnumDescriptor deprecated 

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

Deprecated: Use PsiAlgorithmType.Descriptor instead.

func (PsiAlgorithmType) Number 

func (x PsiAlgorithmType) Number() protoreflect.EnumNumber

func (PsiAlgorithmType) String 

func (x PsiAlgorithmType) String() string

func (PsiAlgorithmType) Type 

func (PsiAlgorithmType) Type() protoreflect.EnumType

type QueryRequest 

type QueryRequest struct {
	Header    *RequestHeader `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	ProjectId string         `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Query     string         `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	DebugOpts *DebugOptions  `protobuf:"bytes,4,opt,name=debug_opts,json=debugOpts,proto3" json:"debug_opts,omitempty"`
	DryRun    bool           `protobuf:"varint,5,opt,name=dry_run,json=dryRun,proto3" json:"dry_run,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryRequest) Descriptor deprecated 

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

Deprecated: Use QueryRequest.ProtoReflect.Descriptor instead.

func (*QueryRequest) GetDebugOpts 

func (x *QueryRequest) GetDebugOpts() *DebugOptions

func (*QueryRequest) GetDryRun 

func (x *QueryRequest) GetDryRun() bool

func (*QueryRequest) GetHeader 

func (x *QueryRequest) GetHeader() *RequestHeader

func (*QueryRequest) GetProjectId 

func (x *QueryRequest) GetProjectId() string

func (*QueryRequest) GetQuery 

func (x *QueryRequest) GetQuery() string

func (*QueryRequest) ProtoMessage 

func (*QueryRequest) ProtoMessage()

func (*QueryRequest) ProtoReflect 

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

func (*QueryRequest) Reset 

func (x *QueryRequest) Reset()

func (*QueryRequest) String 

func (x *QueryRequest) String() string

type QueryResponse 

type QueryResponse struct {
	Status       *Status       `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	AffectedRows int64         `protobuf:"varint,2,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"`
	Warnings     []*SQLWarning `protobuf:"bytes,3,rep,name=warnings,proto3" json:"warnings,omitempty"`
	CostTimeS    float64       `protobuf:"fixed64,4,opt,name=cost_time_s,json=costTimeS,proto3" json:"cost_time_s,omitempty"`
	OutColumns   []*Tensor     `protobuf:"bytes,1000,rep,name=out_columns,json=outColumns,proto3" json:"out_columns,omitempty"`
	// contains filtered or unexported fields
}

func (*QueryResponse) Descriptor deprecated 

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

Deprecated: Use QueryResponse.ProtoReflect.Descriptor instead.

func (*QueryResponse) GetAffectedRows 

func (x *QueryResponse) GetAffectedRows() int64

func (*QueryResponse) GetCostTimeS 

func (x *QueryResponse) GetCostTimeS() float64

func (*QueryResponse) GetOutColumns 

func (x *QueryResponse) GetOutColumns() []*Tensor

func (*QueryResponse) GetStatus 

func (x *QueryResponse) GetStatus() *Status

func (*QueryResponse) GetWarnings 

func (x *QueryResponse) GetWarnings() []*SQLWarning

func (*QueryResponse) ProtoMessage 

func (*QueryResponse) ProtoMessage()

func (*QueryResponse) ProtoReflect 

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

func (*QueryResponse) Reset 

func (x *QueryResponse) Reset()

func (*QueryResponse) String 

func (x *QueryResponse) String() string

type ReplyInvitationRequest 

type ReplyInvitationRequest struct {
	ClientId       *PartyId          `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Signature      []byte            `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	ProjectId      string            `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	InvitationCode string            `protobuf:"bytes,4,opt,name=invitation_code,json=invitationCode,proto3" json:"invitation_code,omitempty"`
	Respond        InvitationRespond `protobuf:"varint,5,opt,name=respond,proto3,enum=scql.pb.InvitationRespond" json:"respond,omitempty"`
	RespondComment string            `protobuf:"bytes,6,opt,name=respond_comment,json=respondComment,proto3" json:"respond_comment,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplyInvitationRequest) Descriptor deprecated 

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

Deprecated: Use ReplyInvitationRequest.ProtoReflect.Descriptor instead.

func (*ReplyInvitationRequest) GetClientId 

func (x *ReplyInvitationRequest) GetClientId() *PartyId

func (*ReplyInvitationRequest) GetInvitationCode 

func (x *ReplyInvitationRequest) GetInvitationCode() string

func (*ReplyInvitationRequest) GetProjectId 

func (x *ReplyInvitationRequest) GetProjectId() string

func (*ReplyInvitationRequest) GetRespond 

func (x *ReplyInvitationRequest) GetRespond() InvitationRespond

func (*ReplyInvitationRequest) GetRespondComment 

func (x *ReplyInvitationRequest) GetRespondComment() string

func (*ReplyInvitationRequest) GetSignature 

func (x *ReplyInvitationRequest) GetSignature() []byte

func (*ReplyInvitationRequest) ProtoMessage 

func (*ReplyInvitationRequest) ProtoMessage()

func (*ReplyInvitationRequest) ProtoReflect 

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

func (*ReplyInvitationRequest) Reset 

func (x *ReplyInvitationRequest) Reset()

func (*ReplyInvitationRequest) String 

func (x *ReplyInvitationRequest) String() string

type ReplyInvitationResponse 

type ReplyInvitationResponse struct {
	Status      *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ProjectInfo []byte  `protobuf:"bytes,2,opt,name=project_info,json=projectInfo,proto3" json:"project_info,omitempty"`
	// contains filtered or unexported fields
}

func (*ReplyInvitationResponse) Descriptor deprecated 

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

Deprecated: Use ReplyInvitationResponse.ProtoReflect.Descriptor instead.

func (*ReplyInvitationResponse) GetProjectInfo 

func (x *ReplyInvitationResponse) GetProjectInfo() []byte

func (*ReplyInvitationResponse) GetStatus 

func (x *ReplyInvitationResponse) GetStatus() *Status

func (*ReplyInvitationResponse) ProtoMessage 

func (*ReplyInvitationResponse) ProtoMessage()

func (*ReplyInvitationResponse) ProtoReflect 

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

func (*ReplyInvitationResponse) Reset 

func (x *ReplyInvitationResponse) Reset()

func (*ReplyInvitationResponse) String 

func (x *ReplyInvitationResponse) String() string

type ReportRequest 

type ReportRequest struct {
	Status          *Status   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	OutColumns      []*Tensor `protobuf:"bytes,2,rep,name=out_columns,json=outColumns,proto3" json:"out_columns,omitempty"`
	SessionId       string    `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	PartyCode       string    `protobuf:"bytes,4,opt,name=party_code,json=partyCode,proto3" json:"party_code,omitempty"`
	NumRowsAffected int64     `protobuf:"varint,5,opt,name=num_rows_affected,json=numRowsAffected,proto3" json:"num_rows_affected,omitempty"`
	// contains filtered or unexported fields
}

func (*ReportRequest) Descriptor deprecated 

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

Deprecated: Use ReportRequest.ProtoReflect.Descriptor instead.

func (*ReportRequest) GetNumRowsAffected 

func (x *ReportRequest) GetNumRowsAffected() int64

func (*ReportRequest) GetOutColumns 

func (x *ReportRequest) GetOutColumns() []*Tensor

func (*ReportRequest) GetPartyCode 

func (x *ReportRequest) GetPartyCode() string

func (*ReportRequest) GetSessionId 

func (x *ReportRequest) GetSessionId() string

func (*ReportRequest) GetStatus 

func (x *ReportRequest) GetStatus() *Status

func (*ReportRequest) ProtoMessage 

func (*ReportRequest) ProtoMessage()

func (*ReportRequest) ProtoReflect 

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

func (*ReportRequest) Reset 

func (x *ReportRequest) Reset()

func (*ReportRequest) String 

func (x *ReportRequest) String() string

type RequestHeader 

type RequestHeader struct {
	CustomHeaders map[string]string `` /* 188-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*RequestHeader) Descriptor deprecated 

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

Deprecated: Use RequestHeader.ProtoReflect.Descriptor instead.

func (*RequestHeader) GetCustomHeaders 

func (x *RequestHeader) GetCustomHeaders() map[string]string

func (*RequestHeader) ProtoMessage 

func (*RequestHeader) ProtoMessage()

func (*RequestHeader) ProtoReflect 

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

func (*RequestHeader) Reset 

func (x *RequestHeader) Reset()

func (*RequestHeader) String 

func (x *RequestHeader) String() string

type ResourceSpec 

type ResourceSpec struct {
	Kind        ResourceSpec_ResourceKind `protobuf:"varint,1,opt,name=kind,proto3,enum=scql.pb.ResourceSpec_ResourceKind" json:"kind,omitempty"`
	ProjectId   string                    `protobuf:"bytes,2,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	TableNames  []string                  `protobuf:"bytes,3,rep,name=table_names,json=tableNames,proto3" json:"table_names,omitempty"`
	DestParties []string                  `protobuf:"bytes,4,rep,name=dest_parties,json=destParties,proto3" json:"dest_parties,omitempty"`
	// contains filtered or unexported fields
}

func (*ResourceSpec) Descriptor deprecated 

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

Deprecated: Use ResourceSpec.ProtoReflect.Descriptor instead.

func (*ResourceSpec) GetDestParties 

func (x *ResourceSpec) GetDestParties() []string

func (*ResourceSpec) GetKind 

func (x *ResourceSpec) GetKind() ResourceSpec_ResourceKind

func (*ResourceSpec) GetProjectId 

func (x *ResourceSpec) GetProjectId() string

func (*ResourceSpec) GetTableNames 

func (x *ResourceSpec) GetTableNames() []string

func (*ResourceSpec) ProtoMessage 

func (*ResourceSpec) ProtoMessage()

func (*ResourceSpec) ProtoReflect 

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

func (*ResourceSpec) Reset 

func (x *ResourceSpec) Reset()

func (*ResourceSpec) String 

func (x *ResourceSpec) String() string

type ResourceSpec_ResourceKind 

type ResourceSpec_ResourceKind int32
const (
	ResourceSpec_Project ResourceSpec_ResourceKind = 0
	ResourceSpec_Table   ResourceSpec_ResourceKind = 1
	ResourceSpec_CCL     ResourceSpec_ResourceKind = 2
	ResourceSpec_All     ResourceSpec_ResourceKind = 3
)

func (ResourceSpec_ResourceKind) Descriptor 

func (ResourceSpec_ResourceKind) Descriptor() protoreflect.EnumDescriptor

func (ResourceSpec_ResourceKind) Enum 

func (x ResourceSpec_ResourceKind) Enum() *ResourceSpec_ResourceKind

func (ResourceSpec_ResourceKind) EnumDescriptor deprecated 

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

Deprecated: Use ResourceSpec_ResourceKind.Descriptor instead.

func (ResourceSpec_ResourceKind) Number 

func (x ResourceSpec_ResourceKind) Number() protoreflect.EnumNumber

func (ResourceSpec_ResourceKind) String 

func (x ResourceSpec_ResourceKind) String() string

func (ResourceSpec_ResourceKind) Type 

func (ResourceSpec_ResourceKind) Type() protoreflect.EnumType

type RevokeCCLRequest 

type RevokeCCLRequest struct {
	ProjectId         string           `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ColumnControlList []*ColumnControl `protobuf:"bytes,2,rep,name=column_control_list,json=columnControlList,proto3" json:"column_control_list,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeCCLRequest) Descriptor deprecated 

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

Deprecated: Use RevokeCCLRequest.ProtoReflect.Descriptor instead.

func (*RevokeCCLRequest) GetColumnControlList 

func (x *RevokeCCLRequest) GetColumnControlList() []*ColumnControl

func (*RevokeCCLRequest) GetProjectId 

func (x *RevokeCCLRequest) GetProjectId() string

func (*RevokeCCLRequest) ProtoMessage 

func (*RevokeCCLRequest) ProtoMessage()

func (*RevokeCCLRequest) ProtoReflect 

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

func (*RevokeCCLRequest) Reset 

func (x *RevokeCCLRequest) Reset()

func (*RevokeCCLRequest) String 

func (x *RevokeCCLRequest) String() string

type RevokeCCLResponse 

type RevokeCCLResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*RevokeCCLResponse) Descriptor deprecated 

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

Deprecated: Use RevokeCCLResponse.ProtoReflect.Descriptor instead.

func (*RevokeCCLResponse) GetStatus 

func (x *RevokeCCLResponse) GetStatus() *Status

func (*RevokeCCLResponse) ProtoMessage 

func (*RevokeCCLResponse) ProtoMessage()

func (*RevokeCCLResponse) ProtoReflect 

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

func (*RevokeCCLResponse) Reset 

func (x *RevokeCCLResponse) Reset()

func (*RevokeCCLResponse) String 

func (x *RevokeCCLResponse) String() string

type RunExecutionPlanRequest 

type RunExecutionPlanRequest struct {
	SessionParams *SessionStartParams `protobuf:"bytes,1,opt,name=session_params,json=sessionParams,proto3" json:"session_params,omitempty"`
	Graph         *SubGraph           `protobuf:"bytes,2,opt,name=graph,proto3" json:"graph,omitempty"`
	Async         bool                `protobuf:"varint,3,opt,name=async,proto3" json:"async,omitempty"`
	CallbackUrl   string              `protobuf:"bytes,4,opt,name=callback_url,json=callbackUrl,proto3" json:"callback_url,omitempty"`
	DebugOpts     *DebugOptions       `protobuf:"bytes,5,opt,name=debug_opts,json=debugOpts,proto3" json:"debug_opts,omitempty"`
	// contains filtered or unexported fields
}

func (*RunExecutionPlanRequest) Descriptor deprecated 

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

Deprecated: Use RunExecutionPlanRequest.ProtoReflect.Descriptor instead.

func (*RunExecutionPlanRequest) GetAsync 

func (x *RunExecutionPlanRequest) GetAsync() bool

func (*RunExecutionPlanRequest) GetCallbackUrl 

func (x *RunExecutionPlanRequest) GetCallbackUrl() string

func (*RunExecutionPlanRequest) GetDebugOpts 

func (x *RunExecutionPlanRequest) GetDebugOpts() *DebugOptions

func (*RunExecutionPlanRequest) GetGraph 

func (x *RunExecutionPlanRequest) GetGraph() *SubGraph

func (*RunExecutionPlanRequest) GetSessionParams 

func (x *RunExecutionPlanRequest) GetSessionParams() *SessionStartParams

func (*RunExecutionPlanRequest) ProtoMessage 

func (*RunExecutionPlanRequest) ProtoMessage()

func (*RunExecutionPlanRequest) ProtoReflect 

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

func (*RunExecutionPlanRequest) Reset 

func (x *RunExecutionPlanRequest) Reset()

func (*RunExecutionPlanRequest) String 

func (x *RunExecutionPlanRequest) String() string

type RunExecutionPlanResponse 

type RunExecutionPlanResponse struct {
	Status          *Status   `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	OutColumns      []*Tensor `protobuf:"bytes,2,rep,name=out_columns,json=outColumns,proto3" json:"out_columns,omitempty"`
	SessionId       string    `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	PartyCode       string    `protobuf:"bytes,4,opt,name=party_code,json=partyCode,proto3" json:"party_code,omitempty"`
	NumRowsAffected int64     `protobuf:"varint,5,opt,name=num_rows_affected,json=numRowsAffected,proto3" json:"num_rows_affected,omitempty"`
	// contains filtered or unexported fields
}

func (*RunExecutionPlanResponse) Descriptor deprecated 

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

Deprecated: Use RunExecutionPlanResponse.ProtoReflect.Descriptor instead.

func (*RunExecutionPlanResponse) GetNumRowsAffected 

func (x *RunExecutionPlanResponse) GetNumRowsAffected() int64

func (*RunExecutionPlanResponse) GetOutColumns 

func (x *RunExecutionPlanResponse) GetOutColumns() []*Tensor

func (*RunExecutionPlanResponse) GetPartyCode 

func (x *RunExecutionPlanResponse) GetPartyCode() string

func (*RunExecutionPlanResponse) GetSessionId 

func (x *RunExecutionPlanResponse) GetSessionId() string

func (*RunExecutionPlanResponse) GetStatus 

func (x *RunExecutionPlanResponse) GetStatus() *Status

func (*RunExecutionPlanResponse) ProtoMessage 

func (*RunExecutionPlanResponse) ProtoMessage()

func (*RunExecutionPlanResponse) ProtoReflect 

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

func (*RunExecutionPlanResponse) Reset 

func (x *RunExecutionPlanResponse) Reset()

func (*RunExecutionPlanResponse) String 

func (x *RunExecutionPlanResponse) String() string

type SCDBCredential 

type SCDBCredential struct {
	User *User `protobuf:"bytes,1,opt,name=user,proto3" json:"user,omitempty"`
	// contains filtered or unexported fields
}

func (*SCDBCredential) Descriptor deprecated 

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

Deprecated: Use SCDBCredential.ProtoReflect.Descriptor instead.

func (*SCDBCredential) GetUser 

func (x *SCDBCredential) GetUser() *User

func (*SCDBCredential) ProtoMessage 

func (*SCDBCredential) ProtoMessage()

func (*SCDBCredential) ProtoReflect 

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

func (*SCDBCredential) Reset 

func (x *SCDBCredential) Reset()

func (*SCDBCredential) String 

func (x *SCDBCredential) String() string

type SCDBFetchRequest 

type SCDBFetchRequest struct {
	Header        *RequestHeader  `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	User          *SCDBCredential `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	ScdbSessionId string          `protobuf:"bytes,3,opt,name=scdb_session_id,json=scdbSessionId,proto3" json:"scdb_session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SCDBFetchRequest) Descriptor deprecated 

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

Deprecated: Use SCDBFetchRequest.ProtoReflect.Descriptor instead.

func (*SCDBFetchRequest) GetHeader 

func (x *SCDBFetchRequest) GetHeader() *RequestHeader

func (*SCDBFetchRequest) GetScdbSessionId 

func (x *SCDBFetchRequest) GetScdbSessionId() string

func (*SCDBFetchRequest) GetUser 

func (x *SCDBFetchRequest) GetUser() *SCDBCredential

func (*SCDBFetchRequest) ProtoMessage 

func (*SCDBFetchRequest) ProtoMessage()

func (*SCDBFetchRequest) ProtoReflect 

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

func (*SCDBFetchRequest) Reset 

func (x *SCDBFetchRequest) Reset()

func (*SCDBFetchRequest) String 

func (x *SCDBFetchRequest) String() string

type SCDBQueryRequest 

type SCDBQueryRequest struct {
	Header                 *RequestHeader  `protobuf:"bytes,1,opt,name=header,proto3" json:"header,omitempty"`
	User                   *SCDBCredential `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Query                  string          `protobuf:"bytes,3,opt,name=query,proto3" json:"query,omitempty"`
	QueryResultCallbackUrl string          `` /* 131-byte string literal not displayed */
	BizRequestId           string          `protobuf:"bytes,5,opt,name=biz_request_id,json=bizRequestId,proto3" json:"biz_request_id,omitempty"`
	DbName                 string          `protobuf:"bytes,6,opt,name=db_name,json=dbName,proto3" json:"db_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SCDBQueryRequest) Descriptor deprecated 

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

Deprecated: Use SCDBQueryRequest.ProtoReflect.Descriptor instead.

func (*SCDBQueryRequest) GetBizRequestId 

func (x *SCDBQueryRequest) GetBizRequestId() string

func (*SCDBQueryRequest) GetDbName 

func (x *SCDBQueryRequest) GetDbName() string

func (*SCDBQueryRequest) GetHeader 

func (x *SCDBQueryRequest) GetHeader() *RequestHeader

func (*SCDBQueryRequest) GetQuery 

func (x *SCDBQueryRequest) GetQuery() string

func (*SCDBQueryRequest) GetQueryResultCallbackUrl 

func (x *SCDBQueryRequest) GetQueryResultCallbackUrl() string

func (*SCDBQueryRequest) GetUser 

func (x *SCDBQueryRequest) GetUser() *SCDBCredential

func (*SCDBQueryRequest) ProtoMessage 

func (*SCDBQueryRequest) ProtoMessage()

func (*SCDBQueryRequest) ProtoReflect 

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

func (*SCDBQueryRequest) Reset 

func (x *SCDBQueryRequest) Reset()

func (*SCDBQueryRequest) String 

func (x *SCDBQueryRequest) String() string

type SCDBQueryResultCallbackClient 

type SCDBQueryResultCallbackClient interface {
	ReportQueryResult(ctx context.Context, in *SCDBQueryResultResponse, opts ...grpc.CallOption) (*emptypb.Empty, error)
}

SCDBQueryResultCallbackClient is the client API for SCDBQueryResultCallback service.

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

func NewSCDBQueryResultCallbackClient 

func NewSCDBQueryResultCallbackClient(cc grpc.ClientConnInterface) SCDBQueryResultCallbackClient

type SCDBQueryResultCallbackServer 

type SCDBQueryResultCallbackServer interface {
	ReportQueryResult(context.Context, *SCDBQueryResultResponse) (*emptypb.Empty, error)
}

SCDBQueryResultCallbackServer is the server API for SCDBQueryResultCallback service.

type SCDBQueryResultResponse 

type SCDBQueryResultResponse struct {
	Status        *Status       `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	OutColumns    []*Tensor     `protobuf:"bytes,2,rep,name=out_columns,json=outColumns,proto3" json:"out_columns,omitempty"`
	ScdbSessionId string        `protobuf:"bytes,3,opt,name=scdb_session_id,json=scdbSessionId,proto3" json:"scdb_session_id,omitempty"`
	AffectedRows  int64         `protobuf:"varint,4,opt,name=affected_rows,json=affectedRows,proto3" json:"affected_rows,omitempty"`
	Warnings      []*SQLWarning `protobuf:"bytes,5,rep,name=warnings,proto3" json:"warnings,omitempty"`
	// contains filtered or unexported fields
}

func (*SCDBQueryResultResponse) Descriptor deprecated 

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

Deprecated: Use SCDBQueryResultResponse.ProtoReflect.Descriptor instead.

func (*SCDBQueryResultResponse) GetAffectedRows 

func (x *SCDBQueryResultResponse) GetAffectedRows() int64

func (*SCDBQueryResultResponse) GetOutColumns 

func (x *SCDBQueryResultResponse) GetOutColumns() []*Tensor

func (*SCDBQueryResultResponse) GetScdbSessionId 

func (x *SCDBQueryResultResponse) GetScdbSessionId() string

func (*SCDBQueryResultResponse) GetStatus 

func (x *SCDBQueryResultResponse) GetStatus() *Status

func (*SCDBQueryResultResponse) GetWarnings 

func (x *SCDBQueryResultResponse) GetWarnings() []*SQLWarning

func (*SCDBQueryResultResponse) ProtoMessage 

func (*SCDBQueryResultResponse) ProtoMessage()

func (*SCDBQueryResultResponse) ProtoReflect 

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

func (*SCDBQueryResultResponse) Reset 

func (x *SCDBQueryResultResponse) Reset()

func (*SCDBQueryResultResponse) String 

func (x *SCDBQueryResultResponse) String() string

type SCDBServiceClient 

type SCDBServiceClient interface {
	Submit(ctx context.Context, in *SCDBQueryRequest, opts ...grpc.CallOption) (*SCDBSubmitResponse, error)
	Fetch(ctx context.Context, in *SCDBFetchRequest, opts ...grpc.CallOption) (*SCDBQueryResultResponse, error)
	SubmitAndGet(ctx context.Context, in *SCDBQueryRequest, opts ...grpc.CallOption) (*SCDBQueryResultResponse, error)
}

SCDBServiceClient is the client API for SCDBService service.

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

func NewSCDBServiceClient 

func NewSCDBServiceClient(cc grpc.ClientConnInterface) SCDBServiceClient

type SCDBServiceServer 

type SCDBServiceServer interface {
	Submit(context.Context, *SCDBQueryRequest) (*SCDBSubmitResponse, error)
	Fetch(context.Context, *SCDBFetchRequest) (*SCDBQueryResultResponse, error)
	SubmitAndGet(context.Context, *SCDBQueryRequest) (*SCDBQueryResultResponse, error)
}

SCDBServiceServer is the server API for SCDBService service.

type SCDBSubmitResponse 

type SCDBSubmitResponse struct {
	Status        *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ScdbSessionId string  `protobuf:"bytes,2,opt,name=scdb_session_id,json=scdbSessionId,proto3" json:"scdb_session_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SCDBSubmitResponse) Descriptor deprecated 

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

Deprecated: Use SCDBSubmitResponse.ProtoReflect.Descriptor instead.

func (*SCDBSubmitResponse) GetScdbSessionId 

func (x *SCDBSubmitResponse) GetScdbSessionId() string

func (*SCDBSubmitResponse) GetStatus 

func (x *SCDBSubmitResponse) GetStatus() *Status

func (*SCDBSubmitResponse) ProtoMessage 

func (*SCDBSubmitResponse) ProtoMessage()

func (*SCDBSubmitResponse) ProtoReflect 

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

func (*SCDBSubmitResponse) Reset 

func (x *SCDBSubmitResponse) Reset()

func (*SCDBSubmitResponse) String 

func (x *SCDBSubmitResponse) String() string

type SCQLEngineServiceClient 

type SCQLEngineServiceClient interface {
	RunExecutionPlan(ctx context.Context, in *RunExecutionPlanRequest, opts ...grpc.CallOption) (*RunExecutionPlanResponse, error)
	StopSession(ctx context.Context, in *StopSessionRequest, opts ...grpc.CallOption) (*Status, error)
}

SCQLEngineServiceClient is the client API for SCQLEngineService service.

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

func NewSCQLEngineServiceClient 

func NewSCQLEngineServiceClient(cc grpc.ClientConnInterface) SCQLEngineServiceClient

type SCQLEngineServiceServer 

type SCQLEngineServiceServer interface {
	RunExecutionPlan(context.Context, *RunExecutionPlanRequest) (*RunExecutionPlanResponse, error)
	StopSession(context.Context, *StopSessionRequest) (*Status, error)
}

SCQLEngineServiceServer is the server API for SCQLEngineService service.

type SQLWarning 

type SQLWarning struct {
	Reason string `protobuf:"bytes,1,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*SQLWarning) Descriptor deprecated 

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

Deprecated: Use SQLWarning.ProtoReflect.Descriptor instead.

func (*SQLWarning) GetReason 

func (x *SQLWarning) GetReason() string

func (*SQLWarning) ProtoMessage 

func (*SQLWarning) ProtoMessage()

func (*SQLWarning) ProtoReflect 

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

func (*SQLWarning) Reset 

func (x *SQLWarning) Reset()

func (*SQLWarning) String 

func (x *SQLWarning) String() string

type SchedulingPolicy 

type SchedulingPolicy struct {
	WorkerNum int32     `protobuf:"varint,1,opt,name=worker_num,json=workerNum,proto3" json:"worker_num,omitempty"`
	Subdags   []*SubDAG `protobuf:"bytes,2,rep,name=subdags,proto3" json:"subdags,omitempty"`
	// contains filtered or unexported fields
}

func (*SchedulingPolicy) Descriptor deprecated 

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

Deprecated: Use SchedulingPolicy.ProtoReflect.Descriptor instead.

func (*SchedulingPolicy) GetSubdags 

func (x *SchedulingPolicy) GetSubdags() []*SubDAG

func (*SchedulingPolicy) GetWorkerNum 

func (x *SchedulingPolicy) GetWorkerNum() int32

func (*SchedulingPolicy) ProtoMessage 

func (*SchedulingPolicy) ProtoMessage()

func (*SchedulingPolicy) ProtoReflect 

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

func (*SchedulingPolicy) Reset 

func (x *SchedulingPolicy) Reset()

func (*SchedulingPolicy) String 

func (x *SchedulingPolicy) String() string

type SecurityCompromiseConfig 

type SecurityCompromiseConfig struct {
	RevealGroupMark  bool   `protobuf:"varint,1,opt,name=reveal_group_mark,json=revealGroupMark,proto3" json:"reveal_group_mark,omitempty"`
	GroupByThreshold uint64 `protobuf:"varint,2,opt,name=group_by_threshold,json=groupByThreshold,proto3" json:"group_by_threshold,omitempty"`
	// contains filtered or unexported fields
}

func (*SecurityCompromiseConfig) Descriptor deprecated 

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

Deprecated: Use SecurityCompromiseConfig.ProtoReflect.Descriptor instead.

func (*SecurityCompromiseConfig) GetGroupByThreshold 

func (x *SecurityCompromiseConfig) GetGroupByThreshold() uint64

func (*SecurityCompromiseConfig) GetRevealGroupMark 

func (x *SecurityCompromiseConfig) GetRevealGroupMark() bool

func (*SecurityCompromiseConfig) ProtoMessage 

func (*SecurityCompromiseConfig) ProtoMessage()

func (*SecurityCompromiseConfig) ProtoReflect 

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

func (*SecurityCompromiseConfig) Reset 

func (x *SecurityCompromiseConfig) Reset()

func (*SecurityCompromiseConfig) String 

func (x *SecurityCompromiseConfig) String() string

type SecurityConfig 

type SecurityConfig struct {
	ColumnControlList []*SecurityConfig_ColumnControl `protobuf:"bytes,1,rep,name=column_control_list,json=columnControlList,proto3" json:"column_control_list,omitempty"`
	// contains filtered or unexported fields
}

func (*SecurityConfig) Descriptor deprecated 

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

Deprecated: Use SecurityConfig.ProtoReflect.Descriptor instead.

func (*SecurityConfig) GetColumnControlList 

func (x *SecurityConfig) GetColumnControlList() []*SecurityConfig_ColumnControl

func (*SecurityConfig) ProtoMessage 

func (*SecurityConfig) ProtoMessage()

func (*SecurityConfig) ProtoReflect 

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

func (*SecurityConfig) Reset 

func (x *SecurityConfig) Reset()

func (*SecurityConfig) String 

func (x *SecurityConfig) String() string

type SecurityConfig_ColumnControl 

type SecurityConfig_ColumnControl struct {
	PartyCode    string                                  `protobuf:"bytes,1,opt,name=party_code,json=partyCode,proto3" json:"party_code,omitempty"`
	Visibility   SecurityConfig_ColumnControl_Visibility `` /* 127-byte string literal not displayed */
	DatabaseName string                                  `protobuf:"bytes,3,opt,name=database_name,json=databaseName,proto3" json:"database_name,omitempty"`
	TableName    string                                  `protobuf:"bytes,4,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	ColumnName   string                                  `protobuf:"bytes,5,opt,name=column_name,json=columnName,proto3" json:"column_name,omitempty"`
	// contains filtered or unexported fields
}

func (*SecurityConfig_ColumnControl) Descriptor deprecated 

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

Deprecated: Use SecurityConfig_ColumnControl.ProtoReflect.Descriptor instead.

func (*SecurityConfig_ColumnControl) GetColumnName 

func (x *SecurityConfig_ColumnControl) GetColumnName() string

func (*SecurityConfig_ColumnControl) GetDatabaseName 

func (x *SecurityConfig_ColumnControl) GetDatabaseName() string

func (*SecurityConfig_ColumnControl) GetPartyCode 

func (x *SecurityConfig_ColumnControl) GetPartyCode() string

func (*SecurityConfig_ColumnControl) GetTableName 

func (x *SecurityConfig_ColumnControl) GetTableName() string

func (*SecurityConfig_ColumnControl) GetVisibility 

func (x *SecurityConfig_ColumnControl) GetVisibility() SecurityConfig_ColumnControl_Visibility

func (*SecurityConfig_ColumnControl) ProtoMessage 

func (*SecurityConfig_ColumnControl) ProtoMessage()

func (*SecurityConfig_ColumnControl) ProtoReflect 

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

func (*SecurityConfig_ColumnControl) Reset 

func (x *SecurityConfig_ColumnControl) Reset()

func (*SecurityConfig_ColumnControl) String 

func (x *SecurityConfig_ColumnControl) String() string

type SecurityConfig_ColumnControl_Visibility 

type SecurityConfig_ColumnControl_Visibility int32
const (
	SecurityConfig_ColumnControl_UNKNOWN                   SecurityConfig_ColumnControl_Visibility = 0
	SecurityConfig_ColumnControl_PLAINTEXT                 SecurityConfig_ColumnControl_Visibility = 1
	SecurityConfig_ColumnControl_ENCRYPTED_ONLY            SecurityConfig_ColumnControl_Visibility = 2
	SecurityConfig_ColumnControl_PLAINTEXT_AFTER_JOIN      SecurityConfig_ColumnControl_Visibility = 3
	SecurityConfig_ColumnControl_PLAINTEXT_AFTER_GROUP_BY  SecurityConfig_ColumnControl_Visibility = 4
	SecurityConfig_ColumnControl_PLAINTEXT_AFTER_COMPARE   SecurityConfig_ColumnControl_Visibility = 5
	SecurityConfig_ColumnControl_PLAINTEXT_AFTER_AGGREGATE SecurityConfig_ColumnControl_Visibility = 6
)

func (SecurityConfig_ColumnControl_Visibility) Descriptor 

func (SecurityConfig_ColumnControl_Visibility) Descriptor() protoreflect.EnumDescriptor

func (SecurityConfig_ColumnControl_Visibility) Enum 

func (x SecurityConfig_ColumnControl_Visibility) Enum() *SecurityConfig_ColumnControl_Visibility

func (SecurityConfig_ColumnControl_Visibility) EnumDescriptor deprecated 

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

Deprecated: Use SecurityConfig_ColumnControl_Visibility.Descriptor instead.

func (SecurityConfig_ColumnControl_Visibility) Number 

func (x SecurityConfig_ColumnControl_Visibility) Number() protoreflect.EnumNumber

func (SecurityConfig_ColumnControl_Visibility) String 

func (x SecurityConfig_ColumnControl_Visibility) String() string

func (SecurityConfig_ColumnControl_Visibility) Type 

func (SecurityConfig_ColumnControl_Visibility) Type() protoreflect.EnumType

type SessionStartParams 

type SessionStartParams struct {
	PartyCode     string                      `protobuf:"bytes,1,opt,name=party_code,json=partyCode,proto3" json:"party_code,omitempty"`
	Parties       []*SessionStartParams_Party `protobuf:"bytes,2,rep,name=parties,proto3" json:"parties,omitempty"`
	SessionId     string                      `protobuf:"bytes,3,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	SpuRuntimeCfg *spu.RuntimeConfig          `protobuf:"bytes,4,opt,name=spu_runtime_cfg,json=spuRuntimeCfg,proto3" json:"spu_runtime_cfg,omitempty"`
	TimeZone      string                      `protobuf:"bytes,5,opt,name=time_zone,json=timeZone,proto3" json:"time_zone,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionStartParams) Descriptor deprecated 

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

Deprecated: Use SessionStartParams.ProtoReflect.Descriptor instead.

func (*SessionStartParams) GetParties 

func (x *SessionStartParams) GetParties() []*SessionStartParams_Party

func (*SessionStartParams) GetPartyCode 

func (x *SessionStartParams) GetPartyCode() string

func (*SessionStartParams) GetSessionId 

func (x *SessionStartParams) GetSessionId() string

func (*SessionStartParams) GetSpuRuntimeCfg 

func (x *SessionStartParams) GetSpuRuntimeCfg() *spu.RuntimeConfig

func (*SessionStartParams) GetTimeZone 

func (x *SessionStartParams) GetTimeZone() string

func (*SessionStartParams) ProtoMessage 

func (*SessionStartParams) ProtoMessage()

func (*SessionStartParams) ProtoReflect 

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

func (*SessionStartParams) Reset 

func (x *SessionStartParams) Reset()

func (*SessionStartParams) String 

func (x *SessionStartParams) String() string

type SessionStartParams_Party 

type SessionStartParams_Party struct {
	Code      string `protobuf:"bytes,1,opt,name=code,proto3" json:"code,omitempty"`
	Name      string `protobuf:"bytes,2,opt,name=name,proto3" json:"name,omitempty"`
	Host      string `protobuf:"bytes,3,opt,name=host,proto3" json:"host,omitempty"`
	Rank      int32  `protobuf:"varint,4,opt,name=rank,proto3" json:"rank,omitempty"`
	PublicKey string `protobuf:"bytes,5,opt,name=public_key,json=publicKey,proto3" json:"public_key,omitempty"`
	// contains filtered or unexported fields
}

func (*SessionStartParams_Party) Descriptor deprecated 

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

Deprecated: Use SessionStartParams_Party.ProtoReflect.Descriptor instead.

func (*SessionStartParams_Party) GetCode 

func (x *SessionStartParams_Party) GetCode() string

func (*SessionStartParams_Party) GetHost 

func (x *SessionStartParams_Party) GetHost() string

func (*SessionStartParams_Party) GetName 

func (x *SessionStartParams_Party) GetName() string

func (*SessionStartParams_Party) GetPublicKey 

func (x *SessionStartParams_Party) GetPublicKey() string

func (*SessionStartParams_Party) GetRank 

func (x *SessionStartParams_Party) GetRank() int32

func (*SessionStartParams_Party) ProtoMessage 

func (*SessionStartParams_Party) ProtoMessage()

func (*SessionStartParams_Party) ProtoReflect 

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

func (*SessionStartParams_Party) Reset 

func (x *SessionStartParams_Party) Reset()

func (*SessionStartParams_Party) String 

func (x *SessionStartParams_Party) String() string

type ShowCCLRequest 

type ShowCCLRequest struct {
	ProjectId   string   `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Tables      []string `protobuf:"bytes,2,rep,name=tables,proto3" json:"tables,omitempty"`
	DestParties []string `protobuf:"bytes,3,rep,name=dest_parties,json=destParties,proto3" json:"dest_parties,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowCCLRequest) Descriptor deprecated 

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

Deprecated: Use ShowCCLRequest.ProtoReflect.Descriptor instead.

func (*ShowCCLRequest) GetDestParties 

func (x *ShowCCLRequest) GetDestParties() []string

func (*ShowCCLRequest) GetProjectId 

func (x *ShowCCLRequest) GetProjectId() string

func (*ShowCCLRequest) GetTables 

func (x *ShowCCLRequest) GetTables() []string

func (*ShowCCLRequest) ProtoMessage 

func (*ShowCCLRequest) ProtoMessage()

func (*ShowCCLRequest) ProtoReflect 

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

func (*ShowCCLRequest) Reset 

func (x *ShowCCLRequest) Reset()

func (*ShowCCLRequest) String 

func (x *ShowCCLRequest) String() string

type ShowCCLResponse 

type ShowCCLResponse struct {
	Status            *Status          `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	ColumnControlList []*ColumnControl `protobuf:"bytes,2,rep,name=column_control_list,json=columnControlList,proto3" json:"column_control_list,omitempty"`
	// contains filtered or unexported fields
}

func (*ShowCCLResponse) Descriptor deprecated 

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

Deprecated: Use ShowCCLResponse.ProtoReflect.Descriptor instead.

func (*ShowCCLResponse) GetColumnControlList 

func (x *ShowCCLResponse) GetColumnControlList() []*ColumnControl

func (*ShowCCLResponse) GetStatus 

func (x *ShowCCLResponse) GetStatus() *Status

func (*ShowCCLResponse) ProtoMessage 

func (*ShowCCLResponse) ProtoMessage()

func (*ShowCCLResponse) ProtoReflect 

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

func (*ShowCCLResponse) Reset 

func (x *ShowCCLResponse) Reset()

func (*ShowCCLResponse) String 

func (x *ShowCCLResponse) 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"`
	Details []*anypb.Any `protobuf:"bytes,3,rep,name=details,proto3" json:"details,omitempty"`
	// contains filtered or unexported fields
}

func (*Status) Descriptor deprecated 

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

Deprecated: Use Status.ProtoReflect.Descriptor instead.

func (*Status) GetCode 

func (x *Status) GetCode() int32

func (*Status) GetDetails 

func (x *Status) GetDetails() []*anypb.Any

func (*Status) GetMessage 

func (x *Status) GetMessage() string

func (*Status) ProtoMessage 

func (*Status) ProtoMessage()

func (*Status) ProtoReflect 

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

func (*Status) Reset 

func (x *Status) Reset()

func (*Status) String 

func (x *Status) String() string

type StopSessionRequest 

type StopSessionRequest struct {
	SessionId string `protobuf:"bytes,1,opt,name=session_id,json=sessionId,proto3" json:"session_id,omitempty"`
	Reason    string `protobuf:"bytes,2,opt,name=reason,proto3" json:"reason,omitempty"`
	// contains filtered or unexported fields
}

func (*StopSessionRequest) Descriptor deprecated 

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

Deprecated: Use StopSessionRequest.ProtoReflect.Descriptor instead.

func (*StopSessionRequest) GetReason 

func (x *StopSessionRequest) GetReason() string

func (*StopSessionRequest) GetSessionId 

func (x *StopSessionRequest) GetSessionId() string

func (*StopSessionRequest) ProtoMessage 

func (*StopSessionRequest) ProtoMessage()

func (*StopSessionRequest) ProtoReflect 

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

func (*StopSessionRequest) Reset 

func (x *StopSessionRequest) Reset()

func (*StopSessionRequest) String 

func (x *StopSessionRequest) String() string

type SubDAG 

type SubDAG struct {
	Jobs                     []*SubDAG_Job `protobuf:"bytes,1,rep,name=jobs,proto3" json:"jobs,omitempty"`
	NeedCallBarrierAfterJobs bool          `` /* 140-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*SubDAG) Descriptor deprecated 

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

Deprecated: Use SubDAG.ProtoReflect.Descriptor instead.

func (*SubDAG) GetJobs 

func (x *SubDAG) GetJobs() []*SubDAG_Job

func (*SubDAG) GetNeedCallBarrierAfterJobs 

func (x *SubDAG) GetNeedCallBarrierAfterJobs() bool

func (*SubDAG) ProtoMessage 

func (*SubDAG) ProtoMessage()

func (*SubDAG) ProtoReflect 

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

func (*SubDAG) Reset 

func (x *SubDAG) Reset()

func (*SubDAG) String 

func (x *SubDAG) String() string

type SubDAG_Job 

type SubDAG_Job struct {
	WorkerId int32    `protobuf:"varint,1,opt,name=worker_id,json=workerId,proto3" json:"worker_id,omitempty"`
	NodeIds  []string `protobuf:"bytes,2,rep,name=node_ids,json=nodeIds,proto3" json:"node_ids,omitempty"`
	// contains filtered or unexported fields
}

func (*SubDAG_Job) Descriptor deprecated 

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

Deprecated: Use SubDAG_Job.ProtoReflect.Descriptor instead.

func (*SubDAG_Job) GetNodeIds 

func (x *SubDAG_Job) GetNodeIds() []string

func (*SubDAG_Job) GetWorkerId 

func (x *SubDAG_Job) GetWorkerId() int32

func (*SubDAG_Job) ProtoMessage 

func (*SubDAG_Job) ProtoMessage()

func (*SubDAG_Job) ProtoReflect 

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

func (*SubDAG_Job) Reset 

func (x *SubDAG_Job) Reset()

func (*SubDAG_Job) String 

func (x *SubDAG_Job) String() string

type SubGraph 

type SubGraph struct {
	Nodes         map[string]*ExecNode `` /* 151-byte string literal not displayed */
	Policy        *SchedulingPolicy    `protobuf:"bytes,2,opt,name=policy,proto3" json:"policy,omitempty"`
	GraphChecksum []byte               `protobuf:"bytes,3,opt,name=graph_checksum,json=graphChecksum,proto3" json:"graph_checksum,omitempty"`
	// contains filtered or unexported fields
}

func (*SubGraph) Descriptor deprecated 

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

Deprecated: Use SubGraph.ProtoReflect.Descriptor instead.

func (*SubGraph) GetGraphChecksum 

func (x *SubGraph) GetGraphChecksum() []byte

func (*SubGraph) GetNodes 

func (x *SubGraph) GetNodes() map[string]*ExecNode

func (*SubGraph) GetPolicy 

func (x *SubGraph) GetPolicy() *SchedulingPolicy

func (*SubGraph) ProtoMessage 

func (*SubGraph) ProtoMessage()

func (*SubGraph) ProtoReflect 

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

func (*SubGraph) Reset 

func (x *SubGraph) Reset()

func (*SubGraph) String 

func (x *SubGraph) String() string

type SubmitResponse 

type SubmitResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	JobId  string  `protobuf:"bytes,2,opt,name=job_id,json=jobId,proto3" json:"job_id,omitempty"`
	// contains filtered or unexported fields
}

func (*SubmitResponse) Descriptor deprecated 

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

Deprecated: Use SubmitResponse.ProtoReflect.Descriptor instead.

func (*SubmitResponse) GetJobId 

func (x *SubmitResponse) GetJobId() string

func (*SubmitResponse) GetStatus 

func (x *SubmitResponse) GetStatus() *Status

func (*SubmitResponse) ProtoMessage 

func (*SubmitResponse) ProtoMessage()

func (*SubmitResponse) ProtoReflect 

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

func (*SubmitResponse) Reset 

func (x *SubmitResponse) Reset()

func (*SubmitResponse) String 

func (x *SubmitResponse) String() string

type SyncInfoRequest 

type SyncInfoRequest struct {
	ClientId    *PartyId     `protobuf:"bytes,1,opt,name=client_id,json=clientId,proto3" json:"client_id,omitempty"`
	Signature   []byte       `protobuf:"bytes,2,opt,name=signature,proto3" json:"signature,omitempty"`
	ProjectId   string       `protobuf:"bytes,3,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	ChangeEntry *ChangeEntry `protobuf:"bytes,4,opt,name=change_entry,json=changeEntry,proto3" json:"change_entry,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncInfoRequest) Descriptor deprecated 

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

Deprecated: Use SyncInfoRequest.ProtoReflect.Descriptor instead.

func (*SyncInfoRequest) GetChangeEntry 

func (x *SyncInfoRequest) GetChangeEntry() *ChangeEntry

func (*SyncInfoRequest) GetClientId 

func (x *SyncInfoRequest) GetClientId() *PartyId

func (*SyncInfoRequest) GetProjectId 

func (x *SyncInfoRequest) GetProjectId() string

func (*SyncInfoRequest) GetSignature 

func (x *SyncInfoRequest) GetSignature() []byte

func (*SyncInfoRequest) ProtoMessage 

func (*SyncInfoRequest) ProtoMessage()

func (*SyncInfoRequest) ProtoReflect 

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

func (*SyncInfoRequest) Reset 

func (x *SyncInfoRequest) Reset()

func (*SyncInfoRequest) String 

func (x *SyncInfoRequest) String() string

type SyncInfoResponse 

type SyncInfoResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*SyncInfoResponse) Descriptor deprecated 

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

Deprecated: Use SyncInfoResponse.ProtoReflect.Descriptor instead.

func (*SyncInfoResponse) GetStatus 

func (x *SyncInfoResponse) GetStatus() *Status

func (*SyncInfoResponse) ProtoMessage 

func (*SyncInfoResponse) ProtoMessage()

func (*SyncInfoResponse) ProtoReflect 

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

func (*SyncInfoResponse) Reset 

func (x *SyncInfoResponse) Reset()

func (*SyncInfoResponse) String 

func (x *SyncInfoResponse) String() string

type TableEntry 

type TableEntry struct {
	TableName    string               `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	Columns      []*TableEntry_Column `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	IsView       bool                 `protobuf:"varint,3,opt,name=is_view,json=isView,proto3" json:"is_view,omitempty"`
	SelectString string               `protobuf:"bytes,4,opt,name=select_string,json=selectString,proto3" json:"select_string,omitempty"`
	RefTable     string               `protobuf:"bytes,5,opt,name=ref_table,json=refTable,proto3" json:"ref_table,omitempty"`
	DbType       string               `protobuf:"bytes,6,opt,name=db_type,json=dbType,proto3" json:"db_type,omitempty"`
	Owner        *PartyId             `protobuf:"bytes,7,opt,name=owner,proto3" json:"owner,omitempty"`
	// contains filtered or unexported fields
}

func (*TableEntry) Descriptor deprecated 

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

Deprecated: Use TableEntry.ProtoReflect.Descriptor instead.

func (*TableEntry) GetColumns 

func (x *TableEntry) GetColumns() []*TableEntry_Column

func (*TableEntry) GetDbType 

func (x *TableEntry) GetDbType() string

func (*TableEntry) GetIsView 

func (x *TableEntry) GetIsView() bool

func (*TableEntry) GetOwner 

func (x *TableEntry) GetOwner() *PartyId

func (*TableEntry) GetRefTable 

func (x *TableEntry) GetRefTable() string

func (*TableEntry) GetSelectString 

func (x *TableEntry) GetSelectString() string

func (*TableEntry) GetTableName 

func (x *TableEntry) GetTableName() string

func (*TableEntry) ProtoMessage 

func (*TableEntry) ProtoMessage()

func (*TableEntry) ProtoReflect 

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

func (*TableEntry) Reset 

func (x *TableEntry) Reset()

func (*TableEntry) String 

func (x *TableEntry) String() string

type TableEntry_Column 

type TableEntry_Column struct {
	Name            string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Type            string `protobuf:"bytes,2,opt,name=type,proto3" json:"type,omitempty"`
	OrdinalPosition int32  `protobuf:"varint,3,opt,name=ordinal_position,json=ordinalPosition,proto3" json:"ordinal_position,omitempty"`
	// contains filtered or unexported fields
}

func (*TableEntry_Column) Descriptor deprecated 

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

Deprecated: Use TableEntry_Column.ProtoReflect.Descriptor instead.

func (*TableEntry_Column) GetName 

func (x *TableEntry_Column) GetName() string

func (*TableEntry_Column) GetOrdinalPosition 

func (x *TableEntry_Column) GetOrdinalPosition() int32

func (*TableEntry_Column) GetType 

func (x *TableEntry_Column) GetType() string

func (*TableEntry_Column) ProtoMessage 

func (*TableEntry_Column) ProtoMessage()

func (*TableEntry_Column) ProtoReflect 

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

func (*TableEntry_Column) Reset 

func (x *TableEntry_Column) Reset()

func (*TableEntry_Column) String 

func (x *TableEntry_Column) String() string

type TableMeta 

type TableMeta struct {
	TableName  string              `protobuf:"bytes,1,opt,name=table_name,json=tableName,proto3" json:"table_name,omitempty"`
	RefTable   string              `protobuf:"bytes,2,opt,name=ref_table,json=refTable,proto3" json:"ref_table,omitempty"`
	DbType     string              `protobuf:"bytes,3,opt,name=db_type,json=dbType,proto3" json:"db_type,omitempty"`
	TableOwner string              `protobuf:"bytes,4,opt,name=table_owner,json=tableOwner,proto3" json:"table_owner,omitempty"`
	Columns    []*TableMeta_Column `protobuf:"bytes,5,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*TableMeta) Descriptor deprecated 

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

Deprecated: Use TableMeta.ProtoReflect.Descriptor instead.

func (*TableMeta) GetColumns 

func (x *TableMeta) GetColumns() []*TableMeta_Column

func (*TableMeta) GetDbType 

func (x *TableMeta) GetDbType() string

func (*TableMeta) GetRefTable 

func (x *TableMeta) GetRefTable() string

func (*TableMeta) GetTableName 

func (x *TableMeta) GetTableName() string

func (*TableMeta) GetTableOwner 

func (x *TableMeta) GetTableOwner() string

func (*TableMeta) ProtoMessage 

func (*TableMeta) ProtoMessage()

func (*TableMeta) ProtoReflect 

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

func (*TableMeta) Reset 

func (x *TableMeta) Reset()

func (*TableMeta) String 

func (x *TableMeta) String() string

type TableMeta_Column 

type TableMeta_Column struct {
	Name  string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Dtype string `protobuf:"bytes,2,opt,name=dtype,proto3" json:"dtype,omitempty"`
	// contains filtered or unexported fields
}

func (*TableMeta_Column) Descriptor deprecated 

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

Deprecated: Use TableMeta_Column.ProtoReflect.Descriptor instead.

func (*TableMeta_Column) GetDtype 

func (x *TableMeta_Column) GetDtype() string

func (*TableMeta_Column) GetName 

func (x *TableMeta_Column) GetName() string

func (*TableMeta_Column) ProtoMessage 

func (*TableMeta_Column) ProtoMessage()

func (*TableMeta_Column) ProtoReflect 

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

func (*TableMeta_Column) Reset 

func (x *TableMeta_Column) Reset()

func (*TableMeta_Column) String 

func (x *TableMeta_Column) String() string

type TableSchema 

type TableSchema struct {
	Columns []*ColumnDesc `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	// contains filtered or unexported fields
}

func (*TableSchema) Descriptor deprecated 

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

Deprecated: Use TableSchema.ProtoReflect.Descriptor instead.

func (*TableSchema) GetColumns 

func (x *TableSchema) GetColumns() []*ColumnDesc

func (*TableSchema) ProtoMessage 

func (*TableSchema) ProtoMessage()

func (*TableSchema) ProtoReflect 

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

func (*TableSchema) Reset 

func (x *TableSchema) Reset()

func (*TableSchema) String 

func (x *TableSchema) String() string

type Tensor 

type Tensor struct {
	Name       string            `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Shape      *TensorShape      `protobuf:"bytes,2,opt,name=shape,proto3" json:"shape,omitempty"`
	ElemType   PrimitiveDataType `protobuf:"varint,3,opt,name=elem_type,json=elemType,proto3,enum=scql.pb.PrimitiveDataType" json:"elem_type,omitempty"`
	Option     TensorOptions     `protobuf:"varint,4,opt,name=option,proto3,enum=scql.pb.TensorOptions" json:"option,omitempty"`
	Annotation *TensorAnnotation `protobuf:"bytes,5,opt,name=annotation,proto3" json:"annotation,omitempty"`
	Int32Data  []int32           `protobuf:"varint,6,rep,packed,name=int32_data,json=int32Data,proto3" json:"int32_data,omitempty"`
	Int64Data  []int64           `protobuf:"varint,7,rep,packed,name=int64_data,json=int64Data,proto3" json:"int64_data,omitempty"`
	FloatData  []float32         `protobuf:"fixed32,8,rep,packed,name=float_data,json=floatData,proto3" json:"float_data,omitempty"`
	DoubleData []float64         `protobuf:"fixed64,9,rep,packed,name=double_data,json=doubleData,proto3" json:"double_data,omitempty"`
	BoolData   []bool            `protobuf:"varint,10,rep,packed,name=bool_data,json=boolData,proto3" json:"bool_data,omitempty"`
	StringData []string          `protobuf:"bytes,11,rep,name=string_data,json=stringData,proto3" json:"string_data,omitempty"`
	RefNum     int32             `protobuf:"varint,12,opt,name=ref_num,json=refNum,proto3" json:"ref_num,omitempty"`
	// contains filtered or unexported fields
}

func (*Tensor) Descriptor deprecated 

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

Deprecated: Use Tensor.ProtoReflect.Descriptor instead.

func (*Tensor) GetAnnotation 

func (x *Tensor) GetAnnotation() *TensorAnnotation

func (*Tensor) GetBoolData 

func (x *Tensor) GetBoolData() []bool

func (*Tensor) GetDoubleData 

func (x *Tensor) GetDoubleData() []float64

func (*Tensor) GetElemType 

func (x *Tensor) GetElemType() PrimitiveDataType

func (*Tensor) GetFloatData 

func (x *Tensor) GetFloatData() []float32

func (*Tensor) GetInt32Data 

func (x *Tensor) GetInt32Data() []int32

func (*Tensor) GetInt64Data 

func (x *Tensor) GetInt64Data() []int64

func (*Tensor) GetName 

func (x *Tensor) GetName() string

func (*Tensor) GetOption 

func (x *Tensor) GetOption() TensorOptions

func (*Tensor) GetRefNum 

func (x *Tensor) GetRefNum() int32

func (*Tensor) GetShape 

func (x *Tensor) GetShape() *TensorShape

func (*Tensor) GetStringData 

func (x *Tensor) GetStringData() []string

func (*Tensor) ProtoMessage 

func (*Tensor) ProtoMessage()

func (*Tensor) ProtoReflect 

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

func (*Tensor) Reset 

func (x *Tensor) Reset()

func (*Tensor) String 

func (x *Tensor) String() string

type TensorAnnotation 

type TensorAnnotation struct {
	Status TensorStatus `protobuf:"varint,1,opt,name=status,proto3,enum=scql.pb.TensorStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TensorAnnotation) Descriptor deprecated 

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

Deprecated: Use TensorAnnotation.ProtoReflect.Descriptor instead.

func (*TensorAnnotation) GetStatus 

func (x *TensorAnnotation) GetStatus() TensorStatus

func (*TensorAnnotation) ProtoMessage 

func (*TensorAnnotation) ProtoMessage()

func (*TensorAnnotation) ProtoReflect 

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

func (*TensorAnnotation) Reset 

func (x *TensorAnnotation) Reset()

func (*TensorAnnotation) String 

func (x *TensorAnnotation) String() string

type TensorList 

type TensorList struct {
	Tensors []*Tensor `protobuf:"bytes,1,rep,name=tensors,proto3" json:"tensors,omitempty"`
	// contains filtered or unexported fields
}

func (*TensorList) Descriptor deprecated 

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

Deprecated: Use TensorList.ProtoReflect.Descriptor instead.

func (*TensorList) GetTensors 

func (x *TensorList) GetTensors() []*Tensor

func (*TensorList) ProtoMessage 

func (*TensorList) ProtoMessage()

func (*TensorList) ProtoReflect 

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

func (*TensorList) Reset 

func (x *TensorList) Reset()

func (*TensorList) String 

func (x *TensorList) String() string

type TensorOptions 

type TensorOptions int32
const (
	TensorOptions_VALUE     TensorOptions = 0
	TensorOptions_REFERENCE TensorOptions = 1
	TensorOptions_VARIABLE  TensorOptions = 2
)

func (TensorOptions) Descriptor 

func (TensorOptions) Descriptor() protoreflect.EnumDescriptor

func (TensorOptions) Enum 

func (x TensorOptions) Enum() *TensorOptions

func (TensorOptions) EnumDescriptor deprecated 

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

Deprecated: Use TensorOptions.Descriptor instead.

func (TensorOptions) Number 

func (x TensorOptions) Number() protoreflect.EnumNumber

func (TensorOptions) String 

func (x TensorOptions) String() string

func (TensorOptions) Type 

func (TensorOptions) Type() protoreflect.EnumType

type TensorShape 

type TensorShape struct {
	Dim []*TensorShape_Dimension `protobuf:"bytes,1,rep,name=dim,proto3" json:"dim,omitempty"`
	// contains filtered or unexported fields
}

func (*TensorShape) Descriptor deprecated 

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

Deprecated: Use TensorShape.ProtoReflect.Descriptor instead.

func (*TensorShape) GetDim 

func (x *TensorShape) GetDim() []*TensorShape_Dimension

func (*TensorShape) ProtoMessage 

func (*TensorShape) ProtoMessage()

func (*TensorShape) ProtoReflect 

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

func (*TensorShape) Reset 

func (x *TensorShape) Reset()

func (*TensorShape) String 

func (x *TensorShape) String() string

type TensorShape_Dimension 

type TensorShape_Dimension struct {

	// Types that are assignable to Value:
	//	*TensorShape_Dimension_DimValue
	//	*TensorShape_Dimension_DimParam
	Value isTensorShape_Dimension_Value `protobuf_oneof:"value"`
	// contains filtered or unexported fields
}

func (*TensorShape_Dimension) Descriptor deprecated 

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

Deprecated: Use TensorShape_Dimension.ProtoReflect.Descriptor instead.

func (*TensorShape_Dimension) GetDimParam 

func (x *TensorShape_Dimension) GetDimParam() string

func (*TensorShape_Dimension) GetDimValue 

func (x *TensorShape_Dimension) GetDimValue() int64

func (*TensorShape_Dimension) GetValue 

func (m *TensorShape_Dimension) GetValue() isTensorShape_Dimension_Value

func (*TensorShape_Dimension) ProtoMessage 

func (*TensorShape_Dimension) ProtoMessage()

func (*TensorShape_Dimension) ProtoReflect 

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

func (*TensorShape_Dimension) Reset 

func (x *TensorShape_Dimension) Reset()

func (*TensorShape_Dimension) String 

func (x *TensorShape_Dimension) String() string

type TensorShape_Dimension_DimParam 

type TensorShape_Dimension_DimParam struct {
	DimParam string `protobuf:"bytes,2,opt,name=dim_param,json=dimParam,proto3,oneof"`
}

type TensorShape_Dimension_DimValue 

type TensorShape_Dimension_DimValue struct {
	DimValue int64 `protobuf:"varint,1,opt,name=dim_value,json=dimValue,proto3,oneof"`
}

type TensorStatus 

type TensorStatus int32
const (
	TensorStatus_TENSORSTATUS_UNKNOWN TensorStatus = 0
	TensorStatus_TENSORSTATUS_PRIVATE TensorStatus = 1
	TensorStatus_TENSORSTATUS_SECRET  TensorStatus = 2
	TensorStatus_TENSORSTATUS_CIPHER  TensorStatus = 3
	TensorStatus_TENSORSTATUS_PUBLIC  TensorStatus = 4
)

func (TensorStatus) Descriptor 

func (TensorStatus) Descriptor() protoreflect.EnumDescriptor

func (TensorStatus) Enum 

func (x TensorStatus) Enum() *TensorStatus

func (TensorStatus) EnumDescriptor deprecated 

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

Deprecated: Use TensorStatus.Descriptor instead.

func (TensorStatus) Number 

func (x TensorStatus) Number() protoreflect.EnumNumber

func (TensorStatus) String 

func (x TensorStatus) String() string

func (TensorStatus) Type 

func (TensorStatus) Type() protoreflect.EnumType

type TensorStatusList 

type TensorStatusList struct {
	Status []TensorStatus `protobuf:"varint,1,rep,packed,name=status,proto3,enum=scql.pb.TensorStatus" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*TensorStatusList) Descriptor deprecated 

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

Deprecated: Use TensorStatusList.ProtoReflect.Descriptor instead.

func (*TensorStatusList) GetStatus 

func (x *TensorStatusList) GetStatus() []TensorStatus

func (*TensorStatusList) ProtoMessage 

func (*TensorStatusList) ProtoMessage()

func (*TensorStatusList) ProtoReflect 

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

func (*TensorStatusList) Reset 

func (x *TensorStatusList) Reset()

func (*TensorStatusList) String 

func (x *TensorStatusList) String() string

type UnimplementedEngineResultCallbackServer 

type UnimplementedEngineResultCallbackServer struct {
}

UnimplementedEngineResultCallbackServer can be embedded to have forward compatible implementations.

func (*UnimplementedEngineResultCallbackServer) Report 

func (*UnimplementedEngineResultCallbackServer) Report(context.Context, *ReportRequest) (*emptypb.Empty, error)

type UnimplementedInterBrokerServiceServer 

type UnimplementedInterBrokerServiceServer struct {
}

UnimplementedInterBrokerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedInterBrokerServiceServer) AskInfo 

func (*UnimplementedInterBrokerServiceServer) AskInfo(context.Context, *AskInfoRequest) (*AskInfoResponse, error)

func (*UnimplementedInterBrokerServiceServer) CancelQueryJob 

func (*UnimplementedInterBrokerServiceServer) CancelQueryJob(context.Context, *CancelQueryJobRequest) (*CancelQueryJobResponse, error)

func (*UnimplementedInterBrokerServiceServer) DistributeQuery 

func (*UnimplementedInterBrokerServiceServer) DistributeQuery(context.Context, *DistributeQueryRequest) (*DistributeQueryResponse, error)

func (*UnimplementedInterBrokerServiceServer) ExchangeJobInfo 

func (*UnimplementedInterBrokerServiceServer) ExchangeJobInfo(context.Context, *ExchangeJobInfoRequest) (*ExchangeJobInfoResponse, error)

func (*UnimplementedInterBrokerServiceServer) InviteToProject 

func (*UnimplementedInterBrokerServiceServer) InviteToProject(context.Context, *InviteToProjectRequest) (*InviteToProjectResponse, error)

func (*UnimplementedInterBrokerServiceServer) ReplyInvitation 

func (*UnimplementedInterBrokerServiceServer) ReplyInvitation(context.Context, *ReplyInvitationRequest) (*ReplyInvitationResponse, error)

func (*UnimplementedInterBrokerServiceServer) SyncInfo 

func (*UnimplementedInterBrokerServiceServer) SyncInfo(context.Context, *SyncInfoRequest) (*SyncInfoResponse, error)

type UnimplementedInterpreterServiceServer 

type UnimplementedInterpreterServiceServer struct {
}

UnimplementedInterpreterServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedInterpreterServiceServer) CompileQuery 

func (*UnimplementedInterpreterServiceServer) CompileQuery(context.Context, *CompileQueryRequest) (*CompileQueryResponse, error)

type UnimplementedIntraBrokerServiceServer 

type UnimplementedIntraBrokerServiceServer struct {
}

UnimplementedIntraBrokerServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedIntraBrokerServiceServer) ArchiveProject 

func (*UnimplementedIntraBrokerServiceServer) ArchiveProject(context.Context, *ArchiveProjectRequest) (*ArchiveProjectResponse, error)

func (*UnimplementedIntraBrokerServiceServer) CancelQuery 

func (*UnimplementedIntraBrokerServiceServer) CancelQuery(context.Context, *CancelQueryRequest) (*CancelQueryResponse, error)

func (*UnimplementedIntraBrokerServiceServer) CheckAndUpdateStatus 

func (*UnimplementedIntraBrokerServiceServer) CheckAndUpdateStatus(context.Context, *CheckAndUpdateStatusRequest) (*CheckAndUpdateStatusResponse, error)

func (*UnimplementedIntraBrokerServiceServer) CreateProject 

func (*UnimplementedIntraBrokerServiceServer) CreateProject(context.Context, *CreateProjectRequest) (*CreateProjectResponse, error)

func (*UnimplementedIntraBrokerServiceServer) CreateTable 

func (*UnimplementedIntraBrokerServiceServer) CreateTable(context.Context, *CreateTableRequest) (*CreateTableResponse, error)

func (*UnimplementedIntraBrokerServiceServer) DoQuery 

func (*UnimplementedIntraBrokerServiceServer) DoQuery(context.Context, *QueryRequest) (*QueryResponse, error)

func (*UnimplementedIntraBrokerServiceServer) DropTable 

func (*UnimplementedIntraBrokerServiceServer) DropTable(context.Context, *DropTableRequest) (*DropTableResponse, error)

func (*UnimplementedIntraBrokerServiceServer) FetchResult 

func (*UnimplementedIntraBrokerServiceServer) FetchResult(context.Context, *FetchResultRequest) (*QueryResponse, error)

func (*UnimplementedIntraBrokerServiceServer) GrantCCL 

func (*UnimplementedIntraBrokerServiceServer) GrantCCL(context.Context, *GrantCCLRequest) (*GrantCCLResponse, error)

func (*UnimplementedIntraBrokerServiceServer) InviteMember 

func (*UnimplementedIntraBrokerServiceServer) InviteMember(context.Context, *InviteMemberRequest) (*InviteMemberResponse, error)

func (*UnimplementedIntraBrokerServiceServer) ListInvitations 

func (*UnimplementedIntraBrokerServiceServer) ListInvitations(context.Context, *ListInvitationsRequest) (*ListInvitationsResponse, error)

func (*UnimplementedIntraBrokerServiceServer) ListProjects 

func (*UnimplementedIntraBrokerServiceServer) ListProjects(context.Context, *ListProjectsRequest) (*ListProjectsResponse, error)

func (*UnimplementedIntraBrokerServiceServer) ListTables 

func (*UnimplementedIntraBrokerServiceServer) ListTables(context.Context, *ListTablesRequest) (*ListTablesResponse, error)

func (*UnimplementedIntraBrokerServiceServer) ProcessInvitation 

func (*UnimplementedIntraBrokerServiceServer) ProcessInvitation(context.Context, *ProcessInvitationRequest) (*ProcessInvitationResponse, error)

func (*UnimplementedIntraBrokerServiceServer) RevokeCCL 

func (*UnimplementedIntraBrokerServiceServer) RevokeCCL(context.Context, *RevokeCCLRequest) (*RevokeCCLResponse, error)

func (*UnimplementedIntraBrokerServiceServer) ShowCCL 

func (*UnimplementedIntraBrokerServiceServer) ShowCCL(context.Context, *ShowCCLRequest) (*ShowCCLResponse, error)

func (*UnimplementedIntraBrokerServiceServer) SubmitQuery 

func (*UnimplementedIntraBrokerServiceServer) SubmitQuery(context.Context, *QueryRequest) (*SubmitResponse, error)

func (*UnimplementedIntraBrokerServiceServer) UpdateProject 

func (*UnimplementedIntraBrokerServiceServer) UpdateProject(context.Context, *UpdateProjectRequest) (*UpdateProjectResponse, error)

type UnimplementedSCDBQueryResultCallbackServer 

type UnimplementedSCDBQueryResultCallbackServer struct {
}

UnimplementedSCDBQueryResultCallbackServer can be embedded to have forward compatible implementations.

func (*UnimplementedSCDBQueryResultCallbackServer) ReportQueryResult 

func (*UnimplementedSCDBQueryResultCallbackServer) ReportQueryResult(context.Context, *SCDBQueryResultResponse) (*emptypb.Empty, error)

type UnimplementedSCDBServiceServer 

type UnimplementedSCDBServiceServer struct {
}

UnimplementedSCDBServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSCDBServiceServer) Fetch 

func (*UnimplementedSCDBServiceServer) Fetch(context.Context, *SCDBFetchRequest) (*SCDBQueryResultResponse, error)

func (*UnimplementedSCDBServiceServer) Submit 

func (*UnimplementedSCDBServiceServer) Submit(context.Context, *SCDBQueryRequest) (*SCDBSubmitResponse, error)

func (*UnimplementedSCDBServiceServer) SubmitAndGet 

func (*UnimplementedSCDBServiceServer) SubmitAndGet(context.Context, *SCDBQueryRequest) (*SCDBQueryResultResponse, error)

type UnimplementedSCQLEngineServiceServer 

type UnimplementedSCQLEngineServiceServer struct {
}

UnimplementedSCQLEngineServiceServer can be embedded to have forward compatible implementations.

func (*UnimplementedSCQLEngineServiceServer) RunExecutionPlan 

func (*UnimplementedSCQLEngineServiceServer) RunExecutionPlan(context.Context, *RunExecutionPlanRequest) (*RunExecutionPlanResponse, error)

func (*UnimplementedSCQLEngineServiceServer) StopSession 

func (*UnimplementedSCQLEngineServiceServer) StopSession(context.Context, *StopSessionRequest) (*Status, error)

type UpdateProjectRequest 

type UpdateProjectRequest struct {
	ProjectId string         `protobuf:"bytes,1,opt,name=project_id,json=projectId,proto3" json:"project_id,omitempty"`
	Conf      *ProjectConfig `protobuf:"bytes,2,opt,name=conf,proto3" json:"conf,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateProjectRequest) Descriptor deprecated 

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

Deprecated: Use UpdateProjectRequest.ProtoReflect.Descriptor instead.

func (*UpdateProjectRequest) GetConf 

func (x *UpdateProjectRequest) GetConf() *ProjectConfig

func (*UpdateProjectRequest) GetProjectId 

func (x *UpdateProjectRequest) GetProjectId() string

func (*UpdateProjectRequest) ProtoMessage 

func (*UpdateProjectRequest) ProtoMessage()

func (*UpdateProjectRequest) ProtoReflect 

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

func (*UpdateProjectRequest) Reset 

func (x *UpdateProjectRequest) Reset()

func (*UpdateProjectRequest) String 

func (x *UpdateProjectRequest) String() string

type UpdateProjectResponse 

type UpdateProjectResponse struct {
	Status *Status `protobuf:"bytes,1,opt,name=status,proto3" json:"status,omitempty"`
	// contains filtered or unexported fields
}

func (*UpdateProjectResponse) Descriptor deprecated 

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

Deprecated: Use UpdateProjectResponse.ProtoReflect.Descriptor instead.

func (*UpdateProjectResponse) GetStatus 

func (x *UpdateProjectResponse) GetStatus() *Status

func (*UpdateProjectResponse) ProtoMessage 

func (*UpdateProjectResponse) ProtoMessage()

func (*UpdateProjectResponse) ProtoReflect 

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

func (*UpdateProjectResponse) Reset 

func (x *UpdateProjectResponse) Reset()

func (*UpdateProjectResponse) String 

func (x *UpdateProjectResponse) String() string

type User 

type User struct {
	AccountSystemType User_AccountSystemType `` /* 151-byte string literal not displayed */
	// Types that are assignable to User:
	//	*User_NativeUser_
	User isUser_User `protobuf_oneof:"user"`
	// contains filtered or unexported fields
}

func (*User) Descriptor deprecated 

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

Deprecated: Use User.ProtoReflect.Descriptor instead.

func (*User) GetAccountSystemType 

func (x *User) GetAccountSystemType() User_AccountSystemType

func (*User) GetNativeUser 

func (x *User) GetNativeUser() *User_NativeUser

func (*User) GetUser 

func (m *User) GetUser() isUser_User

func (*User) ProtoMessage 

func (*User) ProtoMessage()

func (*User) ProtoReflect 

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

func (*User) Reset 

func (x *User) Reset()

func (*User) String 

func (x *User) String() string

type User_AccountSystemType 

type User_AccountSystemType int32
const (
	User_UNKNOWN     User_AccountSystemType = 0
	User_NATIVE_USER User_AccountSystemType = 1
)

func (User_AccountSystemType) Descriptor 

func (User_AccountSystemType) Descriptor() protoreflect.EnumDescriptor

func (User_AccountSystemType) Enum 

func (x User_AccountSystemType) Enum() *User_AccountSystemType

func (User_AccountSystemType) EnumDescriptor deprecated 

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

Deprecated: Use User_AccountSystemType.Descriptor instead.

func (User_AccountSystemType) Number 

func (x User_AccountSystemType) Number() protoreflect.EnumNumber

func (User_AccountSystemType) String 

func (x User_AccountSystemType) String() string

func (User_AccountSystemType) Type 

func (User_AccountSystemType) Type() protoreflect.EnumType

type User_NativeUser 

type User_NativeUser struct {
	Name     string `protobuf:"bytes,1,opt,name=name,proto3" json:"name,omitempty"`
	Password string `protobuf:"bytes,2,opt,name=password,proto3" json:"password,omitempty"`
	// contains filtered or unexported fields
}

func (*User_NativeUser) Descriptor deprecated 

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

Deprecated: Use User_NativeUser.ProtoReflect.Descriptor instead.

func (*User_NativeUser) GetName 

func (x *User_NativeUser) GetName() string

func (*User_NativeUser) GetPassword 

func (x *User_NativeUser) GetPassword() string

func (*User_NativeUser) ProtoMessage 

func (*User_NativeUser) ProtoMessage()

func (*User_NativeUser) ProtoReflect 

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

func (*User_NativeUser) Reset 

func (x *User_NativeUser) Reset()

func (*User_NativeUser) String 

func (x *User_NativeUser) String() string

type User_NativeUser_ 

type User_NativeUser_ struct {
	NativeUser *User_NativeUser `protobuf:"bytes,2,opt,name=native_user,json=nativeUser,proto3,oneof"`
}

type Warning 

type Warning struct {
	MayAffectedByGroupThreshold bool `` /* 149-byte string literal not displayed */
	// contains filtered or unexported fields
}

func (*Warning) Descriptor deprecated 

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

Deprecated: Use Warning.ProtoReflect.Descriptor instead.

func (*Warning) GetMayAffectedByGroupThreshold 

func (x *Warning) GetMayAffectedByGroupThreshold() bool

func (*Warning) ProtoMessage 

func (*Warning) ProtoMessage()

func (*Warning) ProtoReflect 

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

func (*Warning) Reset 

func (x *Warning) Reset()

func (*Warning) String 

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