ignite3

type Char rune

type Client interface {
	// Connected return true if connection to the cluster is active
	Connected() bool

	// Do sends request and receives response
	Do(req Request, res Response) error

	// Close closes connection.
	// Returns:
	// nil in case of success.
	// error object in case of error.
	Close() error

	SendHeartbeat() error

	GetTables() (map[int64]string, error)

	GetTable(table string) error

	// CacheCreateWithName Creates a cache with a given name.
	// Cache template can be applied if there is a '*' in the cache name.
	// https://apacheignite.readme.io/docs/binary-client-protocol-cache-configuration-operations#section-op_cache_create_with_name
	CacheCreateWithName(cache string) error

	// CacheGetOrCreateWithName creates a cache with a given name.
	// Cache template can be applied if there is a '*' in the cache name.
	// Does nothing if the cache exists.
	// https://apacheignite.readme.io/docs/binary-client-protocol-cache-configuration-operations#section-op_cache_get_or_create_with_name
	CacheGetOrCreateWithName(cache string) error

	// CacheGetNames returns existing cache names.
	// https://apacheignite.readme.io/docs/binary-client-protocol-cache-configuration-operations#section-op_cache_get_names
	CacheGetNames() ([]string, error)

	// CacheDestroy destroys cache with a given name.
	// https://apacheignite.readme.io/docs/binary-client-protocol-cache-configuration-operations#section-op_cache_destroy
	CacheDestroy(cache string) error

	// CacheGet retrieves a value from cache by key.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_get
	CacheGet(cache string, binary bool, key interface{}) (interface{}, error)

	// CacheGetAll retrieves multiple key-value pairs from cache.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_get_all
	CacheGetAll(cache string, binary bool, keys []interface{}) (map[interface{}]interface{}, error)

	// CachePut puts a value with a given key to cache (overwriting existing value if any).
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_put
	CachePut(cache string, binary bool, key interface{}, value interface{}) error

	// CachePutAll puts a value with a given key to cache (overwriting existing value if any).
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_put_all
	CachePutAll(cache string, binary bool, data map[interface{}]interface{}) error

	// CacheContainsKey returns a value indicating whether given key is present in cache.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_contains_key
	CacheContainsKey(cache string, binary bool, key interface{}) (bool, error)

	// CacheContainsKeys returns a value indicating whether all given keys are present in cache.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_contains_keys
	CacheContainsKeys(cache string, binary bool, keys []interface{}) (bool, error)

	// CacheGetAndPut puts a value with a given key to cache, and returns the previous value for that key.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_get_and_put
	CacheGetAndPut(cache string, binary bool, key interface{}, value interface{}) (interface{}, error)

	// CacheGetAndReplace puts a value with a given key to cache, returning previous value for that key,
	// if and only if there is a value currently mapped for that key.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_get_and_replace
	CacheGetAndReplace(cache string, binary bool, key interface{}, value interface{}) (interface{}, error)

	// CacheGetAndRemove removes the cache entry with specified key, returning the value.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_get_and_remove
	CacheGetAndRemove(cache string, binary bool, key interface{}) (interface{}, error)

	// CachePutIfAbsent puts a value with a given key to cache only if the key does not already exist.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_put_if_absent
	CachePutIfAbsent(cache string, binary bool, key interface{}, value interface{}) (bool, error)

	// CacheGetAndPutIfAbsent puts a value with a given key to cache only if the key does not already exist.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_get_and_put_if_absent
	CacheGetAndPutIfAbsent(cache string, binary bool, key interface{}, value interface{}) (interface{}, error)

	// CacheReplace puts a value with a given key to cache only if the key already exists.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_replace
	CacheReplace(cache string, binary bool, key interface{}, value interface{}) (bool, error)

	// CacheReplaceIfEquals puts a value with a given key to cache only if
	// the key already exists and value equals provided value.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_replace_if_equals
	CacheReplaceIfEquals(cache string, binary bool, key interface{}, valueCompare interface{}, valueNew interface{}) (bool, error)

	// CacheClear clears the cache without notifying listeners or cache writers.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_clear
	CacheClear(cache string, binary bool) error

	// CacheClearKey clears the cache key without notifying listeners or cache writers.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_clear_key
	CacheClearKey(cache string, binary bool, key interface{}) error

	// CacheClearKeys clears the cache keys without notifying listeners or cache writers.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_clear_keys
	CacheClearKeys(cache string, binary bool, keys []interface{}) error

	// CacheRemoveKey removes an entry with a given key, notifying listeners and cache writers.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_remove_key
	CacheRemoveKey(cache string, binary bool, key interface{}) (bool, error)

	// CacheRemoveIfEquals removes an entry with a given key if provided value is equal to actual value,
	// notifying listeners and cache writers.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_remove_if_equals
	CacheRemoveIfEquals(cache string, binary bool, key interface{}, value interface{}) (bool, error)

	// CacheGetSize gets the number of entries in cache.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_get_size
	CacheGetSize(cache string, binary bool, modes []byte) (int64, error)

	// CacheRemoveKeys removes entries with given keys, notifying listeners and cache writers.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_remove_keys
	CacheRemoveKeys(cache string, binary bool, keys []interface{}) error

	// CacheRemoveAll destroys cache with a given name.
	// https://apacheignite.readme.io/docs/binary-client-protocol-key-value-operations#section-op_cache_remove_all
	CacheRemoveAll(cache string, binary bool) error

	// QuerySQL executes an SQL query over data stored in the cluster. The query returns the whole record (key and value).
	QuerySQL(data QuerySQLData) (QuerySQLResult, error)

	// QuerySQLCursorGetPage retrieves the next SQL query cursor page by cursor id from QuerySQL.
	// It needs the schema (we find it embedded in the metadata of original query)
	QuerySQLCursorGetPage(id int64, metadata *ResultSetMetadata) (QuerySQLResult, error)

	// QuerySQLFieldsRaw is equal to QuerySQLFields but return raw Response object.
	// Used for SQL driver to reduce memory allocations.
	QuerySQLFieldsRaw(data QuerySQLFieldsData) (*ResponseOperation, error)

	// QuerySQLFields performs SQL fields query.
	// https://apacheignite.readme.io/docs/binary-client-protocol-sql-operations#section-op_query_sql_fields
	QuerySQLFields(data QuerySQLFieldsData) (QuerySQLResult, error)

	// QuerySQLFieldsCursorGetPageRaw is equal to QuerySQLFieldsCursorGetPage but return raw Response object.
	// Used for SQL driver to reduce memory allocations.
	QuerySQLFieldsCursorGetPageRaw(id int64) (*ResponseOperation, error)

	// ResourceClose closes a resource, such as query cursor.
	// https://apacheignite.readme.io/docs/binary-client-protocol-sql-operations#section-op_resource_close
	ResourceClose(id int64) error
}

type ClientDirectTxMode uint8

type ClientPartitionAwarenessMetadata struct {
	TableId      int
	Indexes      []int
	Hash         []int
	DirectTxMode ClientDirectTxMode
}

type Column struct {
	Name string
}

type ColumnMetadata struct {
	Name     string
	Nullable bool
	//Class<?> valueClass();
	Type      *ColumnType // See columnType.java
	Precision int
	Scale     int
	Index     int
	Origin    *ColumnOrigin
}

type ColumnOrigin struct {
	Schema string
	Table  string
	Column string
}

type ColumnType struct {
	SQLTypeName      string       // Type name in SQL
	TypeId           int          // Type ID in Ignite3
	GoKind           reflect.Kind // Kind name in Golang
	PrecisionAllowed bool
	ScaleAllowed     bool
	LengthAllowed    bool
}

type ColumnTypes []ColumnType

type ConnInfo struct {
	Network, Host       string
	Port                int
	Major, Minor, Patch int
	Username, Password  string
	Dialer              net.Dialer
	TLSConfig           *tls.Config
}

type Date struct{ Time time.Time }

type DateTime struct{ Time time.Time }

type Decimal struct {
	Unscaled *big.Int // number without dot, Ex.: 31415926535
	Scale    int      // number of decimal places, Ex.: 10. So with Unscaled, we got 3.1415926535
}

type QuerySQLData struct {
	// Schema for the query
	Schema string

	// SQL query string.
	Query string

	// Query arguments.
	QueryArgs []interface{}

	// Cursor page size.
	PageSize int

	// Timeout(milliseconds) value should be non-negative. Zero value disables timeout.
	Timeout int64
}

type QuerySQLFieldsData struct {
	// Schema for the query; can be empty, in which case default PUBLIC schema will be used.
	Schema string

	// Query cursor page size.
	PageSize int

	// SQL query string.
	Query string

	// Query arguments.
	QueryArgs []interface{}

	// Timeout(milliseconds) value should be non-negative. Zero value disables timeout.
	Timeout int64
}

type QuerySQLPage struct {
	// Key -> Values
	Rows map[int]interface{}

	// Indicates whether more results are available to be fetched with QuerySQLCursorGetPage.
	// When false, query cursor is closed automatically.
	HasMore bool
}

type QuerySQLResult struct {
	// Cursor id. Can be closed with ResourceClose func.
	ResponseId int64
	ResourceId int64
	Metadata   *ResultSetMetadata

	HasRowSet bool

	AffectedRows int64
	// Query result first page
	QuerySQLPage
	// contains filtered or unexported fields
}

type QueryScanData struct {
	// Cursor page size.
	PageSize int

	// Number of partitions to query (negative to query entire cache).
	Partitions int

	// Local flag - whether this query should be executed on local node only.
	LocalQuery bool
}

type Request interface {
	// WriteTo is function to write request data to io.Writer.
	// Returns written bytes.
	WriteTo(w io.Writer) (int64, error)
}

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

type RequestHeartbeat struct {
	Code int8
	UID  int64
	// contains filtered or unexported fields
}

type RequestOperation struct {
	Code         int16
	RequestId    int64
	SpecificData []byte
	// contains filtered or unexported fields
}

type Response interface {
	// ReadFrom is function to read request data from io.Reader.
	// Returns read bytes.
	ReadFrom(r *bufio.Reader) (int64, error)
}

type ResponseHandshake struct {
	// Success flag
	Success bool
	// Server version major, minor, patch
	Major, Minor, Patch int
	ErrorUuid           Uuid
	ErrorMessage        string
	ErrorStackTrace     string
	ErrorDetails        string

	ClientType         int8
	IdleTimeout        int64
	ClusterNodeId      Uuid
	ClusterNodeName    string
	ClusterIdsCount    uint8
	ClusterIds         []Uuid
	ClusterName        string
	ObservableTS       int64
	DBMSVerMajor       uint8
	DBMSVerMinor       uint8
	DBMSVerMaintenance uint8
	DBMSVerPatch       string
	DBMSVerPreRelease  string
	Features           []byte // FIXME
	// contains filtered or unexported fields
}

type ResponseHeartbeat struct {
	// Request id
	UID int64
	// Status code (0 for success, otherwise error code)
	Status int32
	// What is this data?
	UnknownData int64
	// contains filtered or unexported fields
}

type ResponseOperation struct {
	// Request id
	RequestId int64
	// Status code (0 for success, otherwise error code)
	Flags int32
	// Observable Timestamp (causality token)
	ObsTs time.Time
	// Error message (present only when status is not 0)
	Code    int64
	Uuid    Uuid
	Message string
	Details string

	// Copie des données restantes, pour comprendre pourquoi j'ai un EOF :
	// ping failed: failed to execute ping query: failed to read result set column metadata: failed to read result set column property count: EOF
	Data bytes.Buffer
	// contains filtered or unexported fields
}

type ResultSetMetadata struct {
	Columns []ColumnMetadata
}

type Schema struct {
	Columns []Column
	// contains filtered or unexported fields
}

type Time struct{ Time time.Time }

type Timestamp struct{ Time time.Time }

type Tuple struct {
	BinaryTuple *bytes.Buffer
	// contains filtered or unexported fields
}

type Uuid struct {
	uuid.UUID
}