ignite

package
v0.7.0 Latest Latest
Warning

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

 Go to latest Published: May 5, 2018 License: Apache-2.0 Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const (
	// CacheAtomicityModeTransactional is TRANSACTIONAL = 0
	CacheAtomicityModeTransactional = 0
	// CacheAtomicityModeAtomic is ATOMIC = 1
	CacheAtomicityModeAtomic = 1

	// CacheModeLocal is LOCAL = 0
	CacheModeLocal = 0
	// CacheModeReplicated is REPLICATED = 1
	CacheModeReplicated = 1
	// CacheModePartitioned is PARTITIONED  = 2
	CacheModePartitioned = 2

	// PartitionLossPolicyReadOnlySafe is READ_ONLY_SAFE = 0
	PartitionLossPolicyReadOnlySafe = 0
	// PartitionLossPolicyReadOnlyAll is READ_ONLY_ALL = 1
	PartitionLossPolicyReadOnlyAll = 1
	// PartitionLossPolicyReadWriteSafe is READ_WRITE_SAFE = 2
	PartitionLossPolicyReadWriteSafe = 2
	// PartitionLossPolicyReadWriteAll is READ_WRITE_ALL = 3
	PartitionLossPolicyReadWriteAll = 3
	// PartitionLossPolicyIgnore is IGNORE = 4
	PartitionLossPolicyIgnore = 4

	// RebalanceModeSync is SYNC = 0
	RebalanceModeSync = 0
	// RebalanceModeASync is ASYNC = 1
	RebalanceModeASync = 0
	// RebalanceModeNone is NONE = 2
	RebalanceModeNone = 2

	// WriteSynchronizationModeFullSync is FULL_SYNC = 0
	WriteSynchronizationModeFullSync = 0
	// WriteSynchronizationModeFullASync is FULL_ASYNC = 1
	WriteSynchronizationModeFullASync = 1
	// WriteSynchronizationModePrimarySync is PRIMARY_SYNC = 2
	WriteSynchronizationModePrimarySync = 2

	// QueryIndexTypeSorted is SORTED = 0
	QueryIndexTypeSorted = 0
	// QueryIndexTypeFullText is FULLTEXT = 1
	QueryIndexTypeFullText = 1
	// QueryIndexTypeGeospatial is GEOSPATIAL = 2
	QueryIndexTypeGeospatial = 2
)
View Source 
const (
	// PeekModeAll is ALL
	PeekModeAll = 0
	// PeekModeNear is NEAR
	PeekModeNear = 1
	// PeekModePrimary is PRIMARY
	PeekModePrimary = 2
	// PeekModeBackup is BACKUP
	PeekModeBackup = 3
)
View Source 
const (
	// StatementTypeAny is ANY = 0
	StatementTypeAny byte = 0

	// StatementTypeSelect is SELECT = 1
	StatementTypeSelect byte = 1

	// StatementTypeUpdate is UPDATE = 2
	StatementTypeUpdate byte = 2
)
View Source 
const (

	// OpCacheGetNames gets existing cache names.
	OpCacheGetNames = 1050
	// OpCacheCreateWithName creates a cache with a given name.
	OpCacheCreateWithName = 1051
	// OpCacheGetOrCreateWithName creates a cache with a given name.
	// Does nothing if the cache exists.
	OpCacheGetOrCreateWithName = 1052
	// OpCacheCreateWithConfiguration creates cache with provided configuration.
	OpCacheCreateWithConfiguration = 1053
	// OpCacheGetOrCreateWithConfiguration creates cache with provided configuration.
	// Does nothing if the name is already in use.
	OpCacheGetOrCreateWithConfiguration = 1054
	// OpCacheGetConfiguration gets configuration for the given cache.
	OpCacheGetConfiguration = 1055
	// OpCacheDestroy destroys cache with a given name.
	OpCacheDestroy = 1056

	// OpCacheGet retrieves a value from cache by key.
	OpCacheGet = 1000
	// OpCachePut puts a value with a given key to cache (overwriting existing value if any).
	OpCachePut = 1001
	// OpCachePutIfAbsent puts a value with a given key to cache only if the key does not already exist.
	OpCachePutIfAbsent = 1002
	// OpCacheGetAll retrieves multiple key-value pairs from cache.
	OpCacheGetAll = 1003
	// OpCachePutAll puts multiple key-value pairs to cache (overwriting existing associations if any).
	OpCachePutAll = 1004
	// OpCacheGetAndPut puts a value with a given key to cache, and returns the previous value for that key.
	OpCacheGetAndPut = 1005
	// OpCacheGetAndReplace 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.
	OpCacheGetAndReplace = 1006
	// OpCacheGetAndRemove removes the cache entry with specified key, returning the value.
	OpCacheGetAndRemove = 1007
	// OpCacheGetAndPutIfAbsent puts a value with a given key to cache only if the key does not already exist.
	OpCacheGetAndPutIfAbsent = 1008
	// OpCacheReplace puts a value with a given key to cache only if the key already exists.
	OpCacheReplace = 1009
	// OpCacheReplaceIfEquals puts a value with a given key to cache only if the key already exists and value equals provided value.
	OpCacheReplaceIfEquals = 1010
	// OpCacheContainsKey returns a value indicating whether given key is present in cache.
	OpCacheContainsKey = 1011
	// OpCacheContainsKeys returns a value indicating whether all given keys are present in cache.
	OpCacheContainsKeys = 1012
	// OpCacheClear clears the cache without notifying listeners or cache writers.
	OpCacheClear = 1013
	// OpCacheClearKey clears the cache key without notifying listeners or cache writers.
	OpCacheClearKey = 1014
	// OpCacheClearKeys clears the cache keys without notifying listeners or cache writers.
	OpCacheClearKeys = 1015
	// OpCacheRemoveKey removes an entry with a given key, notifying listeners and cache writers.
	OpCacheRemoveKey = 1016
	// OpCacheRemoveIfEquals removes an entry with a given key if provided value is equal to actual value,
	// notifying listeners and cache writers.
	OpCacheRemoveIfEquals = 1017
	// OpCacheRemoveKeys removes entries with given keys, notifying listeners and cache writers.
	OpCacheRemoveKeys = 1018
	// OpCacheRemoveAll removes all entries from cache, notifying listeners and cache writers.
	OpCacheRemoveAll = 1019
	// OpCacheGetSize gets the number of entries in cache.
	OpCacheGetSize = 1020

	// OpQuerySQL executes an SQL query over data stored in the cluster.
	// The query returns the whole record (key and value).
	OpQuerySQL = 2002
	// OpQuerySQLCursorGetPage retrieves the next SQL query cursor page by cursor id from OP_QUERY_SQL.
	OpQuerySQLCursorGetPage = 2003
	// OpQuerySQLFields performs SQL fields query.
	OpQuerySQLFields = 2004
	// OpQuerySQLFieldsCursorGetPage retrieves the next query result page by cursor id from OP_QUERY_SQL_FIELDS.
	OpQuerySQLFieldsCursorGetPage = 2005
	// OpQueryScan performs scan query.
	OpQueryScan = 2000
	// OpQueryScanCursorGetPage fetches the next SQL query cursor page by cursor id that is obtained from OP_QUERY_SCAN.
	OpQueryScanCursorGetPage = 2001
	// OpResourceClose closes a resource, such as query cursor.
	OpResourceClose = 0
)
View Source 
const (
	// OperationStatusSuccess means success
	OperationStatusSuccess = 0
)

Variables

This section is empty.

Functions

func HashCode 

func HashCode(s string) int32

HashCode calculates Java hash code for string

Types

type CacheConfiguration 

type CacheConfiguration struct {
	AtomicityMode                 int32
	Backups                       int32
	CacheMode                     int32
	CopyOnRead                    bool
	DataRegionName                string
	EagerTTL                      bool
	EnableStatistics              bool
	GroupName                     string
	LockTimeout                   int64
	MaxConcurrentAsyncOperations  int32
	MaxQueryIterators             int32
	Name                          string
	OnheapCacheEnabled            bool
	PartitionLossPolicy           int32
	QueryDetailMetricsSize        int32
	QueryParellelism              int32
	ReadFromBackup                bool
	RebalanceBatchSize            int32
	RebalanceBatchesPrefetchCount int64
	RebalanceDelay                int64
	RebalanceMode                 int32
	RebalanceOrder                int32
	RebalanceThrottle             int64
	RebalanceTimeout              int64
	SQLEscapeAll                  bool
	SQLIndexInlineMaxSize         int32
	SQLSchema                     string
	WriteSynchronizationMode      int32
	CacheKeyConfigurations        []CacheKeyConfiguration
	QueryEntities                 []QueryEntity
}

CacheConfiguration describes cache configuration

type CacheConfigurationRefs 

type CacheConfigurationRefs struct {
	AtomicityMode                 *int32
	Backups                       *int32
	CacheMode                     *int32
	CopyOnRead                    *bool
	DataRegionName                *string
	EagerTTL                      *bool
	EnableStatistics              *bool
	GroupName                     *string
	LockTimeout                   *int64
	MaxConcurrentAsyncOperations  *int32
	MaxQueryIterators             *int32
	Name                          *string
	OnheapCacheEnabled            *bool
	PartitionLossPolicy           *int32
	QueryDetailMetricsSize        *int32
	QueryParellelism              *int32
	ReadFromBackup                *bool
	RebalanceBatchSize            *int32
	RebalanceBatchesPrefetchCount *int64
	RebalanceDelay                *int64
	RebalanceMode                 *int32
	RebalanceOrder                *int32
	RebalanceThrottle             *int64
	RebalanceTimeout              *int64
	SQLEscapeAll                  *bool
	SQLIndexInlineMaxSize         *int32
	SQLSchema                     *string
	WriteSynchronizationMode      *int32
	CacheKeyConfigurations        []CacheKeyConfiguration
	QueryEntities                 []QueryEntity
}

CacheConfigurationRefs describes cache configuration to create new cache

type CacheKeyConfiguration 

type CacheKeyConfiguration struct {
	TypeName             string
	AffinityKeyFieldName string
}

CacheKeyConfiguration is struct

type Char 

type Char rune

Char is Apache Ignite "char" type

type Client 

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

	// 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)

	// CacheGetConfiguration gets configuration for the given cache.
	// https://apacheignite.readme.io/docs/binary-client-protocol-cache-configuration-operations#section-op_cache_get_configuration
	CacheGetConfiguration(cache string, flag byte) (*CacheConfiguration, error)

	// CacheCreateWithConfiguration creates cache with provided configuration.
	// An error is returned if the name is already in use.
	// https://apacheignite.readme.io/docs/binary-client-protocol-cache-configuration-operations#section-op_cache_create_with_configuration
	CacheCreateWithConfiguration(cc *CacheConfigurationRefs) error

	// CacheGetOrCreateWithConfiguration creates cache with provided configuration.
	// Does nothing if the name is already in use.
	// https://apacheignite.readme.io/docs/binary-client-protocol-cache-configuration-operations#section-op_cache_get_or_create_with_configuration
	CacheGetOrCreateWithConfiguration(cc *CacheConfigurationRefs) 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).
	// https://apacheignite.readme.io/docs/binary-client-protocol-sql-operations#section-op_query_sql
	QuerySQL(cache string, binary bool, data QuerySQLData) (QuerySQLResult, error)

	// QuerySQLCursorGetPage retrieves the next SQL query cursor page by cursor id from QuerySQL.
	// https://apacheignite.readme.io/docs/binary-client-protocol-sql-operations#section-op_query_sql_cursor_get_page
	QuerySQLCursorGetPage(id int64) (QuerySQLPage, error)

	// QuerySQLFieldsRaw is equal to QuerySQLFields but return raw Response object.
	// Used for SQL driver to reduce memory allocations.
	QuerySQLFieldsRaw(cache string, binary bool, 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(cache string, binary bool, data QuerySQLFieldsData) (QuerySQLFieldsResult, error)

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

	// QuerySQLFieldsCursorGetPage retrieves the next query result page by cursor id from QuerySQLFields.
	// https://apacheignite.readme.io/docs/binary-client-protocol-sql-operations#section-op_query_sql_fields_cursor_get_page
	QuerySQLFieldsCursorGetPage(id int64, fieldCount int) (QuerySQLFieldsPage, 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
}

Client is interface to communicate with Apache Ignite cluster. Client is thread safe.

func Connect 

func Connect(ctx context.Context, ci ConnInfo) (Client, error)

Connect connects to the Apache Ignite cluster Returns: client

type ConnInfo 

type ConnInfo struct {
	Network, Host       string
	Port                int
	Major, Minor, Patch int
}

ConnInfo contains connections parameters

type Date 

type Date int64

Date is Unix time, the number of MILLISECONDS elapsed since January 1, 1970 UTC.

func ToDate 

func ToDate(t time.Time) Date

ToDate converts Golang time.Time to Apache Ignite Date

type Field 

type Field struct {
	Name         string
	IsDescensing bool
}

Field is struct

type FieldNameAlias 

type FieldNameAlias struct {
	Name  string
	Alias string
}

FieldNameAlias is struct

type QueryEntity 

type QueryEntity struct {
	KeyTypeName      string
	ValueTypeName    string
	TableName        string
	KeyFieldName     string
	ValueFieldName   string
	QueryFields      []QueryField
	FieldNameAliases []FieldNameAlias
	QueryIndexes     []QueryIndex
}

QueryEntity is struct

type QueryField 

type QueryField struct {
	Name                     string
	TypeName                 string
	IsKeyField               bool
	IsNotNullConstraintField bool
}

QueryField is struct

type QueryIndex 

type QueryIndex struct {
	Name       string
	Type       byte
	InlineSize int32
	Fields     []Field
}

QueryIndex is struct

type QuerySQLData 

type QuerySQLData struct {
	// Name of a type or SQL table.
	Table string

	// SQL query string.
	Query string

	// Query arguments.
	QueryArgs []interface{}

	// Distributed joins.
	DistributedJoins bool

	// Local query.
	LocalQuery bool

	// Replicated only - Whether query contains only replicated tables or not.
	ReplicatedOnly bool

	// Cursor page size.
	PageSize int

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

QuerySQLData input parameter for QuerySQL func

type QuerySQLFieldsData 

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

	// Max rows.
	MaxRows int

	// SQL query string.
	Query string

	// Query arguments.
	QueryArgs []interface{}

	// Statement type.
	// ANY = 0
	// SELECT = 1
	// UPDATE = 2
	StatementType byte

	// Distributed joins.
	DistributedJoins bool

	// Local query.
	LocalQuery bool

	// Replicated only - Whether query contains only replicated tables or not.
	ReplicatedOnly bool

	// Enforce join order.
	EnforceJoinOrder bool

	// Collocated - Whether your data is co-located or not.
	Collocated bool

	// Lazy query execution.
	LazyQuery bool

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

	// Include field names.
	IncludeFieldNames bool
}

QuerySQLFieldsData input parameter for QuerySQLFields func

type QuerySQLFieldsPage 

type QuerySQLFieldsPage struct {
	// Values
	Rows [][]interface{}

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

QuerySQLFieldsPage is query result page

type QuerySQLFieldsResult 

type QuerySQLFieldsResult struct {
	// Cursor id. Can be closed with ResourceClose func.
	ID int64

	// Field (column) count.
	FieldCount int

	// Needed only when IncludeFieldNames is true in the request.
	// Column names.
	Fields []string

	// Query result first page
	QuerySQLFieldsPage
}

QuerySQLFieldsResult output from QuerySQLFields func

type QuerySQLPage 

type QuerySQLPage struct {
	// Keys (field names)
	Keys []interface{}

	// Values
	Values []interface{}

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

QuerySQLPage is query result page

type QuerySQLResult 

type QuerySQLResult struct {
	// Cursor id. Can be closed with ResourceClose func.
	ID int64

	// Query result first page
	QuerySQLPage
}

QuerySQLResult output from QuerySQL func

type Request 

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

Request is interface of base message request functionality

type RequestCacheCreateWithConfiguration 

type RequestCacheCreateWithConfiguration struct {
	Count int16

	RequestOperation
}

RequestCacheCreateWithConfiguration is struct to store operation request

func NewRequestCacheCreateWithConfiguration 

func NewRequestCacheCreateWithConfiguration(code int16) *RequestCacheCreateWithConfiguration

NewRequestCacheCreateWithConfiguration creates new handshake request object

func (*RequestCacheCreateWithConfiguration) WriteBool 

func (r *RequestCacheCreateWithConfiguration) WriteBool(v bool) error

WriteBool writes "bool" value

func (*RequestCacheCreateWithConfiguration) WriteByte 

func (r *RequestCacheCreateWithConfiguration) WriteByte(v byte) error

WriteByte writes "byte" value

func (*RequestCacheCreateWithConfiguration) WriteChar 

func (r *RequestCacheCreateWithConfiguration) WriteChar(v Char) error

WriteChar writes "char" value

func (*RequestCacheCreateWithConfiguration) WriteDouble 

func (r *RequestCacheCreateWithConfiguration) WriteDouble(v float64) error

WriteDouble writes "double" value

func (*RequestCacheCreateWithConfiguration) WriteFloat 

func (r *RequestCacheCreateWithConfiguration) WriteFloat(v float32) error

WriteFloat writes "float" value

func (*RequestCacheCreateWithConfiguration) WriteInt 

func (r *RequestCacheCreateWithConfiguration) WriteInt(v int32) error

WriteInt writes "int" value

func (*RequestCacheCreateWithConfiguration) WriteLong 

func (r *RequestCacheCreateWithConfiguration) WriteLong(v int64) error

WriteLong writes "long" value

func (*RequestCacheCreateWithConfiguration) WriteNull 

func (r *RequestCacheCreateWithConfiguration) WriteNull() error

WriteNull writes NULL

func (*RequestCacheCreateWithConfiguration) WriteOArrayBools 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayBools(v []bool) error

WriteOArrayBools writes "Bool" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayBytes 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayBytes(v []byte) error

WriteOArrayBytes writes "byte" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayChars 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayChars(v []Char) error

WriteOArrayChars writes "char" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayDoubles 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayDoubles(v []float64) error

WriteOArrayDoubles writes "double" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayFloats 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayFloats(v []float32) error

WriteOArrayFloats writes "float" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayInts 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayInts(v []int32) error

WriteOArrayInts writes "int" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayLongs 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayLongs(v []int64) error

WriteOArrayLongs writes "long" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayODates 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayODates(v []Date) error

WriteOArrayODates writes "Date" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayOStrings 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayOStrings(v []string) error

WriteOArrayOStrings writes "String" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayOTimes 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayOTimes(v []Time) error

WriteOArrayOTimes writes "Time" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayOTimestamps 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayOTimestamps(v []time.Time) error

WriteOArrayOTimestamps writes "Timestamp" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayOUUIDs 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayOUUIDs(v []uuid.UUID) error

WriteOArrayOUUIDs writes "UUID" array object value

func (*RequestCacheCreateWithConfiguration) WriteOArrayShorts 

func (r *RequestCacheCreateWithConfiguration) WriteOArrayShorts(v []int16) error

WriteOArrayShorts writes "short" array object value

func (*RequestCacheCreateWithConfiguration) WriteOBool 

func (r *RequestCacheCreateWithConfiguration) WriteOBool(v bool) error

WriteOBool writes "bool" object value

func (*RequestCacheCreateWithConfiguration) WriteOByte 

func (r *RequestCacheCreateWithConfiguration) WriteOByte(v byte) error

WriteOByte writes "byte" object value

func (*RequestCacheCreateWithConfiguration) WriteOChar 

func (r *RequestCacheCreateWithConfiguration) WriteOChar(v Char) error

WriteOChar writes "char" object value

func (*RequestCacheCreateWithConfiguration) WriteODate 

func (r *RequestCacheCreateWithConfiguration) WriteODate(v Date) error

WriteODate writes "Date" object value

func (*RequestCacheCreateWithConfiguration) WriteODouble 

func (r *RequestCacheCreateWithConfiguration) WriteODouble(v float64) error

WriteODouble writes "double" object value

func (*RequestCacheCreateWithConfiguration) WriteOFloat 

func (r *RequestCacheCreateWithConfiguration) WriteOFloat(v float32) error

WriteOFloat writes "float" object value

func (*RequestCacheCreateWithConfiguration) WriteOInt 

func (r *RequestCacheCreateWithConfiguration) WriteOInt(v int32) error

WriteOInt writes "int" object value

func (*RequestCacheCreateWithConfiguration) WriteOLong 

func (r *RequestCacheCreateWithConfiguration) WriteOLong(v int64) error

WriteOLong writes "long" object value

func (*RequestCacheCreateWithConfiguration) WriteOShort 

func (r *RequestCacheCreateWithConfiguration) WriteOShort(v int16) error

WriteOShort writes "short" object value

func (*RequestCacheCreateWithConfiguration) WriteOString 

func (r *RequestCacheCreateWithConfiguration) WriteOString(v string) error

WriteOString writes "string" object value String is marshalling as object in all cases.

func (*RequestCacheCreateWithConfiguration) WriteOTime 

func (r *RequestCacheCreateWithConfiguration) WriteOTime(v Time) error

WriteOTime writes "Time" object value Time is marshaled as object in all cases.

func (*RequestCacheCreateWithConfiguration) WriteOTimestamp 

func (r *RequestCacheCreateWithConfiguration) WriteOTimestamp(v time.Time) error

WriteOTimestamp writes "Timestamp" object value Timestamp is marshaled as object in all cases.

func (*RequestCacheCreateWithConfiguration) WriteOUUID 

func (r *RequestCacheCreateWithConfiguration) WriteOUUID(v uuid.UUID) error

WriteOUUID writes "UUID" object value UUID is marshaled as object in all cases.

func (*RequestCacheCreateWithConfiguration) WriteObject 

func (r *RequestCacheCreateWithConfiguration) WriteObject(o interface{}) error

func (*RequestCacheCreateWithConfiguration) WriteShort 

func (r *RequestCacheCreateWithConfiguration) WriteShort(v int16) error

WriteShort writes "short" value

func (*RequestCacheCreateWithConfiguration) WriteTo 

func (r *RequestCacheCreateWithConfiguration) WriteTo(w io.Writer) (int64, error)

WriteTo is function to write handshake request data to io.Writer. Returns written bytes.

type RequestHandshake 

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

RequestHandshake is struct handshake request

func NewRequestHandshake 

func NewRequestHandshake(major, minor, patch int) *RequestHandshake

NewRequestHandshake creates new handshake request object

func (*RequestHandshake) WriteBool 

func (r *RequestHandshake) WriteBool(v bool) error

WriteBool writes "bool" value

func (*RequestHandshake) WriteByte 

func (r *RequestHandshake) WriteByte(v byte) error

WriteByte writes "byte" value

func (*RequestHandshake) WriteChar 

func (r *RequestHandshake) WriteChar(v Char) error

WriteChar writes "char" value

func (*RequestHandshake) WriteDouble 

func (r *RequestHandshake) WriteDouble(v float64) error

WriteDouble writes "double" value

func (*RequestHandshake) WriteFloat 

func (r *RequestHandshake) WriteFloat(v float32) error

WriteFloat writes "float" value

func (*RequestHandshake) WriteInt 

func (r *RequestHandshake) WriteInt(v int32) error

WriteInt writes "int" value

func (*RequestHandshake) WriteLong 

func (r *RequestHandshake) WriteLong(v int64) error

WriteLong writes "long" value

func (*RequestHandshake) WriteNull 

func (r *RequestHandshake) WriteNull() error

WriteNull writes NULL

func (*RequestHandshake) WriteOArrayBools 

func (r *RequestHandshake) WriteOArrayBools(v []bool) error

WriteOArrayBools writes "Bool" array object value

func (*RequestHandshake) WriteOArrayBytes 

func (r *RequestHandshake) WriteOArrayBytes(v []byte) error

WriteOArrayBytes writes "byte" array object value

func (*RequestHandshake) WriteOArrayChars 

func (r *RequestHandshake) WriteOArrayChars(v []Char) error

WriteOArrayChars writes "char" array object value

func (*RequestHandshake) WriteOArrayDoubles 

func (r *RequestHandshake) WriteOArrayDoubles(v []float64) error

WriteOArrayDoubles writes "double" array object value

func (*RequestHandshake) WriteOArrayFloats 

func (r *RequestHandshake) WriteOArrayFloats(v []float32) error

WriteOArrayFloats writes "float" array object value

func (*RequestHandshake) WriteOArrayInts 

func (r *RequestHandshake) WriteOArrayInts(v []int32) error

WriteOArrayInts writes "int" array object value

func (*RequestHandshake) WriteOArrayLongs 

func (r *RequestHandshake) WriteOArrayLongs(v []int64) error

WriteOArrayLongs writes "long" array object value

func (*RequestHandshake) WriteOArrayODates 

func (r *RequestHandshake) WriteOArrayODates(v []Date) error

WriteOArrayODates writes "Date" array object value

func (*RequestHandshake) WriteOArrayOStrings 

func (r *RequestHandshake) WriteOArrayOStrings(v []string) error

WriteOArrayOStrings writes "String" array object value

func (*RequestHandshake) WriteOArrayOTimes 

func (r *RequestHandshake) WriteOArrayOTimes(v []Time) error

WriteOArrayOTimes writes "Time" array object value

func (*RequestHandshake) WriteOArrayOTimestamps 

func (r *RequestHandshake) WriteOArrayOTimestamps(v []time.Time) error

WriteOArrayOTimestamps writes "Timestamp" array object value

func (*RequestHandshake) WriteOArrayOUUIDs 

func (r *RequestHandshake) WriteOArrayOUUIDs(v []uuid.UUID) error

WriteOArrayOUUIDs writes "UUID" array object value

func (*RequestHandshake) WriteOArrayShorts 

func (r *RequestHandshake) WriteOArrayShorts(v []int16) error

WriteOArrayShorts writes "short" array object value

func (*RequestHandshake) WriteOBool 

func (r *RequestHandshake) WriteOBool(v bool) error

WriteOBool writes "bool" object value

func (*RequestHandshake) WriteOByte 

func (r *RequestHandshake) WriteOByte(v byte) error

WriteOByte writes "byte" object value

func (*RequestHandshake) WriteOChar 

func (r *RequestHandshake) WriteOChar(v Char) error

WriteOChar writes "char" object value

func (*RequestHandshake) WriteODate 

func (r *RequestHandshake) WriteODate(v Date) error

WriteODate writes "Date" object value

func (*RequestHandshake) WriteODouble 

func (r *RequestHandshake) WriteODouble(v float64) error

WriteODouble writes "double" object value

func (*RequestHandshake) WriteOFloat 

func (r *RequestHandshake) WriteOFloat(v float32) error

WriteOFloat writes "float" object value

func (*RequestHandshake) WriteOInt 

func (r *RequestHandshake) WriteOInt(v int32) error

WriteOInt writes "int" object value

func (*RequestHandshake) WriteOLong 

func (r *RequestHandshake) WriteOLong(v int64) error

WriteOLong writes "long" object value

func (*RequestHandshake) WriteOShort 

func (r *RequestHandshake) WriteOShort(v int16) error

WriteOShort writes "short" object value

func (*RequestHandshake) WriteOString 

func (r *RequestHandshake) WriteOString(v string) error

WriteOString writes "string" object value String is marshalling as object in all cases.

func (*RequestHandshake) WriteOTime 

func (r *RequestHandshake) WriteOTime(v Time) error

WriteOTime writes "Time" object value Time is marshaled as object in all cases.

func (*RequestHandshake) WriteOTimestamp 

func (r *RequestHandshake) WriteOTimestamp(v time.Time) error

WriteOTimestamp writes "Timestamp" object value Timestamp is marshaled as object in all cases.

func (*RequestHandshake) WriteOUUID 

func (r *RequestHandshake) WriteOUUID(v uuid.UUID) error

WriteOUUID writes "UUID" object value UUID is marshaled as object in all cases.

func (*RequestHandshake) WriteObject 

func (r *RequestHandshake) WriteObject(o interface{}) error

func (*RequestHandshake) WriteShort 

func (r *RequestHandshake) WriteShort(v int16) error

WriteShort writes "short" value

func (*RequestHandshake) WriteTo 

func (r *RequestHandshake) WriteTo(w io.Writer) (int64, error)

WriteTo is function to write handshake request data to io.Writer. Returns written bytes.

type RequestOperation 

type RequestOperation struct {
	Code int16
	UID  int64
	// contains filtered or unexported fields
}

RequestOperation is struct to store operation request

func NewRequestOperation 

func NewRequestOperation(code int16) *RequestOperation

NewRequestOperation creates new handshake request object

func (*RequestOperation) WriteBool 

func (r *RequestOperation) WriteBool(v bool) error

WriteBool writes "bool" value

func (*RequestOperation) WriteByte 

func (r *RequestOperation) WriteByte(v byte) error

WriteByte writes "byte" value

func (*RequestOperation) WriteChar 

func (r *RequestOperation) WriteChar(v Char) error

WriteChar writes "char" value

func (*RequestOperation) WriteDouble 

func (r *RequestOperation) WriteDouble(v float64) error

WriteDouble writes "double" value

func (*RequestOperation) WriteFloat 

func (r *RequestOperation) WriteFloat(v float32) error

WriteFloat writes "float" value

func (*RequestOperation) WriteInt 

func (r *RequestOperation) WriteInt(v int32) error

WriteInt writes "int" value

func (*RequestOperation) WriteLong 

func (r *RequestOperation) WriteLong(v int64) error

WriteLong writes "long" value

func (*RequestOperation) WriteNull 

func (r *RequestOperation) WriteNull() error

WriteNull writes NULL

func (*RequestOperation) WriteOArrayBools 

func (r *RequestOperation) WriteOArrayBools(v []bool) error

WriteOArrayBools writes "Bool" array object value

func (*RequestOperation) WriteOArrayBytes 

func (r *RequestOperation) WriteOArrayBytes(v []byte) error

WriteOArrayBytes writes "byte" array object value

func (*RequestOperation) WriteOArrayChars 

func (r *RequestOperation) WriteOArrayChars(v []Char) error

WriteOArrayChars writes "char" array object value

func (*RequestOperation) WriteOArrayDoubles 

func (r *RequestOperation) WriteOArrayDoubles(v []float64) error

WriteOArrayDoubles writes "double" array object value

func (*RequestOperation) WriteOArrayFloats 

func (r *RequestOperation) WriteOArrayFloats(v []float32) error

WriteOArrayFloats writes "float" array object value

func (*RequestOperation) WriteOArrayInts 

func (r *RequestOperation) WriteOArrayInts(v []int32) error

WriteOArrayInts writes "int" array object value

func (*RequestOperation) WriteOArrayLongs 

func (r *RequestOperation) WriteOArrayLongs(v []int64) error

WriteOArrayLongs writes "long" array object value

func (*RequestOperation) WriteOArrayODates 

func (r *RequestOperation) WriteOArrayODates(v []Date) error

WriteOArrayODates writes "Date" array object value

func (*RequestOperation) WriteOArrayOStrings 

func (r *RequestOperation) WriteOArrayOStrings(v []string) error

WriteOArrayOStrings writes "String" array object value

func (*RequestOperation) WriteOArrayOTimes 

func (r *RequestOperation) WriteOArrayOTimes(v []Time) error

WriteOArrayOTimes writes "Time" array object value

func (*RequestOperation) WriteOArrayOTimestamps 

func (r *RequestOperation) WriteOArrayOTimestamps(v []time.Time) error

WriteOArrayOTimestamps writes "Timestamp" array object value

func (*RequestOperation) WriteOArrayOUUIDs 

func (r *RequestOperation) WriteOArrayOUUIDs(v []uuid.UUID) error

WriteOArrayOUUIDs writes "UUID" array object value

func (*RequestOperation) WriteOArrayShorts 

func (r *RequestOperation) WriteOArrayShorts(v []int16) error

WriteOArrayShorts writes "short" array object value

func (*RequestOperation) WriteOBool 

func (r *RequestOperation) WriteOBool(v bool) error

WriteOBool writes "bool" object value

func (*RequestOperation) WriteOByte 

func (r *RequestOperation) WriteOByte(v byte) error

WriteOByte writes "byte" object value

func (*RequestOperation) WriteOChar 

func (r *RequestOperation) WriteOChar(v Char) error

WriteOChar writes "char" object value

func (*RequestOperation) WriteODate 

func (r *RequestOperation) WriteODate(v Date) error

WriteODate writes "Date" object value

func (*RequestOperation) WriteODouble 

func (r *RequestOperation) WriteODouble(v float64) error

WriteODouble writes "double" object value

func (*RequestOperation) WriteOFloat 

func (r *RequestOperation) WriteOFloat(v float32) error

WriteOFloat writes "float" object value

func (*RequestOperation) WriteOInt 

func (r *RequestOperation) WriteOInt(v int32) error

WriteOInt writes "int" object value

func (*RequestOperation) WriteOLong 

func (r *RequestOperation) WriteOLong(v int64) error

WriteOLong writes "long" object value

func (*RequestOperation) WriteOShort 

func (r *RequestOperation) WriteOShort(v int16) error

WriteOShort writes "short" object value

func (*RequestOperation) WriteOString 

func (r *RequestOperation) WriteOString(v string) error

WriteOString writes "string" object value String is marshalling as object in all cases.

func (*RequestOperation) WriteOTime 

func (r *RequestOperation) WriteOTime(v Time) error

WriteOTime writes "Time" object value Time is marshaled as object in all cases.

func (*RequestOperation) WriteOTimestamp 

func (r *RequestOperation) WriteOTimestamp(v time.Time) error

WriteOTimestamp writes "Timestamp" object value Timestamp is marshaled as object in all cases.

func (*RequestOperation) WriteOUUID 

func (r *RequestOperation) WriteOUUID(v uuid.UUID) error

WriteOUUID writes "UUID" object value UUID is marshaled as object in all cases.

func (*RequestOperation) WriteObject 

func (r *RequestOperation) WriteObject(o interface{}) error

func (*RequestOperation) WriteShort 

func (r *RequestOperation) WriteShort(v int16) error

WriteShort writes "short" value

func (*RequestOperation) WriteTo 

func (r *RequestOperation) WriteTo(w io.Writer) (int64, error)

WriteTo is function to write operation request data to io.Writer. Returns written bytes.

type Response 

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

Response is interface of base message response functionality

type ResponseHandshake 

type ResponseHandshake struct {
	// Success flag
	Success bool
	// Server version major, minor, patch
	Major, Minor, Patch int
	// Error message
	Message string
	// contains filtered or unexported fields
}

ResponseHandshake is struct handshake response

func (*ResponseHandshake) ReadArrayBools 

func (r *ResponseHandshake) ReadArrayBools() ([]bool, error)

ReadArrayBools reads "bool" array value

func (*ResponseHandshake) ReadArrayBytes 

func (r *ResponseHandshake) ReadArrayBytes() ([]byte, error)

ReadArrayBytes reads "byte" array value

func (*ResponseHandshake) ReadArrayChars 

func (r *ResponseHandshake) ReadArrayChars() ([]Char, error)

ReadArrayChars reads "char" array value

func (*ResponseHandshake) ReadArrayDoubles 

func (r *ResponseHandshake) ReadArrayDoubles() ([]float64, error)

ReadArrayDoubles reads "double" array value

func (*ResponseHandshake) ReadArrayFloats 

func (r *ResponseHandshake) ReadArrayFloats() ([]float32, error)

ReadArrayFloats reads "float" array value

func (*ResponseHandshake) ReadArrayInts 

func (r *ResponseHandshake) ReadArrayInts() ([]int32, error)

ReadArrayInts reads "int" array value

func (*ResponseHandshake) ReadArrayLongs 

func (r *ResponseHandshake) ReadArrayLongs() ([]int64, error)

ReadArrayLongs reads "long" array value

func (*ResponseHandshake) ReadArrayODates 

func (r *ResponseHandshake) ReadArrayODates() ([]time.Time, error)

ReadArrayODates reads "Date" array value

func (*ResponseHandshake) ReadArrayOStrings 

func (r *ResponseHandshake) ReadArrayOStrings() ([]string, error)

ReadArrayOStrings reads "String" array value

func (*ResponseHandshake) ReadArrayOTimes 

func (r *ResponseHandshake) ReadArrayOTimes() ([]time.Time, error)

ReadArrayOTimes reads "Time" array value

func (*ResponseHandshake) ReadArrayOTimestamps 

func (r *ResponseHandshake) ReadArrayOTimestamps() ([]time.Time, error)

ReadArrayOTimestamps reads "Timestamp" array value

func (*ResponseHandshake) ReadArrayOUUIDs 

func (r *ResponseHandshake) ReadArrayOUUIDs() ([]uuid.UUID, error)

ReadArrayOUUIDs reads "UUID" array value

func (*ResponseHandshake) ReadArrayShorts 

func (r *ResponseHandshake) ReadArrayShorts() ([]int16, error)

ReadArrayShorts reads "short" array value

func (*ResponseHandshake) ReadBool 

func (r *ResponseHandshake) ReadBool() (bool, error)

ReadBool reads "bool" value

func (*ResponseHandshake) ReadByte 

func (r *ResponseHandshake) ReadByte() (byte, error)

ReadByte reads "byte" value

func (*ResponseHandshake) ReadChar 

func (r *ResponseHandshake) ReadChar() (Char, error)

ReadChar reads "char" value

func (*ResponseHandshake) ReadDate 

func (r *ResponseHandshake) ReadDate() (time.Time, error)

ReadDate reads "Date" object value

func (*ResponseHandshake) ReadDouble 

func (r *ResponseHandshake) ReadDouble() (float64, error)

ReadDouble reads "Double" value

func (*ResponseHandshake) ReadFloat 

func (r *ResponseHandshake) ReadFloat() (float32, error)

ReadFloat reads "float" value

func (*ResponseHandshake) ReadFrom 

func (r *ResponseHandshake) ReadFrom(rr io.Reader) (int64, error)

ReadFrom is function to read request data from io.Reader. Returns read bytes.

func (*ResponseHandshake) ReadInt 

func (r *ResponseHandshake) ReadInt() (int32, error)

ReadInt reads "int" value

func (*ResponseHandshake) ReadLong 

func (r *ResponseHandshake) ReadLong() (int64, error)

ReadLong reads "long" value

func (*ResponseHandshake) ReadOString 

func (r *ResponseHandshake) ReadOString() (string, error)

ReadOString reads "string" object value or NULL (returns "")

func (*ResponseHandshake) ReadObject 

func (r *ResponseHandshake) ReadObject() (interface{}, error)

func (*ResponseHandshake) ReadShort 

func (r *ResponseHandshake) ReadShort() (int16, error)

ReadShort reads "short" value

func (*ResponseHandshake) ReadString 

func (r *ResponseHandshake) ReadString() (string, error)

ReadString reads "string" value

func (*ResponseHandshake) ReadTime 

func (r *ResponseHandshake) ReadTime() (time.Time, error)

ReadTime reads "Time" object value

func (*ResponseHandshake) ReadTimestamp 

func (r *ResponseHandshake) ReadTimestamp() (time.Time, error)

ReadTimestamp reads "Timestamp" object value

func (*ResponseHandshake) ReadUUID 

func (r *ResponseHandshake) ReadUUID() (uuid.UUID, error)

ReadUUID reads "UUID" object value

type ResponseOperation 

type ResponseOperation struct {
	// Request id
	UID int64
	// Status code (0 for success, otherwise error code)
	Status int32
	// Error message (present only when status is not 0)
	Message string
	// contains filtered or unexported fields
}

ResponseOperation is struct operation response

func NewResponseOperation 

func NewResponseOperation(uid int64) *ResponseOperation

NewResponseOperation is ResponseOperation constructor

func (*ResponseOperation) CheckStatus 

func (r *ResponseOperation) CheckStatus() error

CheckStatus checks status of operation execution. Returns: nil in case of success. error object in case of operation failed.

func (*ResponseOperation) ReadArrayBools 

func (r *ResponseOperation) ReadArrayBools() ([]bool, error)

ReadArrayBools reads "bool" array value

func (*ResponseOperation) ReadArrayBytes 

func (r *ResponseOperation) ReadArrayBytes() ([]byte, error)

ReadArrayBytes reads "byte" array value

func (*ResponseOperation) ReadArrayChars 

func (r *ResponseOperation) ReadArrayChars() ([]Char, error)

ReadArrayChars reads "char" array value

func (*ResponseOperation) ReadArrayDoubles 

func (r *ResponseOperation) ReadArrayDoubles() ([]float64, error)

ReadArrayDoubles reads "double" array value

func (*ResponseOperation) ReadArrayFloats 

func (r *ResponseOperation) ReadArrayFloats() ([]float32, error)

ReadArrayFloats reads "float" array value

func (*ResponseOperation) ReadArrayInts 

func (r *ResponseOperation) ReadArrayInts() ([]int32, error)

ReadArrayInts reads "int" array value

func (*ResponseOperation) ReadArrayLongs 

func (r *ResponseOperation) ReadArrayLongs() ([]int64, error)

ReadArrayLongs reads "long" array value

func (*ResponseOperation) ReadArrayODates 

func (r *ResponseOperation) ReadArrayODates() ([]time.Time, error)

ReadArrayODates reads "Date" array value

func (*ResponseOperation) ReadArrayOStrings 

func (r *ResponseOperation) ReadArrayOStrings() ([]string, error)

ReadArrayOStrings reads "String" array value

func (*ResponseOperation) ReadArrayOTimes 

func (r *ResponseOperation) ReadArrayOTimes() ([]time.Time, error)

ReadArrayOTimes reads "Time" array value

func (*ResponseOperation) ReadArrayOTimestamps 

func (r *ResponseOperation) ReadArrayOTimestamps() ([]time.Time, error)

ReadArrayOTimestamps reads "Timestamp" array value

func (*ResponseOperation) ReadArrayOUUIDs 

func (r *ResponseOperation) ReadArrayOUUIDs() ([]uuid.UUID, error)

ReadArrayOUUIDs reads "UUID" array value

func (*ResponseOperation) ReadArrayShorts 

func (r *ResponseOperation) ReadArrayShorts() ([]int16, error)

ReadArrayShorts reads "short" array value

func (*ResponseOperation) ReadBool 

func (r *ResponseOperation) ReadBool() (bool, error)

ReadBool reads "bool" value

func (*ResponseOperation) ReadByte 

func (r *ResponseOperation) ReadByte() (byte, error)

ReadByte reads "byte" value

func (*ResponseOperation) ReadChar 

func (r *ResponseOperation) ReadChar() (Char, error)

ReadChar reads "char" value

func (*ResponseOperation) ReadDate 

func (r *ResponseOperation) ReadDate() (time.Time, error)

ReadDate reads "Date" object value

func (*ResponseOperation) ReadDouble 

func (r *ResponseOperation) ReadDouble() (float64, error)

ReadDouble reads "Double" value

func (*ResponseOperation) ReadFloat 

func (r *ResponseOperation) ReadFloat() (float32, error)

ReadFloat reads "float" value

func (*ResponseOperation) ReadFrom 

func (r *ResponseOperation) ReadFrom(rr io.Reader) (int64, error)

ReadFrom is function to read request data from io.Reader. Returns read bytes.

func (*ResponseOperation) ReadInt 

func (r *ResponseOperation) ReadInt() (int32, error)

ReadInt reads "int" value

func (*ResponseOperation) ReadLong 

func (r *ResponseOperation) ReadLong() (int64, error)

ReadLong reads "long" value

func (*ResponseOperation) ReadOString 

func (r *ResponseOperation) ReadOString() (string, error)

ReadOString reads "string" object value or NULL (returns "")

func (*ResponseOperation) ReadObject 

func (r *ResponseOperation) ReadObject() (interface{}, error)

func (*ResponseOperation) ReadShort 

func (r *ResponseOperation) ReadShort() (int16, error)

ReadShort reads "short" value

func (*ResponseOperation) ReadString 

func (r *ResponseOperation) ReadString() (string, error)

ReadString reads "string" value

func (*ResponseOperation) ReadTime 

func (r *ResponseOperation) ReadTime() (time.Time, error)

ReadTime reads "Time" object value

func (*ResponseOperation) ReadTimestamp 

func (r *ResponseOperation) ReadTimestamp() (time.Time, error)

ReadTimestamp reads "Timestamp" object value

func (*ResponseOperation) ReadUUID 

func (r *ResponseOperation) ReadUUID() (uuid.UUID, error)

ReadUUID reads "UUID" object value

type Time 

type Time int64

Time is Apache Ignite Time type

func ToTime 

func ToTime(t time.Time) Time

ToTime converts Golang time.Time to Apache Ignite Time

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.