-
Notifications
You must be signed in to change notification settings - Fork 83
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
separate types into internal/types package
- Loading branch information
1 parent
7d5e6a0
commit a31d84b
Showing
25 changed files
with
1,682 additions
and
1,598 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,19 @@ | ||
| package decimal | ||
|
|
||
| import "math/big" | ||
|
|
||
| type Decimal struct { | ||
| Bytes [16]byte | ||
| Precision uint32 | ||
| Scale uint32 | ||
| } | ||
|
|
||
| func (d *Decimal) String() string { | ||
| v := FromInt128(d.Bytes, d.Precision, d.Scale) | ||
|
|
||
| return Format(v, d.Precision, d.Scale) | ||
| } | ||
|
|
||
| func (d *Decimal) BigInt() *big.Int { | ||
| return FromInt128(d.Bytes, d.Precision, d.Scale) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,145 @@ | ||
| package scanner | ||
|
|
||
| import ( | ||
| "io" | ||
| "time" | ||
|
|
||
| "github.com/ydb-platform/ydb-go-sdk/v3/internal/decimal" | ||
| "github.com/ydb-platform/ydb-go-sdk/v3/internal/types" | ||
| "github.com/ydb-platform/ydb-go-sdk/v3/internal/value" | ||
| ) | ||
|
|
||
| // RawValue scanning non-primitive yql types or for own implementation scanner native API | ||
| type RawValue interface { | ||
| Path() string | ||
| WritePathTo(w io.Writer) (n int64, err error) | ||
| Type() types.Type | ||
| Bool() (v bool) | ||
| Int8() (v int8) | ||
| Uint8() (v uint8) | ||
| Int16() (v int16) | ||
| Uint16() (v uint16) | ||
| Int32() (v int32) | ||
| Uint32() (v uint32) | ||
| Int64() (v int64) | ||
| Uint64() (v uint64) | ||
| Float() (v float32) | ||
| Double() (v float64) | ||
| Date() (v time.Time) | ||
| Datetime() (v time.Time) | ||
| Timestamp() (v time.Time) | ||
| Interval() (v time.Duration) | ||
| TzDate() (v time.Time) | ||
| TzDatetime() (v time.Time) | ||
| TzTimestamp() (v time.Time) | ||
| String() (v []byte) | ||
| UTF8() (v string) | ||
| YSON() (v []byte) | ||
| JSON() (v []byte) | ||
| UUID() (v [16]byte) | ||
| JSONDocument() (v []byte) | ||
| DyNumber() (v string) | ||
| Value() value.Value | ||
|
|
||
| // Any returns any primitive or optional value. | ||
| // Currently, it may return one of these types: | ||
| // | ||
| // bool | ||
| // int8 | ||
| // uint8 | ||
| // int16 | ||
| // uint16 | ||
| // int32 | ||
| // uint32 | ||
| // int64 | ||
| // uint64 | ||
| // float32 | ||
| // float64 | ||
| // []byte | ||
| // string | ||
| // [16]byte | ||
| // | ||
| Any() interface{} | ||
|
|
||
| // Unwrap unwraps current item under scan interpreting it as Optional<Type> types. | ||
| Unwrap() | ||
| AssertType(t types.Type) bool | ||
| IsNull() bool | ||
| IsOptional() bool | ||
|
|
||
| // ListIn interprets current item under scan as a ydb's list. | ||
| // It returns the size of the nested items. | ||
| // If current item under scan is not a list types, it returns -1. | ||
| ListIn() (size int) | ||
|
|
||
| // ListItem selects current item i-th element as an item to scan. | ||
| // ListIn() must be called before. | ||
| ListItem(i int) | ||
|
|
||
| // ListOut leaves list entered before by ListIn() call. | ||
| ListOut() | ||
|
|
||
| // TupleIn interprets current item under scan as a ydb's tuple. | ||
| // It returns the size of the nested items. | ||
| TupleIn() (size int) | ||
|
|
||
| // TupleItem selects current item i-th element as an item to scan. | ||
| // Note that TupleIn() must be called before. | ||
| // It panics if it is out of bounds. | ||
| TupleItem(i int) | ||
|
|
||
| // TupleOut leaves tuple entered before by TupleIn() call. | ||
| TupleOut() | ||
|
|
||
| // StructIn interprets current item under scan as a ydb's struct. | ||
| // It returns the size of the nested items – the struct fields values. | ||
| // If there is no current item under scan it returns -1. | ||
| StructIn() (size int) | ||
|
|
||
| // StructField selects current item i-th field value as an item to scan. | ||
| // Note that StructIn() must be called before. | ||
| // It panics if i is out of bounds. | ||
| StructField(i int) (name string) | ||
|
|
||
| // StructOut leaves struct entered before by StructIn() call. | ||
| StructOut() | ||
|
|
||
| // DictIn interprets current item under scan as a ydb's dict. | ||
| // It returns the size of the nested items pairs. | ||
| // If there is no current item under scan it returns -1. | ||
| DictIn() (size int) | ||
|
|
||
| // DictKey selects current item i-th pair key as an item to scan. | ||
| // Note that DictIn() must be called before. | ||
| // It panics if i is out of bounds. | ||
| DictKey(i int) | ||
|
|
||
| // DictPayload selects current item i-th pair value as an item to scan. | ||
| // Note that DictIn() must be called before. | ||
| // It panics if i is out of bounds. | ||
| DictPayload(i int) | ||
|
|
||
| // DictOut leaves dict entered before by DictIn() call. | ||
| DictOut() | ||
|
|
||
| // Variant unwraps current item under scan interpreting it as Variant<Type> types. | ||
| // It returns non-empty name of a field that is filled for struct-based | ||
| // variant. | ||
| // It always returns an index of filled field of a Type. | ||
| Variant() (name string, index uint32) | ||
|
|
||
| // Decimal returns decimal value represented by big-endian 128 bit signed integer. | ||
| Decimal(t types.Type) (v [16]byte) | ||
|
|
||
| // UnwrapDecimal returns decimal value represented by big-endian 128 bit signed | ||
| // integer and its types information. | ||
| UnwrapDecimal() decimal.Decimal | ||
| IsDecimal() bool | ||
| Err() error | ||
| } | ||
|
|
||
| // Scanner scanning raw ydb types | ||
| type Scanner interface { | ||
| // UnmarshalYDB must be implemented on client-side for unmarshal raw ydb value. | ||
| UnmarshalYDB(raw RawValue) error | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
Oops, something went wrong.