proto

package
v1.8.2 Latest Latest
Warning

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

 Go to latest Published: May 10, 2023 License: AGPL-3.0 Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Databricks_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Databricks",
	HandlerType: (*DatabricksServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "Connect",
			Handler:    _Databricks_Connect_Handler,
		},
		{
			MethodName: "Execute",
			Handler:    _Databricks_Execute_Handler,
		},
		{
			MethodName: "ExecuteQuery",
			Handler:    _Databricks_ExecuteQuery_Handler,
		},
		{
			MethodName: "FetchSchemas",
			Handler:    _Databricks_FetchSchemas_Handler,
		},
		{
			MethodName: "FetchTables",
			Handler:    _Databricks_FetchTables_Handler,
		},
		{
			MethodName: "FetchTableAttributes",
			Handler:    _Databricks_FetchTableAttributes_Handler,
		},
		{
			MethodName: "FetchTotalCountInTable",
			Handler:    _Databricks_FetchTotalCountInTable_Handler,
		},
		{
			MethodName: "FetchPartitionColumns",
			Handler:    _Databricks_FetchPartitionColumns_Handler,
		},
		{
			MethodName: "Close",
			Handler:    _Databricks_Close_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/databricks/databricks.proto",
}

Databricks_ServiceDesc is the grpc.ServiceDesc for Databricks service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

View Source 
var File_proto_databricks_databricks_proto protoreflect.FileDescriptor
View Source 
var File_proto_databricks_version_proto protoreflect.FileDescriptor
View Source 
var Version_ServiceDesc = grpc.ServiceDesc{
	ServiceName: "proto.Version",
	HandlerType: (*VersionServer)(nil),
	Methods: []grpc.MethodDesc{
		{
			MethodName: "GetVersion",
			Handler:    _Version_GetVersion_Handler,
		},
	},
	Streams:  []grpc.StreamDesc{},
	Metadata: "proto/databricks/version.proto",
}

Version_ServiceDesc is the grpc.ServiceDesc for Version service. It's only intended for direct use with grpc.RegisterService, and not to be introspected or modified (even as a copy)

Functions

func RegisterDatabricksServer 

func RegisterDatabricksServer(s grpc.ServiceRegistrar, srv DatabricksServer)

func RegisterVersionServer 

func RegisterVersionServer(s grpc.ServiceRegistrar, srv VersionServer)

Types

type CloseRequest 

type CloseRequest struct {
	Config     *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Identifier string            `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseRequest) Descriptor deprecated 

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

Deprecated: Use CloseRequest.ProtoReflect.Descriptor instead.

func (*CloseRequest) GetConfig 

func (x *CloseRequest) GetConfig() *ConnectionConfig

func (*CloseRequest) GetIdentifier 

func (x *CloseRequest) GetIdentifier() string

func (*CloseRequest) ProtoMessage 

func (*CloseRequest) ProtoMessage()

func (*CloseRequest) ProtoReflect 

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

func (*CloseRequest) Reset 

func (x *CloseRequest) Reset()

func (*CloseRequest) String 

func (x *CloseRequest) String() string

type CloseResponse 

type CloseResponse struct {
	ErrorCode    string `protobuf:"bytes,1,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*CloseResponse) Descriptor deprecated 

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

Deprecated: Use CloseResponse.ProtoReflect.Descriptor instead.

func (*CloseResponse) GetErrorCode 

func (x *CloseResponse) GetErrorCode() string

func (*CloseResponse) GetErrorMessage 

func (x *CloseResponse) GetErrorMessage() string

func (*CloseResponse) ProtoMessage 

func (*CloseResponse) ProtoMessage()

func (*CloseResponse) ProtoReflect 

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

func (*CloseResponse) Reset 

func (x *CloseResponse) Reset()

func (*CloseResponse) String 

func (x *CloseResponse) String() string

type ConnectRequest 

type ConnectRequest struct {
	Config     *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Identifier string            `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectRequest) Descriptor deprecated 

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

Deprecated: Use ConnectRequest.ProtoReflect.Descriptor instead.

func (*ConnectRequest) GetConfig 

func (x *ConnectRequest) GetConfig() *ConnectionConfig

func (*ConnectRequest) GetIdentifier 

func (x *ConnectRequest) GetIdentifier() string

func (*ConnectRequest) ProtoMessage 

func (*ConnectRequest) ProtoMessage()

func (*ConnectRequest) ProtoReflect 

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

func (*ConnectRequest) Reset 

func (x *ConnectRequest) Reset()

func (*ConnectRequest) String 

func (x *ConnectRequest) String() string

type ConnectResponse 

type ConnectResponse struct {
	ErrorCode    string `protobuf:"bytes,1,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectResponse) Descriptor deprecated 

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

Deprecated: Use ConnectResponse.ProtoReflect.Descriptor instead.

func (*ConnectResponse) GetErrorCode 

func (x *ConnectResponse) GetErrorCode() string

func (*ConnectResponse) GetErrorMessage 

func (x *ConnectResponse) GetErrorMessage() string

func (*ConnectResponse) ProtoMessage 

func (*ConnectResponse) ProtoMessage()

func (*ConnectResponse) ProtoReflect 

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

func (*ConnectResponse) Reset 

func (x *ConnectResponse) Reset()

func (*ConnectResponse) String 

func (x *ConnectResponse) String() string

type ConnectionConfig 

type ConnectionConfig struct {
	Host            string `protobuf:"bytes,1,opt,name=host,proto3" json:"host,omitempty"`
	Port            string `protobuf:"bytes,2,opt,name=port,proto3" json:"port,omitempty"`
	Schema          string `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	SparkServerType string `protobuf:"bytes,4,opt,name=sparkServerType,proto3" json:"sparkServerType,omitempty"`
	AuthMech        string `protobuf:"bytes,5,opt,name=authMech,proto3" json:"authMech,omitempty"`
	Uid             string `protobuf:"bytes,6,opt,name=uid,proto3" json:"uid,omitempty"`
	Pwd             string `protobuf:"bytes,7,opt,name=pwd,proto3" json:"pwd,omitempty"`
	ThriftTransport string `protobuf:"bytes,8,opt,name=thriftTransport,proto3" json:"thriftTransport,omitempty"`
	Ssl             string `protobuf:"bytes,9,opt,name=ssl,proto3" json:"ssl,omitempty"`
	HttpPath        string `protobuf:"bytes,10,opt,name=httpPath,proto3" json:"httpPath,omitempty"`
	UserAgentEntry  string `protobuf:"bytes,11,opt,name=userAgentEntry,proto3" json:"userAgentEntry,omitempty"`
	// contains filtered or unexported fields
}

func (*ConnectionConfig) Descriptor deprecated 

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

Deprecated: Use ConnectionConfig.ProtoReflect.Descriptor instead.

func (*ConnectionConfig) GetAuthMech 

func (x *ConnectionConfig) GetAuthMech() string

func (*ConnectionConfig) GetHost 

func (x *ConnectionConfig) GetHost() string

func (*ConnectionConfig) GetHttpPath 

func (x *ConnectionConfig) GetHttpPath() string

func (*ConnectionConfig) GetPort 

func (x *ConnectionConfig) GetPort() string

func (*ConnectionConfig) GetPwd 

func (x *ConnectionConfig) GetPwd() string

func (*ConnectionConfig) GetSchema 

func (x *ConnectionConfig) GetSchema() string

func (*ConnectionConfig) GetSparkServerType 

func (x *ConnectionConfig) GetSparkServerType() string

func (*ConnectionConfig) GetSsl 

func (x *ConnectionConfig) GetSsl() string

func (*ConnectionConfig) GetThriftTransport 

func (x *ConnectionConfig) GetThriftTransport() string

func (*ConnectionConfig) GetUid 

func (x *ConnectionConfig) GetUid() string

func (*ConnectionConfig) GetUserAgentEntry 

func (x *ConnectionConfig) GetUserAgentEntry() string

func (*ConnectionConfig) ProtoMessage 

func (*ConnectionConfig) ProtoMessage()

func (*ConnectionConfig) ProtoReflect 

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

func (*ConnectionConfig) Reset 

func (x *ConnectionConfig) Reset()

func (*ConnectionConfig) String 

func (x *ConnectionConfig) String() string

type DatabricksClient 

type DatabricksClient interface {
	Connect(ctx context.Context, in *ConnectRequest, opts ...grpc.CallOption) (*ConnectResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
	ExecuteQuery(ctx context.Context, in *ExecuteQueryRequest, opts ...grpc.CallOption) (*ExecuteQueryResponse, error)
	FetchSchemas(ctx context.Context, in *FetchSchemasRequest, opts ...grpc.CallOption) (*FetchSchemasResponse, error)
	FetchTables(ctx context.Context, in *FetchTablesRequest, opts ...grpc.CallOption) (*FetchTablesResponse, error)
	FetchTableAttributes(ctx context.Context, in *FetchTableAttributesRequest, opts ...grpc.CallOption) (*FetchTableAttributesResponse, error)
	FetchTotalCountInTable(ctx context.Context, in *FetchTotalCountInTableRequest, opts ...grpc.CallOption) (*FetchTotalCountInTableResponse, error)
	FetchPartitionColumns(ctx context.Context, in *FetchPartitionColumnsRequest, opts ...grpc.CallOption) (*FetchPartitionColumnsResponse, error)
	Close(ctx context.Context, in *CloseRequest, opts ...grpc.CallOption) (*CloseResponse, error)
}

DatabricksClient is the client API for Databricks service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewDatabricksClient 

func NewDatabricksClient(cc grpc.ClientConnInterface) DatabricksClient

type DatabricksServer 

type DatabricksServer interface {
	Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	ExecuteQuery(context.Context, *ExecuteQueryRequest) (*ExecuteQueryResponse, error)
	FetchSchemas(context.Context, *FetchSchemasRequest) (*FetchSchemasResponse, error)
	FetchTables(context.Context, *FetchTablesRequest) (*FetchTablesResponse, error)
	FetchTableAttributes(context.Context, *FetchTableAttributesRequest) (*FetchTableAttributesResponse, error)
	FetchTotalCountInTable(context.Context, *FetchTotalCountInTableRequest) (*FetchTotalCountInTableResponse, error)
	FetchPartitionColumns(context.Context, *FetchPartitionColumnsRequest) (*FetchPartitionColumnsResponse, error)
	Close(context.Context, *CloseRequest) (*CloseResponse, error)
	// contains filtered or unexported methods
}

DatabricksServer is the server API for Databricks service. All implementations must embed UnimplementedDatabricksServer for forward compatibility

type ExecuteQueryRequest 

type ExecuteQueryRequest struct {
	Config       *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Identifier   string            `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	SqlStatement string            `protobuf:"bytes,3,opt,name=sqlStatement,proto3" json:"sqlStatement,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteQueryRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteQueryRequest.ProtoReflect.Descriptor instead.

func (*ExecuteQueryRequest) GetConfig 

func (x *ExecuteQueryRequest) GetConfig() *ConnectionConfig

func (*ExecuteQueryRequest) GetIdentifier 

func (x *ExecuteQueryRequest) GetIdentifier() string

func (*ExecuteQueryRequest) GetSqlStatement 

func (x *ExecuteQueryRequest) GetSqlStatement() string

func (*ExecuteQueryRequest) ProtoMessage 

func (*ExecuteQueryRequest) ProtoMessage()

func (*ExecuteQueryRequest) ProtoReflect 

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

func (*ExecuteQueryRequest) Reset 

func (x *ExecuteQueryRequest) Reset()

func (*ExecuteQueryRequest) String 

func (x *ExecuteQueryRequest) String() string

type ExecuteQueryResponse 

type ExecuteQueryResponse struct {
	Rows         []*ItemQueryColumns `protobuf:"bytes,1,rep,name=rows,proto3" json:"rows,omitempty"`
	ErrorCode    string              `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorMessage string              `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteQueryResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteQueryResponse.ProtoReflect.Descriptor instead.

func (*ExecuteQueryResponse) GetErrorCode 

func (x *ExecuteQueryResponse) GetErrorCode() string

func (*ExecuteQueryResponse) GetErrorMessage 

func (x *ExecuteQueryResponse) GetErrorMessage() string

func (*ExecuteQueryResponse) GetRows 

func (x *ExecuteQueryResponse) GetRows() []*ItemQueryColumns

func (*ExecuteQueryResponse) ProtoMessage 

func (*ExecuteQueryResponse) ProtoMessage()

func (*ExecuteQueryResponse) ProtoReflect 

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

func (*ExecuteQueryResponse) Reset 

func (x *ExecuteQueryResponse) Reset()

func (*ExecuteQueryResponse) String 

func (x *ExecuteQueryResponse) String() string

type ExecuteRequest 

type ExecuteRequest struct {
	Config       *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Identifier   string            `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	SqlStatement string            `protobuf:"bytes,3,opt,name=sqlStatement,proto3" json:"sqlStatement,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteRequest) Descriptor deprecated 

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

Deprecated: Use ExecuteRequest.ProtoReflect.Descriptor instead.

func (*ExecuteRequest) GetConfig 

func (x *ExecuteRequest) GetConfig() *ConnectionConfig

func (*ExecuteRequest) GetIdentifier 

func (x *ExecuteRequest) GetIdentifier() string

func (*ExecuteRequest) GetSqlStatement 

func (x *ExecuteRequest) GetSqlStatement() string

func (*ExecuteRequest) ProtoMessage 

func (*ExecuteRequest) ProtoMessage()

func (*ExecuteRequest) ProtoReflect 

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

func (*ExecuteRequest) Reset 

func (x *ExecuteRequest) Reset()

func (*ExecuteRequest) String 

func (x *ExecuteRequest) String() string

type ExecuteResponse 

type ExecuteResponse struct {
	ErrorCode    string `protobuf:"bytes,1,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorMessage string `protobuf:"bytes,2,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*ExecuteResponse) Descriptor deprecated 

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

Deprecated: Use ExecuteResponse.ProtoReflect.Descriptor instead.

func (*ExecuteResponse) GetErrorCode 

func (x *ExecuteResponse) GetErrorCode() string

func (*ExecuteResponse) GetErrorMessage 

func (x *ExecuteResponse) GetErrorMessage() string

func (*ExecuteResponse) ProtoMessage 

func (*ExecuteResponse) ProtoMessage()

func (*ExecuteResponse) ProtoReflect 

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

func (*ExecuteResponse) Reset 

func (x *ExecuteResponse) Reset()

func (*ExecuteResponse) String 

func (x *ExecuteResponse) String() string

type FetchPartitionColumnsRequest added in v1.0.2 

type FetchPartitionColumnsRequest struct {
	Config       *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Identifier   string            `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	SqlStatement string            `protobuf:"bytes,3,opt,name=sqlStatement,proto3" json:"sqlStatement,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchPartitionColumnsRequest) Descriptor deprecated added in v1.0.2 

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

Deprecated: Use FetchPartitionColumnsRequest.ProtoReflect.Descriptor instead.

func (*FetchPartitionColumnsRequest) GetConfig added in v1.0.2 

func (x *FetchPartitionColumnsRequest) GetConfig() *ConnectionConfig

func (*FetchPartitionColumnsRequest) GetIdentifier added in v1.0.2 

func (x *FetchPartitionColumnsRequest) GetIdentifier() string

func (*FetchPartitionColumnsRequest) GetSqlStatement added in v1.0.2 

func (x *FetchPartitionColumnsRequest) GetSqlStatement() string

func (*FetchPartitionColumnsRequest) ProtoMessage added in v1.0.2 

func (*FetchPartitionColumnsRequest) ProtoMessage()

func (*FetchPartitionColumnsRequest) ProtoReflect added in v1.0.2 

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

func (*FetchPartitionColumnsRequest) Reset added in v1.0.2 

func (x *FetchPartitionColumnsRequest) Reset()

func (*FetchPartitionColumnsRequest) String added in v1.0.2 

func (x *FetchPartitionColumnsRequest) String() string

type FetchPartitionColumnsResponse added in v1.0.2 

type FetchPartitionColumnsResponse struct {
	Columns      []string `protobuf:"bytes,1,rep,name=columns,proto3" json:"columns,omitempty"`
	ErrorCode    string   `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorMessage string   `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchPartitionColumnsResponse) Descriptor deprecated added in v1.0.2 

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

Deprecated: Use FetchPartitionColumnsResponse.ProtoReflect.Descriptor instead.

func (*FetchPartitionColumnsResponse) GetColumns added in v1.0.2 

func (x *FetchPartitionColumnsResponse) GetColumns() []string

func (*FetchPartitionColumnsResponse) GetErrorCode added in v1.0.2 

func (x *FetchPartitionColumnsResponse) GetErrorCode() string

func (*FetchPartitionColumnsResponse) GetErrorMessage added in v1.0.2 

func (x *FetchPartitionColumnsResponse) GetErrorMessage() string

func (*FetchPartitionColumnsResponse) ProtoMessage added in v1.0.2 

func (*FetchPartitionColumnsResponse) ProtoMessage()

func (*FetchPartitionColumnsResponse) ProtoReflect added in v1.0.2 

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

func (*FetchPartitionColumnsResponse) Reset added in v1.0.2 

func (x *FetchPartitionColumnsResponse) Reset()

func (*FetchPartitionColumnsResponse) String added in v1.0.2 

func (x *FetchPartitionColumnsResponse) String() string

type FetchSchemasRequest 

type FetchSchemasRequest struct {
	Config       *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Identifier   string            `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	SqlStatement string            `protobuf:"bytes,3,opt,name=sqlStatement,proto3" json:"sqlStatement,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchSchemasRequest) Descriptor deprecated 

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

Deprecated: Use FetchSchemasRequest.ProtoReflect.Descriptor instead.

func (*FetchSchemasRequest) GetConfig 

func (x *FetchSchemasRequest) GetConfig() *ConnectionConfig

func (*FetchSchemasRequest) GetIdentifier 

func (x *FetchSchemasRequest) GetIdentifier() string

func (*FetchSchemasRequest) GetSqlStatement 

func (x *FetchSchemasRequest) GetSqlStatement() string

func (*FetchSchemasRequest) ProtoMessage 

func (*FetchSchemasRequest) ProtoMessage()

func (*FetchSchemasRequest) ProtoReflect 

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

func (*FetchSchemasRequest) Reset 

func (x *FetchSchemasRequest) Reset()

func (*FetchSchemasRequest) String 

func (x *FetchSchemasRequest) String() string

type FetchSchemasResponse 

type FetchSchemasResponse struct {
	Databases    []string `protobuf:"bytes,1,rep,name=databases,proto3" json:"databases,omitempty"`
	ErrorCode    string   `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorMessage string   `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchSchemasResponse) Descriptor deprecated 

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

Deprecated: Use FetchSchemasResponse.ProtoReflect.Descriptor instead.

func (*FetchSchemasResponse) GetDatabases 

func (x *FetchSchemasResponse) GetDatabases() []string

func (*FetchSchemasResponse) GetErrorCode 

func (x *FetchSchemasResponse) GetErrorCode() string

func (*FetchSchemasResponse) GetErrorMessage 

func (x *FetchSchemasResponse) GetErrorMessage() string

func (*FetchSchemasResponse) ProtoMessage 

func (*FetchSchemasResponse) ProtoMessage()

func (*FetchSchemasResponse) ProtoReflect 

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

func (*FetchSchemasResponse) Reset 

func (x *FetchSchemasResponse) Reset()

func (*FetchSchemasResponse) String 

func (x *FetchSchemasResponse) String() string

type FetchTableAttributesRequest 

type FetchTableAttributesRequest struct {
	Config     *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Identifier string            `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Schema     string            `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	Table      string            `protobuf:"bytes,4,opt,name=table,proto3" json:"table,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchTableAttributesRequest) Descriptor deprecated 

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

Deprecated: Use FetchTableAttributesRequest.ProtoReflect.Descriptor instead.

func (*FetchTableAttributesRequest) GetConfig 

func (x *FetchTableAttributesRequest) GetConfig() *ConnectionConfig

func (*FetchTableAttributesRequest) GetIdentifier 

func (x *FetchTableAttributesRequest) GetIdentifier() string

func (*FetchTableAttributesRequest) GetSchema 

func (x *FetchTableAttributesRequest) GetSchema() string

func (*FetchTableAttributesRequest) GetTable 

func (x *FetchTableAttributesRequest) GetTable() string

func (*FetchTableAttributesRequest) ProtoMessage 

func (*FetchTableAttributesRequest) ProtoMessage()

func (*FetchTableAttributesRequest) ProtoReflect 

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

func (*FetchTableAttributesRequest) Reset 

func (x *FetchTableAttributesRequest) Reset()

func (*FetchTableAttributesRequest) String 

func (x *FetchTableAttributesRequest) String() string

type FetchTableAttributesResponse 

type FetchTableAttributesResponse struct {
	Attributes   []*ItemAttribute `protobuf:"bytes,1,rep,name=attributes,proto3" json:"attributes,omitempty"`
	ErrorCode    string           `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorMessage string           `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchTableAttributesResponse) Descriptor deprecated 

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

Deprecated: Use FetchTableAttributesResponse.ProtoReflect.Descriptor instead.

func (*FetchTableAttributesResponse) GetAttributes 

func (x *FetchTableAttributesResponse) GetAttributes() []*ItemAttribute

func (*FetchTableAttributesResponse) GetErrorCode 

func (x *FetchTableAttributesResponse) GetErrorCode() string

func (*FetchTableAttributesResponse) GetErrorMessage 

func (x *FetchTableAttributesResponse) GetErrorMessage() string

func (*FetchTableAttributesResponse) ProtoMessage 

func (*FetchTableAttributesResponse) ProtoMessage()

func (*FetchTableAttributesResponse) ProtoReflect 

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

func (*FetchTableAttributesResponse) Reset 

func (x *FetchTableAttributesResponse) Reset()

func (*FetchTableAttributesResponse) String 

func (x *FetchTableAttributesResponse) String() string

type FetchTablesRequest 

type FetchTablesRequest struct {
	Config     *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Identifier string            `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	Schema     string            `protobuf:"bytes,3,opt,name=schema,proto3" json:"schema,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchTablesRequest) Descriptor deprecated 

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

Deprecated: Use FetchTablesRequest.ProtoReflect.Descriptor instead.

func (*FetchTablesRequest) GetConfig 

func (x *FetchTablesRequest) GetConfig() *ConnectionConfig

func (*FetchTablesRequest) GetIdentifier 

func (x *FetchTablesRequest) GetIdentifier() string

func (*FetchTablesRequest) GetSchema 

func (x *FetchTablesRequest) GetSchema() string

func (*FetchTablesRequest) ProtoMessage 

func (*FetchTablesRequest) ProtoMessage()

func (*FetchTablesRequest) ProtoReflect 

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

func (*FetchTablesRequest) Reset 

func (x *FetchTablesRequest) Reset()

func (*FetchTablesRequest) String 

func (x *FetchTablesRequest) String() string

type FetchTablesResponse 

type FetchTablesResponse struct {
	Tables       []string `protobuf:"bytes,1,rep,name=tables,proto3" json:"tables,omitempty"`
	ErrorCode    string   `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorMessage string   `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchTablesResponse) Descriptor deprecated 

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

Deprecated: Use FetchTablesResponse.ProtoReflect.Descriptor instead.

func (*FetchTablesResponse) GetErrorCode 

func (x *FetchTablesResponse) GetErrorCode() string

func (*FetchTablesResponse) GetErrorMessage 

func (x *FetchTablesResponse) GetErrorMessage() string

func (*FetchTablesResponse) GetTables 

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

func (*FetchTablesResponse) ProtoMessage 

func (*FetchTablesResponse) ProtoMessage()

func (*FetchTablesResponse) ProtoReflect 

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

func (*FetchTablesResponse) Reset 

func (x *FetchTablesResponse) Reset()

func (*FetchTablesResponse) String 

func (x *FetchTablesResponse) String() string

type FetchTotalCountInTableRequest 

type FetchTotalCountInTableRequest struct {
	Config       *ConnectionConfig `protobuf:"bytes,1,opt,name=config,proto3" json:"config,omitempty"`
	Identifier   string            `protobuf:"bytes,2,opt,name=identifier,proto3" json:"identifier,omitempty"`
	SqlStatement string            `protobuf:"bytes,3,opt,name=sqlStatement,proto3" json:"sqlStatement,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchTotalCountInTableRequest) Descriptor deprecated 

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

Deprecated: Use FetchTotalCountInTableRequest.ProtoReflect.Descriptor instead.

func (*FetchTotalCountInTableRequest) GetConfig 

func (x *FetchTotalCountInTableRequest) GetConfig() *ConnectionConfig

func (*FetchTotalCountInTableRequest) GetIdentifier 

func (x *FetchTotalCountInTableRequest) GetIdentifier() string

func (*FetchTotalCountInTableRequest) GetSqlStatement 

func (x *FetchTotalCountInTableRequest) GetSqlStatement() string

func (*FetchTotalCountInTableRequest) ProtoMessage 

func (*FetchTotalCountInTableRequest) ProtoMessage()

func (*FetchTotalCountInTableRequest) ProtoReflect 

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

func (*FetchTotalCountInTableRequest) Reset 

func (x *FetchTotalCountInTableRequest) Reset()

func (*FetchTotalCountInTableRequest) String 

func (x *FetchTotalCountInTableRequest) String() string

type FetchTotalCountInTableResponse 

type FetchTotalCountInTableResponse struct {
	Count        int64  `protobuf:"varint,1,opt,name=count,proto3" json:"count,omitempty"`
	ErrorCode    string `protobuf:"bytes,2,opt,name=errorCode,proto3" json:"errorCode,omitempty"`
	ErrorMessage string `protobuf:"bytes,3,opt,name=errorMessage,proto3" json:"errorMessage,omitempty"`
	// contains filtered or unexported fields
}

func (*FetchTotalCountInTableResponse) Descriptor deprecated 

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

Deprecated: Use FetchTotalCountInTableResponse.ProtoReflect.Descriptor instead.

func (*FetchTotalCountInTableResponse) GetCount 

func (x *FetchTotalCountInTableResponse) GetCount() int64

func (*FetchTotalCountInTableResponse) GetErrorCode 

func (x *FetchTotalCountInTableResponse) GetErrorCode() string

func (*FetchTotalCountInTableResponse) GetErrorMessage 

func (x *FetchTotalCountInTableResponse) GetErrorMessage() string

func (*FetchTotalCountInTableResponse) ProtoMessage 

func (*FetchTotalCountInTableResponse) ProtoMessage()

func (*FetchTotalCountInTableResponse) ProtoReflect 

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

func (*FetchTotalCountInTableResponse) Reset 

func (x *FetchTotalCountInTableResponse) Reset()

func (*FetchTotalCountInTableResponse) String 

func (x *FetchTotalCountInTableResponse) String() string

type ItemAttribute 

type ItemAttribute struct {
	ColName  string `protobuf:"bytes,1,opt,name=colName,proto3" json:"colName,omitempty"`
	DataType string `protobuf:"bytes,2,opt,name=dataType,proto3" json:"dataType,omitempty"`
	// contains filtered or unexported fields
}

func (*ItemAttribute) Descriptor deprecated 

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

Deprecated: Use ItemAttribute.ProtoReflect.Descriptor instead.

func (*ItemAttribute) GetColName 

func (x *ItemAttribute) GetColName() string

func (*ItemAttribute) GetDataType 

func (x *ItemAttribute) GetDataType() string

func (*ItemAttribute) ProtoMessage 

func (*ItemAttribute) ProtoMessage()

func (*ItemAttribute) ProtoReflect 

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

func (*ItemAttribute) Reset 

func (x *ItemAttribute) Reset()

func (*ItemAttribute) String 

func (x *ItemAttribute) String() string

type ItemQueryColumns 

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

func (*ItemQueryColumns) Descriptor deprecated 

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

Deprecated: Use ItemQueryColumns.ProtoReflect.Descriptor instead.

func (*ItemQueryColumns) GetColumns 

func (x *ItemQueryColumns) GetColumns() []string

func (*ItemQueryColumns) ProtoMessage 

func (*ItemQueryColumns) ProtoMessage()

func (*ItemQueryColumns) ProtoReflect 

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

func (*ItemQueryColumns) Reset 

func (x *ItemQueryColumns) Reset()

func (*ItemQueryColumns) String 

func (x *ItemQueryColumns) String() string

type UnimplementedDatabricksServer 

type UnimplementedDatabricksServer struct {
}

UnimplementedDatabricksServer must be embedded to have forward compatible implementations.

func (UnimplementedDatabricksServer) Close 

func (UnimplementedDatabricksServer) Close(context.Context, *CloseRequest) (*CloseResponse, error)

func (UnimplementedDatabricksServer) Connect 

func (UnimplementedDatabricksServer) Connect(context.Context, *ConnectRequest) (*ConnectResponse, error)

func (UnimplementedDatabricksServer) Execute 

func (UnimplementedDatabricksServer) Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)

func (UnimplementedDatabricksServer) ExecuteQuery 

func (UnimplementedDatabricksServer) ExecuteQuery(context.Context, *ExecuteQueryRequest) (*ExecuteQueryResponse, error)

func (UnimplementedDatabricksServer) FetchPartitionColumns added in v1.0.2 

func (UnimplementedDatabricksServer) FetchPartitionColumns(context.Context, *FetchPartitionColumnsRequest) (*FetchPartitionColumnsResponse, error)

func (UnimplementedDatabricksServer) FetchSchemas 

func (UnimplementedDatabricksServer) FetchSchemas(context.Context, *FetchSchemasRequest) (*FetchSchemasResponse, error)

func (UnimplementedDatabricksServer) FetchTableAttributes 

func (UnimplementedDatabricksServer) FetchTableAttributes(context.Context, *FetchTableAttributesRequest) (*FetchTableAttributesResponse, error)

func (UnimplementedDatabricksServer) FetchTables 

func (UnimplementedDatabricksServer) FetchTables(context.Context, *FetchTablesRequest) (*FetchTablesResponse, error)

func (UnimplementedDatabricksServer) FetchTotalCountInTable 

func (UnimplementedDatabricksServer) FetchTotalCountInTable(context.Context, *FetchTotalCountInTableRequest) (*FetchTotalCountInTableResponse, error)

type UnimplementedVersionServer 

type UnimplementedVersionServer struct {
}

UnimplementedVersionServer must be embedded to have forward compatible implementations.

func (UnimplementedVersionServer) GetVersion 

func (UnimplementedVersionServer) GetVersion(context.Context, *VersionRequest) (*VersionResponse, error)

type UnsafeDatabricksServer 

type UnsafeDatabricksServer interface {
	// contains filtered or unexported methods
}

UnsafeDatabricksServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to DatabricksServer will result in compilation errors.

type UnsafeVersionServer 

type UnsafeVersionServer interface {
	// contains filtered or unexported methods
}

UnsafeVersionServer may be embedded to opt out of forward compatibility for this service. Use of this interface is not recommended, as added methods to VersionServer will result in compilation errors.

type VersionClient 

type VersionClient interface {
	GetVersion(ctx context.Context, in *VersionRequest, opts ...grpc.CallOption) (*VersionResponse, error)
}

VersionClient is the client API for Version service.

For semantics around ctx use and closing/ending streaming RPCs, please refer to https://pkg.go.dev/google.golang.org/grpc/?tab=doc#ClientConn.NewStream.

func NewVersionClient 

func NewVersionClient(cc grpc.ClientConnInterface) VersionClient

type VersionRequest 

type VersionRequest struct {
	// contains filtered or unexported fields
}

func (*VersionRequest) Descriptor deprecated 

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

Deprecated: Use VersionRequest.ProtoReflect.Descriptor instead.

func (*VersionRequest) ProtoMessage 

func (*VersionRequest) ProtoMessage()

func (*VersionRequest) ProtoReflect 

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

func (*VersionRequest) Reset 

func (x *VersionRequest) Reset()

func (*VersionRequest) String 

func (x *VersionRequest) String() string

type VersionResponse 

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

func (*VersionResponse) Descriptor deprecated 

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

Deprecated: Use VersionResponse.ProtoReflect.Descriptor instead.

func (*VersionResponse) GetVersion 

func (x *VersionResponse) GetVersion() string

func (*VersionResponse) ProtoMessage 

func (*VersionResponse) ProtoMessage()

func (*VersionResponse) ProtoReflect 

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

func (*VersionResponse) Reset 

func (x *VersionResponse) Reset()

func (*VersionResponse) String 

func (x *VersionResponse) String() string

type VersionServer 

type VersionServer interface {
	GetVersion(context.Context, *VersionRequest) (*VersionResponse, error)
	// contains filtered or unexported methods
}

VersionServer is the server API for Version service. All implementations must embed UnimplementedVersionServer for forward compatibility

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.