proto

type AuthRequest struct {
	AuthType    AuthenticationType `` /* 140-byte string literal not displayed */
	User        string             `protobuf:"bytes,2,opt,name=user,proto3" json:"user,omitempty"`
	Password    string             `protobuf:"bytes,3,opt,name=password,proto3" json:"password,omitempty"`
	AccessToken string             `protobuf:"bytes,4,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	// contains filtered or unexported fields
}

type AuthResponse struct {
	Token string `protobuf:"bytes,1,opt,name=token,proto3" json:"token,omitempty"`
	Error *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type AuthenticationServiceClient interface {
	Auth(ctx context.Context, in *AuthRequest, opts ...grpc.CallOption) (*AuthResponse, error)
	Session(ctx context.Context, in *SessionRequest, opts ...grpc.CallOption) (*SessionResponse, error)
	RefreshToken(ctx context.Context, in *RefreshTokenRequest, opts ...grpc.CallOption) (*RefreshTokenResponse, error)
}

type AuthenticationServiceServer interface {
	Auth(context.Context, *AuthRequest) (*AuthResponse, error)
	Session(context.Context, *SessionRequest) (*SessionResponse, error)
	RefreshToken(context.Context, *RefreshTokenRequest) (*RefreshTokenResponse, error)
	// contains filtered or unexported methods
}

type AuthenticationType int32

type CancelRequest struct {
	ContextId string `protobuf:"bytes,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	// contains filtered or unexported fields
}

type CancelResponse struct {
	Canceled bool   `protobuf:"varint,1,opt,name=canceled,proto3" json:"canceled,omitempty"`
	Error    *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type ClientInfo struct {
	Version    string     `protobuf:"bytes,1,opt,name=version,proto3" json:"version,omitempty"`
	SourceType SourceType `` /* 138-byte string literal not displayed */
	// contains filtered or unexported fields
}

type CloseRequest struct {
	ContextId string `protobuf:"bytes,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	// contains filtered or unexported fields
}

type CloseResponse struct {
	Closed bool   `protobuf:"varint,1,opt,name=closed,proto3" json:"closed,omitempty"`
	Error  *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type CloseSessionRequest struct {
	CloseRequest *CloseRequest `protobuf:"bytes,1,opt,name=close_request,json=closeRequest,proto3" json:"close_request,omitempty"`
	// contains filtered or unexported fields
}

type CloseSessionResponse struct {
	CloseResponse *CloseResponse `protobuf:"bytes,1,opt,name=close_response,json=closeResponse,proto3" json:"close_response,omitempty"`
	// contains filtered or unexported fields
}

type CloseStatementRequest struct {
	CloseRequest *CloseRequest `protobuf:"bytes,1,opt,name=close_request,json=closeRequest,proto3" json:"close_request,omitempty"`
	// contains filtered or unexported fields
}

type CloseStatementResponse struct {
	CloseResponse *CloseResponse `protobuf:"bytes,1,opt,name=close_response,json=closeResponse,proto3" json:"close_response,omitempty"`
	// contains filtered or unexported fields
}

type ColumnMetadata struct {
	Type       ColumnType `protobuf:"varint,1,opt,name=type,proto3,enum=com.sqream.cloud.generated.v1.ColumnType" json:"type,omitempty"`
	Nullable   bool       `protobuf:"varint,2,opt,name=nullable,proto3" json:"nullable,omitempty"`
	TruVarchar bool       `protobuf:"varint,3,opt,name=tru_varchar,json=truVarchar,proto3" json:"tru_varchar,omitempty"`
	Name       string     `protobuf:"bytes,4,opt,name=name,proto3" json:"name,omitempty"`
	ValueSize  int64      `protobuf:"varint,5,opt,name=value_size,json=valueSize,proto3" json:"value_size,omitempty"`
	Scale      int32      `protobuf:"varint,6,opt,name=scale,proto3" json:"scale,omitempty"`
	Precision  int32      `protobuf:"varint,7,opt,name=precision,proto3" json:"precision,omitempty"`
	// contains filtered or unexported fields
}

type ColumnType int32

type CompileRequest struct {
	ContextId    string `protobuf:"bytes,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	Sql          []byte `protobuf:"bytes,2,opt,name=sql,proto3" json:"sql,omitempty"`
	Encoding     string `protobuf:"bytes,3,opt,name=encoding,proto3" json:"encoding,omitempty"`
	QueryTimeout int64  `protobuf:"varint,4,opt,name=query_timeout,json=queryTimeout,proto3" json:"query_timeout,omitempty"`
	// contains filtered or unexported fields
}

type CompileResponse struct {
	ContextId string            `protobuf:"bytes,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	Columns   []*ColumnMetadata `protobuf:"bytes,2,rep,name=columns,proto3" json:"columns,omitempty"`
	QueryType QueryType         `` /* 134-byte string literal not displayed */
	Error     *Error            `protobuf:"bytes,4,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type Error 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"`
	// contains filtered or unexported fields
}

type ExecuteRequest struct {
	ContextId string `protobuf:"bytes,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	// contains filtered or unexported fields
}

type ExecuteResponse struct {
	ContextId string `protobuf:"bytes,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	Error     *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type FetchRequest struct {
	ContextId string `protobuf:"bytes,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	// contains filtered or unexported fields
}

type FetchResponse struct {
	QueryResult []byte `protobuf:"bytes,1,opt,name=query_result,json=queryResult,proto3" json:"query_result,omitempty"`
	Error       *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	RetryFetch  bool   `protobuf:"varint,3,opt,name=retry_fetch,json=retryFetch,proto3" json:"retry_fetch,omitempty"`
	// contains filtered or unexported fields
}

type QueryExecutionStatus int32

type QueryHandlerServiceClient interface {
	Compile(ctx context.Context, in *CompileRequest, opts ...grpc.CallOption) (*CompileResponse, error)
	Execute(ctx context.Context, in *ExecuteRequest, opts ...grpc.CallOption) (*ExecuteResponse, error)
	Status(ctx context.Context, in *StatusRequest, opts ...grpc.CallOption) (*StatusResponse, error)
	Fetch(ctx context.Context, in *FetchRequest, opts ...grpc.CallOption) (*FetchResponse, error)
	CloseStatement(ctx context.Context, in *CloseStatementRequest, opts ...grpc.CallOption) (*CloseStatementResponse, error)
	Cancel(ctx context.Context, in *CancelRequest, opts ...grpc.CallOption) (*CancelResponse, error)
	CloseSession(ctx context.Context, in *CloseSessionRequest, opts ...grpc.CallOption) (*CloseSessionResponse, error)
}

type QueryHandlerServiceServer interface {
	Compile(context.Context, *CompileRequest) (*CompileResponse, error)
	Execute(context.Context, *ExecuteRequest) (*ExecuteResponse, error)
	Status(context.Context, *StatusRequest) (*StatusResponse, error)
	Fetch(context.Context, *FetchRequest) (*FetchResponse, error)
	CloseStatement(context.Context, *CloseStatementRequest) (*CloseStatementResponse, error)
	Cancel(context.Context, *CancelRequest) (*CancelResponse, error)
	CloseSession(context.Context, *CloseSessionRequest) (*CloseSessionResponse, error)
	// contains filtered or unexported methods
}

type QueryType int32

type RefreshTokenRequest struct {
	RefreshToken string `protobuf:"bytes,1,opt,name=refresh_token,json=refreshToken,proto3" json:"refresh_token,omitempty"`
	// contains filtered or unexported fields
}

type RefreshTokenResponse struct {
	AccessToken string `protobuf:"bytes,1,opt,name=access_token,json=accessToken,proto3" json:"access_token,omitempty"`
	Error       *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type SessionRequest struct {
	TenantId   string      `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	Database   string      `protobuf:"bytes,2,opt,name=database,proto3" json:"database,omitempty"`
	SourceIp   string      `protobuf:"bytes,3,opt,name=source_ip,json=sourceIp,proto3" json:"source_ip,omitempty"`
	ClientInfo *ClientInfo `protobuf:"bytes,4,opt,name=client_info,json=clientInfo,proto3" json:"client_info,omitempty"`
	PoolName   string      `protobuf:"bytes,5,opt,name=pool_name,json=poolName,proto3" json:"pool_name,omitempty"`
	// contains filtered or unexported fields
}

type SessionResponse struct {
	ContextId     string `protobuf:"bytes,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	Error         *Error `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	SqreamVersion string `protobuf:"bytes,3,opt,name=sqream_version,json=sqreamVersion,proto3" json:"sqream_version,omitempty"`
	// contains filtered or unexported fields
}

type SourceType int32

type StatusRequest struct {
	ContextId string `protobuf:"bytes,1,opt,name=context_id,json=contextId,proto3" json:"context_id,omitempty"`
	// contains filtered or unexported fields
}

type StatusResponse struct {
	Status QueryExecutionStatus `protobuf:"varint,1,opt,name=status,proto3,enum=com.sqream.cloud.generated.v1.QueryExecutionStatus" json:"status,omitempty"`
	Error  *Error               `protobuf:"bytes,2,opt,name=error,proto3" json:"error,omitempty"`
	// contains filtered or unexported fields
}

type UnimplementedAuthenticationServiceServer struct {
}

type UnimplementedQueryHandlerServiceServer struct {
}

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

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