Documentation ¶
Index ¶
- Constants
- type BlockHeader
- func (s *BlockHeader) BlockSize() BlockSize
- func (s *BlockHeader) Blocks() int64
- func (s *BlockHeader) Bytes() []byte
- func (s *BlockHeader) Clone() *BlockHeader
- func (s *BlockHeader) Completed() int64
- func (s *BlockHeader) Count() uint16
- func (s *BlockHeader) Created() int64
- func (s *BlockHeader) Encoding() Encoding
- func (s *BlockHeader) End() int64
- func (s *BlockHeader) Format() Format
- func (s *BlockHeader) HeadID() int64
- func (s *BlockHeader) HeadMin() int64
- func (s *BlockHeader) HeadStart() int64
- func (s *BlockHeader) Id() int64
- func (s *BlockHeader) Kind() StreamKind
- func (s *BlockHeader) MarshalBinary() ([]byte, error)
- func (s *BlockHeader) MarshalBinaryTo(b []byte) []byte
- func (s *BlockHeader) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *BlockHeader) Max() int64
- func (s *BlockHeader) Min() int64
- func (s *BlockHeader) Mut() *BlockHeaderMut
- func (s *BlockHeader) Read(b []byte) (n int, err error)
- func (s *BlockHeader) ReadFrom(r io.Reader) (int64, error)
- func (s *BlockHeader) Record() uint16
- func (s *BlockHeader) Records() int64
- func (s *BlockHeader) Size() uint16
- func (s *BlockHeader) SizeU() uint16
- func (s *BlockHeader) SizeX() uint16
- func (s *BlockHeader) Start() int64
- func (s *BlockHeader) Storage() uint64
- func (s *BlockHeader) StorageU() uint64
- func (s *BlockHeader) StreamID() int64
- func (s *BlockHeader) String() string
- func (s *BlockHeader) UnmarshalBinary(b []byte) error
- func (s *BlockHeader) WriteTo(w io.Writer) (int64, error)
- type BlockHeaderMut
- func (s *BlockHeaderMut) Clone() *BlockHeaderMut
- func (s *BlockHeaderMut) Freeze() *BlockHeader
- func (s *BlockHeaderMut) SetBlockSize(v BlockSize) *BlockHeaderMut
- func (s *BlockHeaderMut) SetBlocks(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetCompleted(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetCount(v uint16) *BlockHeaderMut
- func (s *BlockHeaderMut) SetCreated(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetEncoding(v Encoding) *BlockHeaderMut
- func (s *BlockHeaderMut) SetEnd(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetFormat(v Format) *BlockHeaderMut
- func (s *BlockHeaderMut) SetHeadID(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetHeadMin(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetHeadStart(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetId(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetKind(v StreamKind) *BlockHeaderMut
- func (s *BlockHeaderMut) SetMax(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetMin(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetRecord(v uint16) *BlockHeaderMut
- func (s *BlockHeaderMut) SetRecords(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetSize(v uint16) *BlockHeaderMut
- func (s *BlockHeaderMut) SetSizeU(v uint16) *BlockHeaderMut
- func (s *BlockHeaderMut) SetSizeX(v uint16) *BlockHeaderMut
- func (s *BlockHeaderMut) SetStart(v int64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetStorage(v uint64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetStorageU(v uint64) *BlockHeaderMut
- func (s *BlockHeaderMut) SetStreamID(v int64) *BlockHeaderMut
- type BlockID
- func (s *BlockID) Bytes() []byte
- func (s *BlockID) Clone() *BlockID
- func (s *BlockID) Id() int64
- func (s *BlockID) MarshalBinary() ([]byte, error)
- func (s *BlockID) MarshalBinaryTo(b []byte) []byte
- func (s *BlockID) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *BlockID) Mut() *BlockIDMut
- func (s *BlockID) Read(b []byte) (n int, err error)
- func (s *BlockID) ReadFrom(r io.Reader) (int64, error)
- func (s *BlockID) StreamID() int64
- func (s *BlockID) String() string
- func (s *BlockID) UnmarshalBinary(b []byte) error
- func (s *BlockID) WriteTo(w io.Writer) (int64, error)
- type BlockIDMut
- type BlockLayout
- type BlockSize
- type EOS
- func (s *EOS) Bytes() []byte
- func (s *EOS) Clone() *EOS
- func (s *EOS) MarshalBinary() ([]byte, error)
- func (s *EOS) MarshalBinaryTo(b []byte) []byte
- func (s *EOS) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *EOS) Mut() *EOSMut
- func (s *EOS) Read(b []byte) (n int, err error)
- func (s *EOS) ReadFrom(r io.Reader) (int64, error)
- func (s *EOS) RecordID() *RecordID
- func (s *EOS) String() string
- func (s *EOS) Timestamp() int64
- func (s *EOS) UnmarshalBinary(b []byte) error
- func (s *EOS) WriteTo(w io.Writer) (int64, error)
- type EOSMut
- type EOSWaiting
- func (s *EOSWaiting) Bytes() []byte
- func (s *EOSWaiting) Clone() *EOSWaiting
- func (s *EOSWaiting) MarshalBinary() ([]byte, error)
- func (s *EOSWaiting) MarshalBinaryTo(b []byte) []byte
- func (s *EOSWaiting) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *EOSWaiting) Mut() *EOSWaitingMut
- func (s *EOSWaiting) Read(b []byte) (n int, err error)
- func (s *EOSWaiting) ReadFrom(r io.Reader) (int64, error)
- func (s *EOSWaiting) RecordID() *RecordID
- func (s *EOSWaiting) String() string
- func (s *EOSWaiting) Timestamp() int64
- func (s *EOSWaiting) UnmarshalBinary(b []byte) error
- func (s *EOSWaiting) WriteTo(w io.Writer) (int64, error)
- type EOSWaitingMut
- type Encoding
- type Enum
- func (s *Enum) Bytes() []byte
- func (s *Enum) Clone() *Enum
- func (s *Enum) MarshalBinary() ([]byte, error)
- func (s *Enum) MarshalBinaryTo(b []byte) []byte
- func (s *Enum) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Enum) Mut() *EnumMut
- func (s *Enum) Name() *String40
- func (s *Enum) Options() *EnumOption16List
- func (s *Enum) Read(b []byte) (n int, err error)
- func (s *Enum) ReadFrom(r io.Reader) (int64, error)
- func (s *Enum) String() string
- func (s *Enum) UnmarshalBinary(b []byte) error
- func (s *Enum) WriteTo(w io.Writer) (int64, error)
- type EnumMut
- type EnumOption
- func (s *EnumOption) Bytes() []byte
- func (s *EnumOption) Clone() *EnumOption
- func (s *EnumOption) Index() int32
- func (s *EnumOption) MarshalBinary() ([]byte, error)
- func (s *EnumOption) MarshalBinaryTo(b []byte) []byte
- func (s *EnumOption) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *EnumOption) Mut() *EnumOptionMut
- func (s *EnumOption) Name() *String64
- func (s *EnumOption) Read(b []byte) (n int, err error)
- func (s *EnumOption) ReadFrom(r io.Reader) (int64, error)
- func (s *EnumOption) String() string
- func (s *EnumOption) UnmarshalBinary(b []byte) error
- func (s *EnumOption) Value() int64
- func (s *EnumOption) ValueStr() *String64
- func (s *EnumOption) WriteTo(w io.Writer) (int64, error)
- type EnumOption16List
- func (s *EnumOption16List) Bytes() []byte
- func (s *EnumOption16List) Cap() int
- func (s *EnumOption16List) CopyTo(v []EnumOption) []EnumOption
- func (s *EnumOption16List) Get(i int) *EnumOption
- func (s *EnumOption16List) Len() int
- func (s *EnumOption16List) MarshalBinary() ([]byte, error)
- func (s *EnumOption16List) MarshalBinaryTo(b []byte) []byte
- func (s *EnumOption16List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
- func (s *EnumOption16List) Mut() *EnumOption16ListMut
- func (s *EnumOption16List) Read(r io.Reader) error
- func (s *EnumOption16List) UnmarshalBinary(b []byte) error
- func (s *EnumOption16List) Unsafe() []EnumOption
- func (s *EnumOption16List) Write(w io.Writer) (n int, err error)
- type EnumOption16ListMut
- type EnumOptionMut
- func (s *EnumOptionMut) Clone() *EnumOptionMut
- func (s *EnumOptionMut) Freeze() *EnumOption
- func (s *EnumOptionMut) Name() *String64Mut
- func (s *EnumOptionMut) SetIndex(v int32) *EnumOptionMut
- func (s *EnumOptionMut) SetName(v *String64) *EnumOptionMut
- func (s *EnumOptionMut) SetValue(v int64) *EnumOptionMut
- func (s *EnumOptionMut) SetValueStr(v *String64) *EnumOptionMut
- func (s *EnumOptionMut) ValueStr() *String64Mut
- type Field
- func (s *Field) Align() uint16
- func (s *Field) Bytes() []byte
- func (s *Field) Clone() *Field
- func (s *Field) Compact() *String8
- func (s *Field) IsOptional() bool
- func (s *Field) IsPointer() bool
- func (s *Field) Kind() Kind
- func (s *Field) MarshalBinary() ([]byte, error)
- func (s *Field) MarshalBinaryTo(b []byte) []byte
- func (s *Field) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Field) Mut() *FieldMut
- func (s *Field) Name() *String40
- func (s *Field) Number() uint16
- func (s *Field) Offset() uint16
- func (s *Field) Read(b []byte) (n int, err error)
- func (s *Field) ReadFrom(r io.Reader) (int64, error)
- func (s *Field) RootOffset() uint16
- func (s *Field) Size() uint16
- func (s *Field) String() string
- func (s *Field) UnmarshalBinary(b []byte) error
- func (s *Field) WriteTo(w io.Writer) (int64, error)
- type Field64List
- func (s *Field64List) Bytes() []byte
- func (s *Field64List) Cap() int
- func (s *Field64List) CopyTo(v []Field) []Field
- func (s *Field64List) Get(i int) *Field
- func (s *Field64List) Len() int
- func (s *Field64List) MarshalBinary() ([]byte, error)
- func (s *Field64List) MarshalBinaryTo(b []byte) []byte
- func (s *Field64List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
- func (s *Field64List) Mut() *Field64ListMut
- func (s *Field64List) Read(r io.Reader) error
- func (s *Field64List) UnmarshalBinary(b []byte) error
- func (s *Field64List) Unsafe() []Field
- func (s *Field64List) Write(w io.Writer) (n int, err error)
- type Field64ListMut
- type FieldMut
- func (s *FieldMut) Clone() *FieldMut
- func (s *FieldMut) Compact() *String8Mut
- func (s *FieldMut) Freeze() *Field
- func (s *FieldMut) Name() *String40Mut
- func (s *FieldMut) SetAlign(v uint16) *FieldMut
- func (s *FieldMut) SetCompact(v *String8) *FieldMut
- func (s *FieldMut) SetIsOptional(v bool) *FieldMut
- func (s *FieldMut) SetIsPointer(v bool) *FieldMut
- func (s *FieldMut) SetKind(v Kind) *FieldMut
- func (s *FieldMut) SetName(v *String40) *FieldMut
- func (s *FieldMut) SetNumber(v uint16) *FieldMut
- func (s *FieldMut) SetOffset(v uint16) *FieldMut
- func (s *FieldMut) SetRootOffset(v uint16) *FieldMut
- func (s *FieldMut) SetSize(v uint16) *FieldMut
- type Format
- type ID
- type Import
- func (s *Import) Alias() *String32
- func (s *Import) Bytes() []byte
- func (s *Import) Clone() *Import
- func (s *Import) Id() int32
- func (s *Import) Line() *Line
- func (s *Import) MarshalBinary() ([]byte, error)
- func (s *Import) MarshalBinaryTo(b []byte) []byte
- func (s *Import) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Import) Mut() *ImportMut
- func (s *Import) Name() *String32
- func (s *Import) Path() *String128
- func (s *Import) Read(b []byte) (n int, err error)
- func (s *Import) ReadFrom(r io.Reader) (int64, error)
- func (s *Import) String() string
- func (s *Import) UnmarshalBinary(b []byte) error
- func (s *Import) WriteTo(w io.Writer) (int64, error)
- type Import16List
- func (s *Import16List) Bytes() []byte
- func (s *Import16List) Cap() int
- func (s *Import16List) CopyTo(v []Import) []Import
- func (s *Import16List) Get(i int) *Import
- func (s *Import16List) Len() int
- func (s *Import16List) MarshalBinary() ([]byte, error)
- func (s *Import16List) MarshalBinaryTo(b []byte) []byte
- func (s *Import16List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
- func (s *Import16List) Mut() *Import16ListMut
- func (s *Import16List) Read(r io.Reader) error
- func (s *Import16List) UnmarshalBinary(b []byte) error
- func (s *Import16List) Unsafe() []Import
- func (s *Import16List) Write(w io.Writer) (n int, err error)
- type Import16ListMut
- type ImportMut
- func (s *ImportMut) Alias() *String32Mut
- func (s *ImportMut) Clone() *ImportMut
- func (s *ImportMut) Freeze() *Import
- func (s *ImportMut) Line() *LineMut
- func (s *ImportMut) Name() *String32Mut
- func (s *ImportMut) Path() *String128Mut
- func (s *ImportMut) SetAlias(v *String32) *ImportMut
- func (s *ImportMut) SetId(v int32) *ImportMut
- func (s *ImportMut) SetLine(v *Line) *ImportMut
- func (s *ImportMut) SetName(v *String32) *ImportMut
- func (s *ImportMut) SetPath(v *String128) *ImportMut
- type Imports
- func (s *Imports) Bytes() []byte
- func (s *Imports) Clone() *Imports
- func (s *Imports) Id() int32
- func (s *Imports) Line() *Line
- func (s *Imports) List() *Import16List
- func (s *Imports) MarshalBinary() ([]byte, error)
- func (s *Imports) MarshalBinaryTo(b []byte) []byte
- func (s *Imports) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Imports) Mut() *ImportsMut
- func (s *Imports) Read(b []byte) (n int, err error)
- func (s *Imports) ReadFrom(r io.Reader) (int64, error)
- func (s *Imports) String() string
- func (s *Imports) UnmarshalBinary(b []byte) error
- func (s *Imports) WriteTo(w io.Writer) (int64, error)
- type Imports16List
- func (s *Imports16List) Bytes() []byte
- func (s *Imports16List) Cap() int
- func (s *Imports16List) CopyTo(v []Imports) []Imports
- func (s *Imports16List) Get(i int) *Imports
- func (s *Imports16List) Len() int
- func (s *Imports16List) MarshalBinary() ([]byte, error)
- func (s *Imports16List) MarshalBinaryTo(b []byte) []byte
- func (s *Imports16List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
- func (s *Imports16List) Mut() *Imports16ListMut
- func (s *Imports16List) Read(r io.Reader) error
- func (s *Imports16List) UnmarshalBinary(b []byte) error
- func (s *Imports16List) Unsafe() []Imports
- func (s *Imports16List) Write(w io.Writer) (n int, err error)
- type Imports16ListMut
- type ImportsMut
- func (s *ImportsMut) Clone() *ImportsMut
- func (s *ImportsMut) Freeze() *Imports
- func (s *ImportsMut) Line() *LineMut
- func (s *ImportsMut) List() *Import16ListMut
- func (s *ImportsMut) SetId(v int32) *ImportsMut
- func (s *ImportsMut) SetLine(v *Line) *ImportsMut
- func (s *ImportsMut) SetList(v *Import16List) *ImportsMut
- type Kind
- type Line
- func (s *Line) Begin() int32
- func (s *Line) Bytes() []byte
- func (s *Line) Clone() *Line
- func (s *Line) End() int32
- func (s *Line) MarshalBinary() ([]byte, error)
- func (s *Line) MarshalBinaryTo(b []byte) []byte
- func (s *Line) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Line) Mut() *LineMut
- func (s *Line) Number() int32
- func (s *Line) Read(b []byte) (n int, err error)
- func (s *Line) ReadFrom(r io.Reader) (int64, error)
- func (s *Line) String() string
- func (s *Line) UnmarshalBinary(b []byte) error
- func (s *Line) WriteTo(w io.Writer) (int64, error)
- type LineMut
- type MessageType
- type Record
- func (s *Record) Bytes() []byte
- func (s *Record) Clone() *Record
- func (s *Record) Fields() *Field64List
- func (s *Record) MarshalBinary() ([]byte, error)
- func (s *Record) MarshalBinaryTo(b []byte) []byte
- func (s *Record) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Record) Mut() *RecordMut
- func (s *Record) Name() *String40
- func (s *Record) Read(b []byte) (n int, err error)
- func (s *Record) ReadFrom(r io.Reader) (int64, error)
- func (s *Record) String() string
- func (s *Record) UnmarshalBinary(b []byte) error
- func (s *Record) WriteTo(w io.Writer) (int64, error)
- type Record128List
- func (s *Record128List) Bytes() []byte
- func (s *Record128List) Cap() int
- func (s *Record128List) CopyTo(v []Record) []Record
- func (s *Record128List) Get(i int) *Record
- func (s *Record128List) Len() int
- func (s *Record128List) MarshalBinary() ([]byte, error)
- func (s *Record128List) MarshalBinaryTo(b []byte) []byte
- func (s *Record128List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
- func (s *Record128List) Mut() *Record128ListMut
- func (s *Record128List) Read(r io.Reader) error
- func (s *Record128List) UnmarshalBinary(b []byte) error
- func (s *Record128List) Unsafe() []Record
- func (s *Record128List) Write(w io.Writer) (n int, err error)
- type Record128ListMut
- type RecordHeader
- func (s *RecordHeader) Bytes() []byte
- func (s *RecordHeader) Clone() *RecordHeader
- func (s *RecordHeader) Encoding() Encoding
- func (s *RecordHeader) End() int64
- func (s *RecordHeader) Id() *RecordID
- func (s *RecordHeader) MarshalBinary() ([]byte, error)
- func (s *RecordHeader) MarshalBinaryTo(b []byte) []byte
- func (s *RecordHeader) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *RecordHeader) Mut() *RecordHeaderMut
- func (s *RecordHeader) Pad() bool
- func (s *RecordHeader) PrevID() int64
- func (s *RecordHeader) Read(b []byte) (n int, err error)
- func (s *RecordHeader) ReadFrom(r io.Reader) (int64, error)
- func (s *RecordHeader) Seq() uint16
- func (s *RecordHeader) Size() uint16
- func (s *RecordHeader) SizeU() uint16
- func (s *RecordHeader) Start() int64
- func (s *RecordHeader) String() string
- func (s *RecordHeader) Timestamp() int64
- func (s *RecordHeader) UnmarshalBinary(b []byte) error
- func (s *RecordHeader) WriteTo(w io.Writer) (int64, error)
- type RecordHeaderMut
- func (s *RecordHeaderMut) Clone() *RecordHeaderMut
- func (s *RecordHeaderMut) Freeze() *RecordHeader
- func (s *RecordHeaderMut) Id() *RecordIDMut
- func (s *RecordHeaderMut) SetEncoding(v Encoding) *RecordHeaderMut
- func (s *RecordHeaderMut) SetEnd(v int64) *RecordHeaderMut
- func (s *RecordHeaderMut) SetId(v *RecordID) *RecordHeaderMut
- func (s *RecordHeaderMut) SetPad(v bool) *RecordHeaderMut
- func (s *RecordHeaderMut) SetPrevID(v int64) *RecordHeaderMut
- func (s *RecordHeaderMut) SetSeq(v uint16) *RecordHeaderMut
- func (s *RecordHeaderMut) SetSize(v uint16) *RecordHeaderMut
- func (s *RecordHeaderMut) SetSizeU(v uint16) *RecordHeaderMut
- func (s *RecordHeaderMut) SetStart(v int64) *RecordHeaderMut
- func (s *RecordHeaderMut) SetTimestamp(v int64) *RecordHeaderMut
- type RecordID
- func (s *RecordID) BlockID() int64
- func (s *RecordID) Bytes() []byte
- func (s *RecordID) Clone() *RecordID
- func (s *RecordID) Id() int64
- func (s *RecordID) MarshalBinary() ([]byte, error)
- func (s *RecordID) MarshalBinaryTo(b []byte) []byte
- func (s *RecordID) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *RecordID) Mut() *RecordIDMut
- func (s *RecordID) Read(b []byte) (n int, err error)
- func (s *RecordID) ReadFrom(r io.Reader) (int64, error)
- func (s *RecordID) StreamID() int64
- func (s *RecordID) String() string
- func (s *RecordID) UnmarshalBinary(b []byte) error
- func (s *RecordID) WriteTo(w io.Writer) (int64, error)
- type RecordIDMut
- type RecordLayout
- type RecordMut
- type RecordsHeader
- func (s *RecordsHeader) Bytes() []byte
- func (s *RecordsHeader) Clone() *RecordsHeader
- func (s *RecordsHeader) Count() uint16
- func (s *RecordsHeader) Header() *RecordHeader
- func (s *RecordsHeader) MarshalBinary() ([]byte, error)
- func (s *RecordsHeader) MarshalBinaryTo(b []byte) []byte
- func (s *RecordsHeader) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *RecordsHeader) Mut() *RecordsHeaderMut
- func (s *RecordsHeader) Read(b []byte) (n int, err error)
- func (s *RecordsHeader) ReadFrom(r io.Reader) (int64, error)
- func (s *RecordsHeader) Record() uint16
- func (s *RecordsHeader) String() string
- func (s *RecordsHeader) UnmarshalBinary(b []byte) error
- func (s *RecordsHeader) WriteTo(w io.Writer) (int64, error)
- type RecordsHeaderMut
- func (s *RecordsHeaderMut) Clone() *RecordsHeaderMut
- func (s *RecordsHeaderMut) Freeze() *RecordsHeader
- func (s *RecordsHeaderMut) Header() *RecordHeaderMut
- func (s *RecordsHeaderMut) SetCount(v uint16) *RecordsHeaderMut
- func (s *RecordsHeaderMut) SetHeader(v *RecordHeader) *RecordsHeaderMut
- func (s *RecordsHeaderMut) SetRecord(v uint16) *RecordsHeaderMut
- type SEnum
- type SEnumOption
- type SField
- type SRecord
- type SSchema
- type SStruct
- type SUnion
- type SUnionOption
- type Savepoint
- func (s *Savepoint) Bytes() []byte
- func (s *Savepoint) Clone() *Savepoint
- func (s *Savepoint) Duration() int64
- func (s *Savepoint) MarshalBinary() ([]byte, error)
- func (s *Savepoint) MarshalBinaryTo(b []byte) []byte
- func (s *Savepoint) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Savepoint) Mut() *SavepointMut
- func (s *Savepoint) Read(b []byte) (n int, err error)
- func (s *Savepoint) ReadFrom(r io.Reader) (int64, error)
- func (s *Savepoint) RecordID() *RecordID
- func (s *Savepoint) String() string
- func (s *Savepoint) Timestamp() int64
- func (s *Savepoint) UnmarshalBinary(b []byte) error
- func (s *Savepoint) WriteTo(w io.Writer) (int64, error)
- type SavepointMut
- func (s *SavepointMut) Clone() *SavepointMut
- func (s *SavepointMut) Freeze() *Savepoint
- func (s *SavepointMut) RecordID() *RecordIDMut
- func (s *SavepointMut) SetDuration(v int64) *SavepointMut
- func (s *SavepointMut) SetRecordID(v *RecordID) *SavepointMut
- func (s *SavepointMut) SetTimestamp(v int64) *SavepointMut
- type Schema
- func (s *Schema) Bytes() []byte
- func (s *Schema) Clone() *Schema
- func (s *Schema) Imports() *Imports16List
- func (s *Schema) MarshalBinary() ([]byte, error)
- func (s *Schema) MarshalBinaryTo(b []byte) []byte
- func (s *Schema) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Schema) Mut() *SchemaMut
- func (s *Schema) Read(b []byte) (n int, err error)
- func (s *Schema) ReadFrom(r io.Reader) (int64, error)
- func (s *Schema) Records() *Record128List
- func (s *Schema) String() string
- func (s *Schema) UnmarshalBinary(b []byte) error
- func (s *Schema) WriteTo(w io.Writer) (int64, error)
- type SchemaMut
- type Started
- func (s *Started) Bytes() []byte
- func (s *Started) Clone() *Started
- func (s *Started) MarshalBinary() ([]byte, error)
- func (s *Started) MarshalBinaryTo(b []byte) []byte
- func (s *Started) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Started) Mut() *StartedMut
- func (s *Started) Read(b []byte) (n int, err error)
- func (s *Started) ReadFrom(r io.Reader) (int64, error)
- func (s *Started) RecordID() *RecordID
- func (s *Started) Stops() int64
- func (s *Started) String() string
- func (s *Started) Timestamp() int64
- func (s *Started) UnmarshalBinary(b []byte) error
- func (s *Started) WriteTo(w io.Writer) (int64, error)
- func (s *Started) WriterID() int64
- type StartedMut
- func (s *StartedMut) Clone() *StartedMut
- func (s *StartedMut) Freeze() *Started
- func (s *StartedMut) RecordID() *RecordIDMut
- func (s *StartedMut) SetRecordID(v *RecordID) *StartedMut
- func (s *StartedMut) SetStops(v int64) *StartedMut
- func (s *StartedMut) SetTimestamp(v int64) *StartedMut
- func (s *StartedMut) SetWriterID(v int64) *StartedMut
- type Starting
- func (s *Starting) Bytes() []byte
- func (s *Starting) Clone() *Starting
- func (s *Starting) MarshalBinary() ([]byte, error)
- func (s *Starting) MarshalBinaryTo(b []byte) []byte
- func (s *Starting) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Starting) Mut() *StartingMut
- func (s *Starting) Read(b []byte) (n int, err error)
- func (s *Starting) ReadFrom(r io.Reader) (int64, error)
- func (s *Starting) RecordID() *RecordID
- func (s *Starting) String() string
- func (s *Starting) Timestamp() int64
- func (s *Starting) UnmarshalBinary(b []byte) error
- func (s *Starting) WriteTo(w io.Writer) (int64, error)
- func (s *Starting) WriterID() int64
- type StartingMut
- func (s *StartingMut) Clone() *StartingMut
- func (s *StartingMut) Freeze() *Starting
- func (s *StartingMut) RecordID() *RecordIDMut
- func (s *StartingMut) SetRecordID(v *RecordID) *StartingMut
- func (s *StartingMut) SetTimestamp(v int64) *StartingMut
- func (s *StartingMut) SetWriterID(v int64) *StartingMut
- type StopReason
- type Stopped
- func (s *Stopped) Bytes() []byte
- func (s *Stopped) Clone() *Stopped
- func (s *Stopped) MarshalBinary() ([]byte, error)
- func (s *Stopped) MarshalBinaryTo(b []byte) []byte
- func (s *Stopped) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Stopped) Mut() *StoppedMut
- func (s *Stopped) Read(b []byte) (n int, err error)
- func (s *Stopped) ReadFrom(r io.Reader) (int64, error)
- func (s *Stopped) Reason() StopReason
- func (s *Stopped) RecordID() *RecordID
- func (s *Stopped) Starts() int64
- func (s *Stopped) String() string
- func (s *Stopped) Timestamp() int64
- func (s *Stopped) UnmarshalBinary(b []byte) error
- func (s *Stopped) WriteTo(w io.Writer) (int64, error)
- type StoppedMut
- func (s *StoppedMut) Clone() *StoppedMut
- func (s *StoppedMut) Freeze() *Stopped
- func (s *StoppedMut) RecordID() *RecordIDMut
- func (s *StoppedMut) SetReason(v StopReason) *StoppedMut
- func (s *StoppedMut) SetRecordID(v *RecordID) *StoppedMut
- func (s *StoppedMut) SetStarts(v int64) *StoppedMut
- func (s *StoppedMut) SetTimestamp(v int64) *StoppedMut
- type Stream
- func (s *Stream) AccountID() int64
- func (s *Stream) BlockSize() BlockSize
- func (s *Stream) Bytes() []byte
- func (s *Stream) Clone() *Stream
- func (s *Stream) Created() int64
- func (s *Stream) Duration() int64
- func (s *Stream) Format() Format
- func (s *Stream) Id() int64
- func (s *Stream) Kind() StreamKind
- func (s *Stream) MarshalBinary() ([]byte, error)
- func (s *Stream) MarshalBinaryTo(b []byte) []byte
- func (s *Stream) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Stream) Mut() *StreamMut
- func (s *Stream) Name() *String32
- func (s *Stream) Read(b []byte) (n int, err error)
- func (s *Stream) ReadFrom(r io.Reader) (int64, error)
- func (s *Stream) Record() uint16
- func (s *Stream) String() string
- func (s *Stream) UnmarshalBinary(b []byte) error
- func (s *Stream) WriteTo(w io.Writer) (int64, error)
- type StreamKind
- type StreamMut
- func (s *StreamMut) Clone() *StreamMut
- func (s *StreamMut) Freeze() *Stream
- func (s *StreamMut) Name() *String32Mut
- func (s *StreamMut) SetAccountID(v int64) *StreamMut
- func (s *StreamMut) SetBlockSize(v BlockSize) *StreamMut
- func (s *StreamMut) SetCreated(v int64) *StreamMut
- func (s *StreamMut) SetDuration(v int64) *StreamMut
- func (s *StreamMut) SetFormat(v Format) *StreamMut
- func (s *StreamMut) SetId(v int64) *StreamMut
- func (s *StreamMut) SetKind(v StreamKind) *StreamMut
- func (s *StreamMut) SetName(v *String32) *StreamMut
- func (s *StreamMut) SetRecord(v uint16) *StreamMut
- type String128
- func (s *String128) Bytes() []byte
- func (s *String128) Cap() int
- func (s *String128) Clone() *String128
- func (s *String128) Len() int
- func (s *String128) MarshalBinary() ([]byte, error)
- func (s *String128) MarshalBinaryTo(b []byte) []byte
- func (s *String128) Mut() *String128Mut
- func (s *String128) ReadFrom(r io.Reader) error
- func (s *String128) String() string
- func (s *String128) StringClone() string
- func (s *String128) UnmarshalBinary(b []byte) error
- func (s *String128) WriteTo(w io.Writer) (n int, err error)
- type String128Mut
- type String32
- func (s *String32) Bytes() []byte
- func (s *String32) Cap() int
- func (s *String32) Clone() *String32
- func (s *String32) Len() int
- func (s *String32) MarshalBinary() ([]byte, error)
- func (s *String32) MarshalBinaryTo(b []byte) []byte
- func (s *String32) Mut() *String32Mut
- func (s *String32) ReadFrom(r io.Reader) error
- func (s *String32) String() string
- func (s *String32) StringClone() string
- func (s *String32) UnmarshalBinary(b []byte) error
- func (s *String32) WriteTo(w io.Writer) (n int, err error)
- type String32Mut
- type String40
- func (s *String40) Bytes() []byte
- func (s *String40) Cap() int
- func (s *String40) Clone() *String40
- func (s *String40) Len() int
- func (s *String40) MarshalBinary() ([]byte, error)
- func (s *String40) MarshalBinaryTo(b []byte) []byte
- func (s *String40) Mut() *String40Mut
- func (s *String40) ReadFrom(r io.Reader) error
- func (s *String40) String() string
- func (s *String40) StringClone() string
- func (s *String40) UnmarshalBinary(b []byte) error
- func (s *String40) WriteTo(w io.Writer) (n int, err error)
- type String40Mut
- type String64
- func (s *String64) Bytes() []byte
- func (s *String64) Cap() int
- func (s *String64) Clone() *String64
- func (s *String64) Len() int
- func (s *String64) MarshalBinary() ([]byte, error)
- func (s *String64) MarshalBinaryTo(b []byte) []byte
- func (s *String64) Mut() *String64Mut
- func (s *String64) ReadFrom(r io.Reader) error
- func (s *String64) String() string
- func (s *String64) StringClone() string
- func (s *String64) UnmarshalBinary(b []byte) error
- func (s *String64) WriteTo(w io.Writer) (n int, err error)
- type String64Mut
- type String8
- func (s *String8) Bytes() []byte
- func (s *String8) Cap() int
- func (s *String8) Clone() *String8
- func (s *String8) Len() int
- func (s *String8) MarshalBinary() ([]byte, error)
- func (s *String8) MarshalBinaryTo(b []byte) []byte
- func (s *String8) Mut() *String8Mut
- func (s *String8) ReadFrom(r io.Reader) error
- func (s *String8) String() string
- func (s *String8) StringClone() string
- func (s *String8) UnmarshalBinary(b []byte) error
- func (s *String8) WriteTo(w io.Writer) (n int, err error)
- type String8Mut
- type Struct
- func (s *Struct) Bytes() []byte
- func (s *Struct) Clone() *Struct
- func (s *Struct) Fields() *Field64List
- func (s *Struct) MarshalBinary() ([]byte, error)
- func (s *Struct) MarshalBinaryTo(b []byte) []byte
- func (s *Struct) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Struct) Mut() *StructMut
- func (s *Struct) Name() *String40
- func (s *Struct) Read(b []byte) (n int, err error)
- func (s *Struct) ReadFrom(r io.Reader) (int64, error)
- func (s *Struct) String() string
- func (s *Struct) UnmarshalBinary(b []byte) error
- func (s *Struct) WriteTo(w io.Writer) (int64, error)
- type StructMut
- type SyncProgress
- func (s *SyncProgress) Bytes() []byte
- func (s *SyncProgress) Clone() *SyncProgress
- func (s *SyncProgress) Count() int64
- func (s *SyncProgress) MarshalBinary() ([]byte, error)
- func (s *SyncProgress) MarshalBinaryTo(b []byte) []byte
- func (s *SyncProgress) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *SyncProgress) Mut() *SyncProgressMut
- func (s *SyncProgress) Read(b []byte) (n int, err error)
- func (s *SyncProgress) ReadFrom(r io.Reader) (int64, error)
- func (s *SyncProgress) RecordID() *RecordID
- func (s *SyncProgress) Remaining() int64
- func (s *SyncProgress) Started() int64
- func (s *SyncProgress) String() string
- func (s *SyncProgress) Timestamp() int64
- func (s *SyncProgress) UnmarshalBinary(b []byte) error
- func (s *SyncProgress) WriteTo(w io.Writer) (int64, error)
- type SyncProgressMut
- func (s *SyncProgressMut) Clone() *SyncProgressMut
- func (s *SyncProgressMut) Freeze() *SyncProgress
- func (s *SyncProgressMut) RecordID() *RecordIDMut
- func (s *SyncProgressMut) SetCount(v int64) *SyncProgressMut
- func (s *SyncProgressMut) SetRecordID(v *RecordID) *SyncProgressMut
- func (s *SyncProgressMut) SetRemaining(v int64) *SyncProgressMut
- func (s *SyncProgressMut) SetStarted(v int64) *SyncProgressMut
- func (s *SyncProgressMut) SetTimestamp(v int64) *SyncProgressMut
- type SyncStarted
- func (s *SyncStarted) Bytes() []byte
- func (s *SyncStarted) Clone() *SyncStarted
- func (s *SyncStarted) MarshalBinary() ([]byte, error)
- func (s *SyncStarted) MarshalBinaryTo(b []byte) []byte
- func (s *SyncStarted) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *SyncStarted) Mut() *SyncStartedMut
- func (s *SyncStarted) Read(b []byte) (n int, err error)
- func (s *SyncStarted) ReadFrom(r io.Reader) (int64, error)
- func (s *SyncStarted) RecordID() *RecordID
- func (s *SyncStarted) String() string
- func (s *SyncStarted) Timestamp() int64
- func (s *SyncStarted) UnmarshalBinary(b []byte) error
- func (s *SyncStarted) WriteTo(w io.Writer) (int64, error)
- type SyncStartedMut
- type SyncStopped
- func (s *SyncStopped) Bytes() []byte
- func (s *SyncStopped) Clone() *SyncStopped
- func (s *SyncStopped) MarshalBinary() ([]byte, error)
- func (s *SyncStopped) MarshalBinaryTo(b []byte) []byte
- func (s *SyncStopped) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *SyncStopped) Message() *String64
- func (s *SyncStopped) Mut() *SyncStoppedMut
- func (s *SyncStopped) Progress() *SyncProgress
- func (s *SyncStopped) Read(b []byte) (n int, err error)
- func (s *SyncStopped) ReadFrom(r io.Reader) (int64, error)
- func (s *SyncStopped) Reason() SyncStoppedReason
- func (s *SyncStopped) String() string
- func (s *SyncStopped) UnmarshalBinary(b []byte) error
- func (s *SyncStopped) WriteTo(w io.Writer) (int64, error)
- type SyncStoppedMut
- func (s *SyncStoppedMut) Clone() *SyncStoppedMut
- func (s *SyncStoppedMut) Freeze() *SyncStopped
- func (s *SyncStoppedMut) Message() *String64Mut
- func (s *SyncStoppedMut) Progress() *SyncProgressMut
- func (s *SyncStoppedMut) SetMessage(v *String64) *SyncStoppedMut
- func (s *SyncStoppedMut) SetProgress(v *SyncProgress) *SyncStoppedMut
- func (s *SyncStoppedMut) SetReason(v SyncStoppedReason) *SyncStoppedMut
- type SyncStoppedReason
- type Union
- func (s *Union) Bytes() []byte
- func (s *Union) Clone() *Union
- func (s *Union) MarshalBinary() ([]byte, error)
- func (s *Union) MarshalBinaryTo(b []byte) []byte
- func (s *Union) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *Union) Mut() *UnionMut
- func (s *Union) Name() *String40
- func (s *Union) Options() *UnionOption16List
- func (s *Union) Read(b []byte) (n int, err error)
- func (s *Union) ReadFrom(r io.Reader) (int64, error)
- func (s *Union) String() string
- func (s *Union) UnmarshalBinary(b []byte) error
- func (s *Union) WriteTo(w io.Writer) (int64, error)
- type UnionMut
- type UnionOption
- func (s *UnionOption) Bytes() []byte
- func (s *UnionOption) Clone() *UnionOption
- func (s *UnionOption) Id() *String40
- func (s *UnionOption) Kind() Kind
- func (s *UnionOption) MarshalBinary() ([]byte, error)
- func (s *UnionOption) MarshalBinaryTo(b []byte) []byte
- func (s *UnionOption) MarshalMap(m map[string]interface{}) map[string]interface{}
- func (s *UnionOption) Mut() *UnionOptionMut
- func (s *UnionOption) Name() *String40
- func (s *UnionOption) Read(b []byte) (n int, err error)
- func (s *UnionOption) ReadFrom(r io.Reader) (int64, error)
- func (s *UnionOption) String() string
- func (s *UnionOption) UnmarshalBinary(b []byte) error
- func (s *UnionOption) WriteTo(w io.Writer) (int64, error)
- type UnionOption16List
- func (s *UnionOption16List) Bytes() []byte
- func (s *UnionOption16List) Cap() int
- func (s *UnionOption16List) CopyTo(v []UnionOption) []UnionOption
- func (s *UnionOption16List) Get(i int) *UnionOption
- func (s *UnionOption16List) Len() int
- func (s *UnionOption16List) MarshalBinary() ([]byte, error)
- func (s *UnionOption16List) MarshalBinaryTo(b []byte) []byte
- func (s *UnionOption16List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
- func (s *UnionOption16List) Mut() *UnionOption16ListMut
- func (s *UnionOption16List) Read(r io.Reader) error
- func (s *UnionOption16List) UnmarshalBinary(b []byte) error
- func (s *UnionOption16List) Unsafe() []UnionOption
- func (s *UnionOption16List) Write(w io.Writer) (n int, err error)
- type UnionOption16ListMut
- type UnionOptionMut
- func (s *UnionOptionMut) Clone() *UnionOptionMut
- func (s *UnionOptionMut) Freeze() *UnionOption
- func (s *UnionOptionMut) Id() *String40Mut
- func (s *UnionOptionMut) Name() *String40Mut
- func (s *UnionOptionMut) SetId(v *String40) *UnionOptionMut
- func (s *UnionOptionMut) SetKind(v Kind) *UnionOptionMut
- func (s *UnionOptionMut) SetName(v *String40) *UnionOptionMut
Constants ¶
const ( RecordLayout_Aligned = RecordLayout(0) RecordLayout_Compact = RecordLayout(1) )
const ( BlockLayout_Row = BlockLayout(1) BlockLayout_Column = BlockLayout(2) )
const ( Format_Raw = Format(0) Format_WAP = Format(1) Format_Json = Format(2) Format_Protobuf = Format(3) )
const ( StreamKind_Log = StreamKind(0) StreamKind_Series = StreamKind(1) StreamKind_Table = StreamKind(2) )
const ( Kind_Unknown = Kind(0) Kind_Bool = Kind(1) Kind_Byte = Kind(2) Kind_Int8 = Kind(3) Kind_UInt8 = Kind(4) Kind_Int16 = Kind(5) Kind_UInt16 = Kind(6) Kind_Int32 = Kind(7) Kind_UInt32 = Kind(8) Kind_Int64 = Kind(9) Kind_UInt64 = Kind(10) Kind_Float32 = Kind(11) Kind_Float64 = Kind(12) Kind_String = Kind(13) Kind_Bytes = Kind(14) Kind_RecordHeader = Kind(20) Kind_BlockHeader = Kind(21) Kind_Enum = Kind(30) Kind_Record = Kind(40) Kind_Struct = Kind(41) Kind_List = Kind(50) Kind_LinkedList = Kind(51) Kind_Map = Kind(52) Kind_LinkedMap = Kind(53) )
const ( SyncStoppedReason_Success = SyncStoppedReason(1) SyncStoppedReason_Error = SyncStoppedReason(2) )
const ( BlockSize_B1kb = BlockSize(1024) BlockSize_B2kb = BlockSize(2048) BlockSize_B4kb = BlockSize(4096) BlockSize_B8kb = BlockSize(8192) BlockSize_B16kb = BlockSize(16384) BlockSize_B32kb = BlockSize(32768) BlockSize_B64kb = BlockSize(65535) )
const ( MessageType_Record = MessageType(1) MessageType_Records = MessageType(2) MessageType_Block = MessageType(3) MessageType_EOS = MessageType(4) MessageType_EOSWaiting = MessageType(5) MessageType_Savepoint = MessageType(6) MessageType_Starting = MessageType(7) MessageType_Started = MessageType(8) MessageType_Stopped = MessageType(9) MessageType_SyncStarted = MessageType(10) MessageType_SyncProgress = MessageType(11) MessageType_SyncStopped = MessageType(12) )
const ( // Stream is composed from another stream or external datasource and it stopped StopReason_Source = StopReason(1) // Stream has been paused StopReason_Paused = StopReason(2) // Stream is being migrated to a new writer StopReason_Migrate = StopReason(3) // Stream has stopped unexpectedly StopReason_Unexpected = StopReason(4) )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type BlockHeader ¶
type BlockHeader struct {
// contains filtered or unexported fields
}
BlockHeader
func (*BlockHeader) BlockSize ¶
func (s *BlockHeader) BlockSize() BlockSize
func (*BlockHeader) Blocks ¶
func (s *BlockHeader) Blocks() int64
func (*BlockHeader) Bytes ¶
func (s *BlockHeader) Bytes() []byte
func (*BlockHeader) Clone ¶
func (s *BlockHeader) Clone() *BlockHeader
func (*BlockHeader) Completed ¶
func (s *BlockHeader) Completed() int64
func (*BlockHeader) Count ¶
func (s *BlockHeader) Count() uint16
func (*BlockHeader) Created ¶
func (s *BlockHeader) Created() int64
func (*BlockHeader) Encoding ¶
func (s *BlockHeader) Encoding() Encoding
func (*BlockHeader) End ¶
func (s *BlockHeader) End() int64
func (*BlockHeader) Format ¶
func (s *BlockHeader) Format() Format
func (*BlockHeader) HeadID ¶
func (s *BlockHeader) HeadID() int64
func (*BlockHeader) HeadMin ¶
func (s *BlockHeader) HeadMin() int64
func (*BlockHeader) HeadStart ¶
func (s *BlockHeader) HeadStart() int64
func (*BlockHeader) Id ¶
func (s *BlockHeader) Id() int64
func (*BlockHeader) Kind ¶
func (s *BlockHeader) Kind() StreamKind
func (*BlockHeader) MarshalBinary ¶
func (s *BlockHeader) MarshalBinary() ([]byte, error)
func (*BlockHeader) MarshalBinaryTo ¶
func (s *BlockHeader) MarshalBinaryTo(b []byte) []byte
func (*BlockHeader) MarshalMap ¶
func (s *BlockHeader) MarshalMap(m map[string]interface{}) map[string]interface{}
func (*BlockHeader) Max ¶
func (s *BlockHeader) Max() int64
func (*BlockHeader) Min ¶
func (s *BlockHeader) Min() int64
func (*BlockHeader) Mut ¶
func (s *BlockHeader) Mut() *BlockHeaderMut
func (*BlockHeader) Record ¶
func (s *BlockHeader) Record() uint16
func (*BlockHeader) Records ¶
func (s *BlockHeader) Records() int64
func (*BlockHeader) Size ¶
func (s *BlockHeader) Size() uint16
func (*BlockHeader) SizeU ¶
func (s *BlockHeader) SizeU() uint16
func (*BlockHeader) SizeX ¶
func (s *BlockHeader) SizeX() uint16
func (*BlockHeader) Start ¶
func (s *BlockHeader) Start() int64
func (*BlockHeader) Storage ¶
func (s *BlockHeader) Storage() uint64
func (*BlockHeader) StorageU ¶
func (s *BlockHeader) StorageU() uint64
func (*BlockHeader) StreamID ¶
func (s *BlockHeader) StreamID() int64
func (*BlockHeader) String ¶
func (s *BlockHeader) String() string
func (*BlockHeader) UnmarshalBinary ¶
func (s *BlockHeader) UnmarshalBinary(b []byte) error
type BlockHeaderMut ¶
type BlockHeaderMut struct {
BlockHeader
}
BlockHeader
func (*BlockHeaderMut) Clone ¶
func (s *BlockHeaderMut) Clone() *BlockHeaderMut
func (*BlockHeaderMut) Freeze ¶
func (s *BlockHeaderMut) Freeze() *BlockHeader
func (*BlockHeaderMut) SetBlockSize ¶
func (s *BlockHeaderMut) SetBlockSize(v BlockSize) *BlockHeaderMut
func (*BlockHeaderMut) SetBlocks ¶
func (s *BlockHeaderMut) SetBlocks(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetCompleted ¶
func (s *BlockHeaderMut) SetCompleted(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetCount ¶
func (s *BlockHeaderMut) SetCount(v uint16) *BlockHeaderMut
func (*BlockHeaderMut) SetCreated ¶
func (s *BlockHeaderMut) SetCreated(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetEncoding ¶
func (s *BlockHeaderMut) SetEncoding(v Encoding) *BlockHeaderMut
func (*BlockHeaderMut) SetEnd ¶
func (s *BlockHeaderMut) SetEnd(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetFormat ¶
func (s *BlockHeaderMut) SetFormat(v Format) *BlockHeaderMut
func (*BlockHeaderMut) SetHeadID ¶
func (s *BlockHeaderMut) SetHeadID(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetHeadMin ¶
func (s *BlockHeaderMut) SetHeadMin(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetHeadStart ¶
func (s *BlockHeaderMut) SetHeadStart(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetId ¶
func (s *BlockHeaderMut) SetId(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetKind ¶
func (s *BlockHeaderMut) SetKind(v StreamKind) *BlockHeaderMut
func (*BlockHeaderMut) SetMax ¶
func (s *BlockHeaderMut) SetMax(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetMin ¶
func (s *BlockHeaderMut) SetMin(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetRecord ¶
func (s *BlockHeaderMut) SetRecord(v uint16) *BlockHeaderMut
func (*BlockHeaderMut) SetRecords ¶
func (s *BlockHeaderMut) SetRecords(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetSize ¶
func (s *BlockHeaderMut) SetSize(v uint16) *BlockHeaderMut
func (*BlockHeaderMut) SetSizeU ¶
func (s *BlockHeaderMut) SetSizeU(v uint16) *BlockHeaderMut
func (*BlockHeaderMut) SetSizeX ¶
func (s *BlockHeaderMut) SetSizeX(v uint16) *BlockHeaderMut
func (*BlockHeaderMut) SetStart ¶
func (s *BlockHeaderMut) SetStart(v int64) *BlockHeaderMut
func (*BlockHeaderMut) SetStorage ¶
func (s *BlockHeaderMut) SetStorage(v uint64) *BlockHeaderMut
func (*BlockHeaderMut) SetStorageU ¶
func (s *BlockHeaderMut) SetStorageU(v uint64) *BlockHeaderMut
func (*BlockHeaderMut) SetStreamID ¶
func (s *BlockHeaderMut) SetStreamID(v int64) *BlockHeaderMut
type BlockID ¶
type BlockID struct {
// contains filtered or unexported fields
}
BlockID represents a globally unique ID of a single page of a single stream. String representation
func (*BlockID) MarshalBinary ¶
func (*BlockID) MarshalBinaryTo ¶
func (*BlockID) MarshalMap ¶
func (*BlockID) Mut ¶
func (s *BlockID) Mut() *BlockIDMut
func (*BlockID) UnmarshalBinary ¶
type BlockIDMut ¶
type BlockIDMut struct {
BlockID
}
BlockID represents a globally unique ID of a single page of a single stream. String representation
func (*BlockIDMut) Clone ¶
func (s *BlockIDMut) Clone() *BlockIDMut
func (*BlockIDMut) Freeze ¶
func (s *BlockIDMut) Freeze() *BlockID
func (*BlockIDMut) SetId ¶
func (s *BlockIDMut) SetId(v int64) *BlockIDMut
func (*BlockIDMut) SetStreamID ¶
func (s *BlockIDMut) SetStreamID(v int64) *BlockIDMut
type BlockLayout ¶
type BlockLayout byte
type EOS ¶
type EOS struct {
// contains filtered or unexported fields
}
EOS = End of Stream The reader is caught up on the stream and is NOT subscribed to new records.
func (*EOS) MarshalBinary ¶
func (*EOS) MarshalBinaryTo ¶
func (*EOS) MarshalMap ¶
func (*EOS) UnmarshalBinary ¶
type EOSMut ¶
type EOSMut struct {
EOS
}
EOS = End of Stream The reader is caught up on the stream and is NOT subscribed to new records.
func (*EOSMut) RecordID ¶
func (s *EOSMut) RecordID() *RecordIDMut
func (*EOSMut) SetRecordID ¶
func (*EOSMut) SetTimestamp ¶
type EOSWaiting ¶
type EOSWaiting struct {
// contains filtered or unexported fields
}
EOSWaiting = End of Stream Waiting for next record. The reader is caught up on the stream and is subscribed to new records.
func (*EOSWaiting) Bytes ¶
func (s *EOSWaiting) Bytes() []byte
func (*EOSWaiting) Clone ¶
func (s *EOSWaiting) Clone() *EOSWaiting
func (*EOSWaiting) MarshalBinary ¶
func (s *EOSWaiting) MarshalBinary() ([]byte, error)
func (*EOSWaiting) MarshalBinaryTo ¶
func (s *EOSWaiting) MarshalBinaryTo(b []byte) []byte
func (*EOSWaiting) MarshalMap ¶
func (s *EOSWaiting) MarshalMap(m map[string]interface{}) map[string]interface{}
func (*EOSWaiting) Mut ¶
func (s *EOSWaiting) Mut() *EOSWaitingMut
func (*EOSWaiting) RecordID ¶
func (s *EOSWaiting) RecordID() *RecordID
func (*EOSWaiting) String ¶
func (s *EOSWaiting) String() string
func (*EOSWaiting) Timestamp ¶
func (s *EOSWaiting) Timestamp() int64
func (*EOSWaiting) UnmarshalBinary ¶
func (s *EOSWaiting) UnmarshalBinary(b []byte) error
type EOSWaitingMut ¶
type EOSWaitingMut struct {
EOSWaiting
}
EOSWaiting = End of Stream Waiting for next record. The reader is caught up on the stream and is subscribed to new records.
func (*EOSWaitingMut) Clone ¶
func (s *EOSWaitingMut) Clone() *EOSWaitingMut
func (*EOSWaitingMut) Freeze ¶
func (s *EOSWaitingMut) Freeze() *EOSWaiting
func (*EOSWaitingMut) RecordID ¶
func (s *EOSWaitingMut) RecordID() *RecordIDMut
func (*EOSWaitingMut) SetRecordID ¶
func (s *EOSWaitingMut) SetRecordID(v *RecordID) *EOSWaitingMut
func (*EOSWaitingMut) SetTimestamp ¶
func (s *EOSWaitingMut) SetTimestamp(v int64) *EOSWaitingMut
type Enum ¶
type Enum struct {
// contains filtered or unexported fields
}
func (*Enum) MarshalBinary ¶
func (*Enum) MarshalBinaryTo ¶
func (*Enum) MarshalMap ¶
func (*Enum) Options ¶
func (s *Enum) Options() *EnumOption16List
func (*Enum) UnmarshalBinary ¶
type EnumMut ¶
type EnumMut struct {
Enum
}
func (*EnumMut) Name ¶
func (s *EnumMut) Name() *String40Mut
func (*EnumMut) Options ¶
func (s *EnumMut) Options() *EnumOption16ListMut
func (*EnumMut) SetOptions ¶
func (s *EnumMut) SetOptions(v *EnumOption16List) *EnumMut
type EnumOption ¶
type EnumOption struct {
// contains filtered or unexported fields
}
func (*EnumOption) Bytes ¶
func (s *EnumOption) Bytes() []byte
func (*EnumOption) Clone ¶
func (s *EnumOption) Clone() *EnumOption
func (*EnumOption) Index ¶
func (s *EnumOption) Index() int32
func (*EnumOption) MarshalBinary ¶
func (s *EnumOption) MarshalBinary() ([]byte, error)
func (*EnumOption) MarshalBinaryTo ¶
func (s *EnumOption) MarshalBinaryTo(b []byte) []byte
func (*EnumOption) MarshalMap ¶
func (s *EnumOption) MarshalMap(m map[string]interface{}) map[string]interface{}
func (*EnumOption) Mut ¶
func (s *EnumOption) Mut() *EnumOptionMut
func (*EnumOption) Name ¶
func (s *EnumOption) Name() *String64
func (*EnumOption) String ¶
func (s *EnumOption) String() string
func (*EnumOption) UnmarshalBinary ¶
func (s *EnumOption) UnmarshalBinary(b []byte) error
func (*EnumOption) Value ¶
func (s *EnumOption) Value() int64
func (*EnumOption) ValueStr ¶
func (s *EnumOption) ValueStr() *String64
type EnumOption16List ¶
type EnumOption16List struct {
// contains filtered or unexported fields
}
func (*EnumOption16List) Bytes ¶
func (s *EnumOption16List) Bytes() []byte
func (*EnumOption16List) Cap ¶
func (s *EnumOption16List) Cap() int
func (*EnumOption16List) CopyTo ¶
func (s *EnumOption16List) CopyTo(v []EnumOption) []EnumOption
func (*EnumOption16List) Get ¶
func (s *EnumOption16List) Get(i int) *EnumOption
func (*EnumOption16List) Len ¶
func (s *EnumOption16List) Len() int
func (*EnumOption16List) MarshalBinary ¶
func (s *EnumOption16List) MarshalBinary() ([]byte, error)
func (*EnumOption16List) MarshalBinaryTo ¶
func (s *EnumOption16List) MarshalBinaryTo(b []byte) []byte
func (*EnumOption16List) MarshalMap ¶
func (s *EnumOption16List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
func (*EnumOption16List) Mut ¶
func (s *EnumOption16List) Mut() *EnumOption16ListMut
func (*EnumOption16List) UnmarshalBinary ¶
func (s *EnumOption16List) UnmarshalBinary(b []byte) error
func (*EnumOption16List) Unsafe ¶
func (s *EnumOption16List) Unsafe() []EnumOption
type EnumOption16ListMut ¶
type EnumOption16ListMut struct {
EnumOption16List
}
func (*EnumOption16ListMut) Clear ¶
func (s *EnumOption16ListMut) Clear()
func (*EnumOption16ListMut) Pop ¶
func (s *EnumOption16ListMut) Pop(v *EnumOption) bool
Removes the last item
func (*EnumOption16ListMut) Push ¶
func (s *EnumOption16ListMut) Push(v *EnumOption) bool
func (*EnumOption16ListMut) Shift ¶
func (s *EnumOption16ListMut) Shift(v *EnumOption) bool
Removes the first item
type EnumOptionMut ¶
type EnumOptionMut struct {
EnumOption
}
func (*EnumOptionMut) Clone ¶
func (s *EnumOptionMut) Clone() *EnumOptionMut
func (*EnumOptionMut) Freeze ¶
func (s *EnumOptionMut) Freeze() *EnumOption
func (*EnumOptionMut) Name ¶
func (s *EnumOptionMut) Name() *String64Mut
func (*EnumOptionMut) SetIndex ¶
func (s *EnumOptionMut) SetIndex(v int32) *EnumOptionMut
func (*EnumOptionMut) SetName ¶
func (s *EnumOptionMut) SetName(v *String64) *EnumOptionMut
func (*EnumOptionMut) SetValue ¶
func (s *EnumOptionMut) SetValue(v int64) *EnumOptionMut
func (*EnumOptionMut) SetValueStr ¶
func (s *EnumOptionMut) SetValueStr(v *String64) *EnumOptionMut
func (*EnumOptionMut) ValueStr ¶
func (s *EnumOptionMut) ValueStr() *String64Mut
type Field ¶
type Field struct {
// contains filtered or unexported fields
}
func (*Field) IsOptional ¶
func (*Field) MarshalBinary ¶
func (*Field) MarshalBinaryTo ¶
func (*Field) MarshalMap ¶
func (*Field) RootOffset ¶
func (*Field) UnmarshalBinary ¶
type Field64List ¶
type Field64List struct {
// contains filtered or unexported fields
}
func (*Field64List) Bytes ¶
func (s *Field64List) Bytes() []byte
func (*Field64List) Cap ¶
func (s *Field64List) Cap() int
func (*Field64List) CopyTo ¶
func (s *Field64List) CopyTo(v []Field) []Field
func (*Field64List) Get ¶
func (s *Field64List) Get(i int) *Field
func (*Field64List) Len ¶
func (s *Field64List) Len() int
func (*Field64List) MarshalBinary ¶
func (s *Field64List) MarshalBinary() ([]byte, error)
func (*Field64List) MarshalBinaryTo ¶
func (s *Field64List) MarshalBinaryTo(b []byte) []byte
func (*Field64List) MarshalMap ¶
func (s *Field64List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
func (*Field64List) Mut ¶
func (s *Field64List) Mut() *Field64ListMut
func (*Field64List) UnmarshalBinary ¶
func (s *Field64List) UnmarshalBinary(b []byte) error
func (*Field64List) Unsafe ¶
func (s *Field64List) Unsafe() []Field
type Field64ListMut ¶
type Field64ListMut struct {
Field64List
}
func (*Field64ListMut) Clear ¶
func (s *Field64ListMut) Clear()
func (*Field64ListMut) Push ¶
func (s *Field64ListMut) Push(v *Field) bool
type FieldMut ¶
type FieldMut struct {
Field
}
func (*FieldMut) Compact ¶
func (s *FieldMut) Compact() *String8Mut
func (*FieldMut) Name ¶
func (s *FieldMut) Name() *String40Mut
func (*FieldMut) SetCompact ¶
func (*FieldMut) SetIsOptional ¶
func (*FieldMut) SetIsPointer ¶
func (*FieldMut) SetRootOffset ¶
type Import ¶
type Import struct {
// contains filtered or unexported fields
}
func (*Import) MarshalBinary ¶
func (*Import) MarshalBinaryTo ¶
func (*Import) MarshalMap ¶
func (*Import) UnmarshalBinary ¶
type Import16List ¶
type Import16List struct {
// contains filtered or unexported fields
}
func (*Import16List) Bytes ¶
func (s *Import16List) Bytes() []byte
func (*Import16List) Cap ¶
func (s *Import16List) Cap() int
func (*Import16List) CopyTo ¶
func (s *Import16List) CopyTo(v []Import) []Import
func (*Import16List) Get ¶
func (s *Import16List) Get(i int) *Import
func (*Import16List) Len ¶
func (s *Import16List) Len() int
func (*Import16List) MarshalBinary ¶
func (s *Import16List) MarshalBinary() ([]byte, error)
func (*Import16List) MarshalBinaryTo ¶
func (s *Import16List) MarshalBinaryTo(b []byte) []byte
func (*Import16List) MarshalMap ¶
func (s *Import16List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
func (*Import16List) Mut ¶
func (s *Import16List) Mut() *Import16ListMut
func (*Import16List) UnmarshalBinary ¶
func (s *Import16List) UnmarshalBinary(b []byte) error
func (*Import16List) Unsafe ¶
func (s *Import16List) Unsafe() []Import
type Import16ListMut ¶
type Import16ListMut struct {
Import16List
}
func (*Import16ListMut) Clear ¶
func (s *Import16ListMut) Clear()
func (*Import16ListMut) Push ¶
func (s *Import16ListMut) Push(v *Import) bool
func (*Import16ListMut) Shift ¶
func (s *Import16ListMut) Shift(v *Import) bool
Removes the first item
type ImportMut ¶
type ImportMut struct {
Import
}
func (*ImportMut) Alias ¶
func (s *ImportMut) Alias() *String32Mut
func (*ImportMut) Name ¶
func (s *ImportMut) Name() *String32Mut
func (*ImportMut) Path ¶
func (s *ImportMut) Path() *String128Mut
type Imports ¶
type Imports struct {
// contains filtered or unexported fields
}
func (*Imports) List ¶
func (s *Imports) List() *Import16List
func (*Imports) MarshalBinary ¶
func (*Imports) MarshalBinaryTo ¶
func (*Imports) MarshalMap ¶
func (*Imports) Mut ¶
func (s *Imports) Mut() *ImportsMut
func (*Imports) UnmarshalBinary ¶
type Imports16List ¶
type Imports16List struct {
// contains filtered or unexported fields
}
func (*Imports16List) Bytes ¶
func (s *Imports16List) Bytes() []byte
func (*Imports16List) Cap ¶
func (s *Imports16List) Cap() int
func (*Imports16List) CopyTo ¶
func (s *Imports16List) CopyTo(v []Imports) []Imports
func (*Imports16List) Get ¶
func (s *Imports16List) Get(i int) *Imports
func (*Imports16List) Len ¶
func (s *Imports16List) Len() int
func (*Imports16List) MarshalBinary ¶
func (s *Imports16List) MarshalBinary() ([]byte, error)
func (*Imports16List) MarshalBinaryTo ¶
func (s *Imports16List) MarshalBinaryTo(b []byte) []byte
func (*Imports16List) MarshalMap ¶
func (s *Imports16List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
func (*Imports16List) Mut ¶
func (s *Imports16List) Mut() *Imports16ListMut
func (*Imports16List) UnmarshalBinary ¶
func (s *Imports16List) UnmarshalBinary(b []byte) error
func (*Imports16List) Unsafe ¶
func (s *Imports16List) Unsafe() []Imports
type Imports16ListMut ¶
type Imports16ListMut struct {
Imports16List
}
func (*Imports16ListMut) Clear ¶
func (s *Imports16ListMut) Clear()
func (*Imports16ListMut) Pop ¶
func (s *Imports16ListMut) Pop(v *Imports) bool
Removes the last item
func (*Imports16ListMut) Push ¶
func (s *Imports16ListMut) Push(v *Imports) bool
func (*Imports16ListMut) Shift ¶
func (s *Imports16ListMut) Shift(v *Imports) bool
Removes the first item
type ImportsMut ¶
type ImportsMut struct {
Imports
}
func (*ImportsMut) Clone ¶
func (s *ImportsMut) Clone() *ImportsMut
func (*ImportsMut) Freeze ¶
func (s *ImportsMut) Freeze() *Imports
func (*ImportsMut) Line ¶
func (s *ImportsMut) Line() *LineMut
func (*ImportsMut) List ¶
func (s *ImportsMut) List() *Import16ListMut
func (*ImportsMut) SetId ¶
func (s *ImportsMut) SetId(v int32) *ImportsMut
func (*ImportsMut) SetLine ¶
func (s *ImportsMut) SetLine(v *Line) *ImportsMut
func (*ImportsMut) SetList ¶
func (s *ImportsMut) SetList(v *Import16List) *ImportsMut
type Line ¶
type Line struct {
// contains filtered or unexported fields
}
func (*Line) MarshalBinary ¶
func (*Line) MarshalBinaryTo ¶
func (*Line) MarshalMap ¶
func (*Line) UnmarshalBinary ¶
type MessageType ¶
type MessageType byte
type Record ¶
type Record struct {
// contains filtered or unexported fields
}
func (*Record) Fields ¶
func (s *Record) Fields() *Field64List
func (*Record) MarshalBinary ¶
func (*Record) MarshalBinaryTo ¶
func (*Record) MarshalMap ¶
func (*Record) UnmarshalBinary ¶
type Record128List ¶
type Record128List struct {
// contains filtered or unexported fields
}
func (*Record128List) Bytes ¶
func (s *Record128List) Bytes() []byte
func (*Record128List) Cap ¶
func (s *Record128List) Cap() int
func (*Record128List) CopyTo ¶
func (s *Record128List) CopyTo(v []Record) []Record
func (*Record128List) Get ¶
func (s *Record128List) Get(i int) *Record
func (*Record128List) Len ¶
func (s *Record128List) Len() int
func (*Record128List) MarshalBinary ¶
func (s *Record128List) MarshalBinary() ([]byte, error)
func (*Record128List) MarshalBinaryTo ¶
func (s *Record128List) MarshalBinaryTo(b []byte) []byte
func (*Record128List) MarshalMap ¶
func (s *Record128List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
func (*Record128List) Mut ¶
func (s *Record128List) Mut() *Record128ListMut
func (*Record128List) UnmarshalBinary ¶
func (s *Record128List) UnmarshalBinary(b []byte) error
func (*Record128List) Unsafe ¶
func (s *Record128List) Unsafe() []Record
type Record128ListMut ¶
type Record128ListMut struct {
Record128List
}
func (*Record128ListMut) Clear ¶
func (s *Record128ListMut) Clear()
func (*Record128ListMut) Push ¶
func (s *Record128ListMut) Push(v *Record) bool
func (*Record128ListMut) Shift ¶
func (s *Record128ListMut) Shift(v *Record) bool
Removes the first item
type RecordHeader ¶
type RecordHeader struct {
// contains filtered or unexported fields
}
func (*RecordHeader) Bytes ¶
func (s *RecordHeader) Bytes() []byte
func (*RecordHeader) Clone ¶
func (s *RecordHeader) Clone() *RecordHeader
func (*RecordHeader) Encoding ¶
func (s *RecordHeader) Encoding() Encoding
func (*RecordHeader) End ¶
func (s *RecordHeader) End() int64
func (*RecordHeader) Id ¶
func (s *RecordHeader) Id() *RecordID
func (*RecordHeader) MarshalBinary ¶
func (s *RecordHeader) MarshalBinary() ([]byte, error)
func (*RecordHeader) MarshalBinaryTo ¶
func (s *RecordHeader) MarshalBinaryTo(b []byte) []byte
func (*RecordHeader) MarshalMap ¶
func (s *RecordHeader) MarshalMap(m map[string]interface{}) map[string]interface{}
func (*RecordHeader) Mut ¶
func (s *RecordHeader) Mut() *RecordHeaderMut
func (*RecordHeader) Pad ¶
func (s *RecordHeader) Pad() bool
func (*RecordHeader) PrevID ¶
func (s *RecordHeader) PrevID() int64
func (*RecordHeader) Seq ¶
func (s *RecordHeader) Seq() uint16
func (*RecordHeader) Size ¶
func (s *RecordHeader) Size() uint16
func (*RecordHeader) SizeU ¶
func (s *RecordHeader) SizeU() uint16
func (*RecordHeader) Start ¶
func (s *RecordHeader) Start() int64
func (*RecordHeader) String ¶
func (s *RecordHeader) String() string
func (*RecordHeader) Timestamp ¶
func (s *RecordHeader) Timestamp() int64
func (*RecordHeader) UnmarshalBinary ¶
func (s *RecordHeader) UnmarshalBinary(b []byte) error
type RecordHeaderMut ¶
type RecordHeaderMut struct {
RecordHeader
}
func (*RecordHeaderMut) Clone ¶
func (s *RecordHeaderMut) Clone() *RecordHeaderMut
func (*RecordHeaderMut) Freeze ¶
func (s *RecordHeaderMut) Freeze() *RecordHeader
func (*RecordHeaderMut) Id ¶
func (s *RecordHeaderMut) Id() *RecordIDMut
func (*RecordHeaderMut) SetEncoding ¶
func (s *RecordHeaderMut) SetEncoding(v Encoding) *RecordHeaderMut
func (*RecordHeaderMut) SetEnd ¶
func (s *RecordHeaderMut) SetEnd(v int64) *RecordHeaderMut
func (*RecordHeaderMut) SetId ¶
func (s *RecordHeaderMut) SetId(v *RecordID) *RecordHeaderMut
func (*RecordHeaderMut) SetPad ¶
func (s *RecordHeaderMut) SetPad(v bool) *RecordHeaderMut
func (*RecordHeaderMut) SetPrevID ¶
func (s *RecordHeaderMut) SetPrevID(v int64) *RecordHeaderMut
func (*RecordHeaderMut) SetSeq ¶
func (s *RecordHeaderMut) SetSeq(v uint16) *RecordHeaderMut
func (*RecordHeaderMut) SetSize ¶
func (s *RecordHeaderMut) SetSize(v uint16) *RecordHeaderMut
func (*RecordHeaderMut) SetSizeU ¶
func (s *RecordHeaderMut) SetSizeU(v uint16) *RecordHeaderMut
func (*RecordHeaderMut) SetStart ¶
func (s *RecordHeaderMut) SetStart(v int64) *RecordHeaderMut
func (*RecordHeaderMut) SetTimestamp ¶
func (s *RecordHeaderMut) SetTimestamp(v int64) *RecordHeaderMut
type RecordID ¶
type RecordID struct {
// contains filtered or unexported fields
}
func (*RecordID) MarshalBinary ¶
func (*RecordID) MarshalBinaryTo ¶
func (*RecordID) MarshalMap ¶
func (*RecordID) Mut ¶
func (s *RecordID) Mut() *RecordIDMut
func (*RecordID) UnmarshalBinary ¶
type RecordIDMut ¶
type RecordIDMut struct {
RecordID
}
func (*RecordIDMut) Clone ¶
func (s *RecordIDMut) Clone() *RecordIDMut
func (*RecordIDMut) Freeze ¶
func (s *RecordIDMut) Freeze() *RecordID
func (*RecordIDMut) SetBlockID ¶
func (s *RecordIDMut) SetBlockID(v int64) *RecordIDMut
func (*RecordIDMut) SetId ¶
func (s *RecordIDMut) SetId(v int64) *RecordIDMut
func (*RecordIDMut) SetStreamID ¶
func (s *RecordIDMut) SetStreamID(v int64) *RecordIDMut
type RecordLayout ¶
type RecordLayout byte
type RecordMut ¶
type RecordMut struct {
Record
}
func (*RecordMut) Fields ¶
func (s *RecordMut) Fields() *Field64ListMut
func (*RecordMut) Name ¶
func (s *RecordMut) Name() *String40Mut
func (*RecordMut) SetFields ¶
func (s *RecordMut) SetFields(v *Field64List) *RecordMut
type RecordsHeader ¶
type RecordsHeader struct {
// contains filtered or unexported fields
}
func (*RecordsHeader) Bytes ¶
func (s *RecordsHeader) Bytes() []byte
func (*RecordsHeader) Clone ¶
func (s *RecordsHeader) Clone() *RecordsHeader
func (*RecordsHeader) Count ¶
func (s *RecordsHeader) Count() uint16
func (*RecordsHeader) Header ¶
func (s *RecordsHeader) Header() *RecordHeader
func (*RecordsHeader) MarshalBinary ¶
func (s *RecordsHeader) MarshalBinary() ([]byte, error)
func (*RecordsHeader) MarshalBinaryTo ¶
func (s *RecordsHeader) MarshalBinaryTo(b []byte) []byte
func (*RecordsHeader) MarshalMap ¶
func (s *RecordsHeader) MarshalMap(m map[string]interface{}) map[string]interface{}
func (*RecordsHeader) Mut ¶
func (s *RecordsHeader) Mut() *RecordsHeaderMut
func (*RecordsHeader) Record ¶
func (s *RecordsHeader) Record() uint16
func (*RecordsHeader) String ¶
func (s *RecordsHeader) String() string
func (*RecordsHeader) UnmarshalBinary ¶
func (s *RecordsHeader) UnmarshalBinary(b []byte) error
type RecordsHeaderMut ¶
type RecordsHeaderMut struct {
RecordsHeader
}
func (*RecordsHeaderMut) Clone ¶
func (s *RecordsHeaderMut) Clone() *RecordsHeaderMut
func (*RecordsHeaderMut) Freeze ¶
func (s *RecordsHeaderMut) Freeze() *RecordsHeader
func (*RecordsHeaderMut) Header ¶
func (s *RecordsHeaderMut) Header() *RecordHeaderMut
func (*RecordsHeaderMut) SetCount ¶
func (s *RecordsHeaderMut) SetCount(v uint16) *RecordsHeaderMut
func (*RecordsHeaderMut) SetHeader ¶
func (s *RecordsHeaderMut) SetHeader(v *RecordHeader) *RecordsHeaderMut
func (*RecordsHeaderMut) SetRecord ¶
func (s *RecordsHeaderMut) SetRecord(v uint16) *RecordsHeaderMut
type SEnum ¶
type SEnum struct { Enum Options []SEnumOption }
type SEnumOption ¶
type SEnumOption struct{}
type SUnion ¶
type SUnion struct { Union Options []UnionOption }
type SUnionOption ¶
type SUnionOption struct {
UnionOption
}
type Savepoint ¶
type Savepoint struct {
// contains filtered or unexported fields
}
func (*Savepoint) MarshalBinary ¶
func (*Savepoint) MarshalBinaryTo ¶
func (*Savepoint) MarshalMap ¶
func (*Savepoint) Mut ¶
func (s *Savepoint) Mut() *SavepointMut
func (*Savepoint) UnmarshalBinary ¶
type SavepointMut ¶
type SavepointMut struct {
Savepoint
}
func (*SavepointMut) Clone ¶
func (s *SavepointMut) Clone() *SavepointMut
func (*SavepointMut) Freeze ¶
func (s *SavepointMut) Freeze() *Savepoint
func (*SavepointMut) RecordID ¶
func (s *SavepointMut) RecordID() *RecordIDMut
func (*SavepointMut) SetDuration ¶
func (s *SavepointMut) SetDuration(v int64) *SavepointMut
func (*SavepointMut) SetRecordID ¶
func (s *SavepointMut) SetRecordID(v *RecordID) *SavepointMut
func (*SavepointMut) SetTimestamp ¶
func (s *SavepointMut) SetTimestamp(v int64) *SavepointMut
type Schema ¶
type Schema struct {
// contains filtered or unexported fields
}
func (*Schema) Imports ¶
func (s *Schema) Imports() *Imports16List
func (*Schema) MarshalBinary ¶
func (*Schema) MarshalBinaryTo ¶
func (*Schema) MarshalMap ¶
func (*Schema) Records ¶
func (s *Schema) Records() *Record128List
func (*Schema) UnmarshalBinary ¶
type SchemaMut ¶
type SchemaMut struct {
Schema
}
func (*SchemaMut) Imports ¶
func (s *SchemaMut) Imports() *Imports16ListMut
func (*SchemaMut) Records ¶
func (s *SchemaMut) Records() *Record128ListMut
func (*SchemaMut) SetImports ¶
func (s *SchemaMut) SetImports(v *Imports16List) *SchemaMut
func (*SchemaMut) SetRecords ¶
func (s *SchemaMut) SetRecords(v *Record128List) *SchemaMut
type Started ¶
type Started struct {
// contains filtered or unexported fields
}
func (*Started) MarshalBinary ¶
func (*Started) MarshalBinaryTo ¶
func (*Started) MarshalMap ¶
func (*Started) Mut ¶
func (s *Started) Mut() *StartedMut
func (*Started) UnmarshalBinary ¶
type StartedMut ¶
type StartedMut struct {
Started
}
func (*StartedMut) Clone ¶
func (s *StartedMut) Clone() *StartedMut
func (*StartedMut) Freeze ¶
func (s *StartedMut) Freeze() *Started
func (*StartedMut) RecordID ¶
func (s *StartedMut) RecordID() *RecordIDMut
func (*StartedMut) SetRecordID ¶
func (s *StartedMut) SetRecordID(v *RecordID) *StartedMut
func (*StartedMut) SetStops ¶
func (s *StartedMut) SetStops(v int64) *StartedMut
func (*StartedMut) SetTimestamp ¶
func (s *StartedMut) SetTimestamp(v int64) *StartedMut
func (*StartedMut) SetWriterID ¶
func (s *StartedMut) SetWriterID(v int64) *StartedMut
type Starting ¶
type Starting struct {
// contains filtered or unexported fields
}
func (*Starting) MarshalBinary ¶
func (*Starting) MarshalBinaryTo ¶
func (*Starting) MarshalMap ¶
func (*Starting) Mut ¶
func (s *Starting) Mut() *StartingMut
func (*Starting) UnmarshalBinary ¶
type StartingMut ¶
type StartingMut struct {
Starting
}
func (*StartingMut) Clone ¶
func (s *StartingMut) Clone() *StartingMut
func (*StartingMut) Freeze ¶
func (s *StartingMut) Freeze() *Starting
func (*StartingMut) RecordID ¶
func (s *StartingMut) RecordID() *RecordIDMut
func (*StartingMut) SetRecordID ¶
func (s *StartingMut) SetRecordID(v *RecordID) *StartingMut
func (*StartingMut) SetTimestamp ¶
func (s *StartingMut) SetTimestamp(v int64) *StartingMut
func (*StartingMut) SetWriterID ¶
func (s *StartingMut) SetWriterID(v int64) *StartingMut
type StopReason ¶
type StopReason byte
type Stopped ¶
type Stopped struct {
// contains filtered or unexported fields
}
func (*Stopped) MarshalBinary ¶
func (*Stopped) MarshalBinaryTo ¶
func (*Stopped) MarshalMap ¶
func (*Stopped) Mut ¶
func (s *Stopped) Mut() *StoppedMut
func (*Stopped) Reason ¶
func (s *Stopped) Reason() StopReason
func (*Stopped) UnmarshalBinary ¶
type StoppedMut ¶
type StoppedMut struct {
Stopped
}
func (*StoppedMut) Clone ¶
func (s *StoppedMut) Clone() *StoppedMut
func (*StoppedMut) Freeze ¶
func (s *StoppedMut) Freeze() *Stopped
func (*StoppedMut) RecordID ¶
func (s *StoppedMut) RecordID() *RecordIDMut
func (*StoppedMut) SetReason ¶
func (s *StoppedMut) SetReason(v StopReason) *StoppedMut
func (*StoppedMut) SetRecordID ¶
func (s *StoppedMut) SetRecordID(v *RecordID) *StoppedMut
func (*StoppedMut) SetStarts ¶
func (s *StoppedMut) SetStarts(v int64) *StoppedMut
func (*StoppedMut) SetTimestamp ¶
func (s *StoppedMut) SetTimestamp(v int64) *StoppedMut
type Stream ¶
type Stream struct {
// contains filtered or unexported fields
}
func (*Stream) Kind ¶
func (s *Stream) Kind() StreamKind
func (*Stream) MarshalBinary ¶
func (*Stream) MarshalBinaryTo ¶
func (*Stream) MarshalMap ¶
func (*Stream) UnmarshalBinary ¶
type StreamKind ¶
type StreamKind byte
type StreamMut ¶
type StreamMut struct {
Stream
}
func (*StreamMut) Name ¶
func (s *StreamMut) Name() *String32Mut
func (*StreamMut) SetAccountID ¶
func (*StreamMut) SetBlockSize ¶
func (*StreamMut) SetCreated ¶
func (*StreamMut) SetDuration ¶
func (*StreamMut) SetKind ¶
func (s *StreamMut) SetKind(v StreamKind) *StreamMut
type String128 ¶
type String128 [128]byte
func NewString128 ¶
func (*String128) MarshalBinary ¶
func (*String128) MarshalBinaryTo ¶
func (*String128) Mut ¶
func (s *String128) Mut() *String128Mut
func (*String128) StringClone ¶
func (*String128) UnmarshalBinary ¶
type String128Mut ¶
type String128Mut struct {
String128
}
func (*String128Mut) Set ¶
func (s *String128Mut) Set(v string)
type String32 ¶
type String32 [32]byte
func NewString32 ¶
func (*String32) MarshalBinary ¶
func (*String32) MarshalBinaryTo ¶
func (*String32) Mut ¶
func (s *String32) Mut() *String32Mut
func (*String32) StringClone ¶
func (*String32) UnmarshalBinary ¶
type String32Mut ¶
type String32Mut struct {
String32
}
func (*String32Mut) Set ¶
func (s *String32Mut) Set(v string)
type String40 ¶
type String40 [40]byte
func NewString40 ¶
func (*String40) MarshalBinary ¶
func (*String40) MarshalBinaryTo ¶
func (*String40) Mut ¶
func (s *String40) Mut() *String40Mut
func (*String40) StringClone ¶
func (*String40) UnmarshalBinary ¶
type String40Mut ¶
type String40Mut struct {
String40
}
func (*String40Mut) Set ¶
func (s *String40Mut) Set(v string)
type String64 ¶
type String64 [64]byte
func NewString64 ¶
func (*String64) MarshalBinary ¶
func (*String64) MarshalBinaryTo ¶
func (*String64) Mut ¶
func (s *String64) Mut() *String64Mut
func (*String64) StringClone ¶
func (*String64) UnmarshalBinary ¶
type String64Mut ¶
type String64Mut struct {
String64
}
func (*String64Mut) Set ¶
func (s *String64Mut) Set(v string)
type String8 ¶
type String8 [8]byte
func NewString8 ¶
func (*String8) MarshalBinary ¶
func (*String8) MarshalBinaryTo ¶
func (*String8) Mut ¶
func (s *String8) Mut() *String8Mut
func (*String8) StringClone ¶
func (*String8) UnmarshalBinary ¶
type String8Mut ¶
type String8Mut struct {
String8
}
func (*String8Mut) Set ¶
func (s *String8Mut) Set(v string)
type Struct ¶
type Struct struct {
// contains filtered or unexported fields
}
func (*Struct) Fields ¶
func (s *Struct) Fields() *Field64List
func (*Struct) MarshalBinary ¶
func (*Struct) MarshalBinaryTo ¶
func (*Struct) MarshalMap ¶
func (*Struct) UnmarshalBinary ¶
type StructMut ¶
type StructMut struct {
Struct
}
func (*StructMut) Fields ¶
func (s *StructMut) Fields() *Field64ListMut
func (*StructMut) Name ¶
func (s *StructMut) Name() *String40Mut
func (*StructMut) SetFields ¶
func (s *StructMut) SetFields(v *Field64List) *StructMut
type SyncProgress ¶
type SyncProgress struct {
// contains filtered or unexported fields
}
func (*SyncProgress) Bytes ¶
func (s *SyncProgress) Bytes() []byte
func (*SyncProgress) Clone ¶
func (s *SyncProgress) Clone() *SyncProgress
func (*SyncProgress) Count ¶
func (s *SyncProgress) Count() int64
func (*SyncProgress) MarshalBinary ¶
func (s *SyncProgress) MarshalBinary() ([]byte, error)
func (*SyncProgress) MarshalBinaryTo ¶
func (s *SyncProgress) MarshalBinaryTo(b []byte) []byte
func (*SyncProgress) MarshalMap ¶
func (s *SyncProgress) MarshalMap(m map[string]interface{}) map[string]interface{}
func (*SyncProgress) Mut ¶
func (s *SyncProgress) Mut() *SyncProgressMut
func (*SyncProgress) RecordID ¶
func (s *SyncProgress) RecordID() *RecordID
func (*SyncProgress) Remaining ¶
func (s *SyncProgress) Remaining() int64
func (*SyncProgress) Started ¶
func (s *SyncProgress) Started() int64
func (*SyncProgress) String ¶
func (s *SyncProgress) String() string
func (*SyncProgress) Timestamp ¶
func (s *SyncProgress) Timestamp() int64
func (*SyncProgress) UnmarshalBinary ¶
func (s *SyncProgress) UnmarshalBinary(b []byte) error
type SyncProgressMut ¶
type SyncProgressMut struct {
SyncProgress
}
func (*SyncProgressMut) Clone ¶
func (s *SyncProgressMut) Clone() *SyncProgressMut
func (*SyncProgressMut) Freeze ¶
func (s *SyncProgressMut) Freeze() *SyncProgress
func (*SyncProgressMut) RecordID ¶
func (s *SyncProgressMut) RecordID() *RecordIDMut
func (*SyncProgressMut) SetCount ¶
func (s *SyncProgressMut) SetCount(v int64) *SyncProgressMut
func (*SyncProgressMut) SetRecordID ¶
func (s *SyncProgressMut) SetRecordID(v *RecordID) *SyncProgressMut
func (*SyncProgressMut) SetRemaining ¶
func (s *SyncProgressMut) SetRemaining(v int64) *SyncProgressMut
func (*SyncProgressMut) SetStarted ¶
func (s *SyncProgressMut) SetStarted(v int64) *SyncProgressMut
func (*SyncProgressMut) SetTimestamp ¶
func (s *SyncProgressMut) SetTimestamp(v int64) *SyncProgressMut
type SyncStarted ¶
type SyncStarted struct {
// contains filtered or unexported fields
}
func (*SyncStarted) Bytes ¶
func (s *SyncStarted) Bytes() []byte
func (*SyncStarted) Clone ¶
func (s *SyncStarted) Clone() *SyncStarted
func (*SyncStarted) MarshalBinary ¶
func (s *SyncStarted) MarshalBinary() ([]byte, error)
func (*SyncStarted) MarshalBinaryTo ¶
func (s *SyncStarted) MarshalBinaryTo(b []byte) []byte
func (*SyncStarted) MarshalMap ¶
func (s *SyncStarted) MarshalMap(m map[string]interface{}) map[string]interface{}
func (*SyncStarted) Mut ¶
func (s *SyncStarted) Mut() *SyncStartedMut
func (*SyncStarted) RecordID ¶
func (s *SyncStarted) RecordID() *RecordID
func (*SyncStarted) String ¶
func (s *SyncStarted) String() string
func (*SyncStarted) Timestamp ¶
func (s *SyncStarted) Timestamp() int64
func (*SyncStarted) UnmarshalBinary ¶
func (s *SyncStarted) UnmarshalBinary(b []byte) error
type SyncStartedMut ¶
type SyncStartedMut struct {
SyncStarted
}
func (*SyncStartedMut) Clone ¶
func (s *SyncStartedMut) Clone() *SyncStartedMut
func (*SyncStartedMut) Freeze ¶
func (s *SyncStartedMut) Freeze() *SyncStarted
func (*SyncStartedMut) RecordID ¶
func (s *SyncStartedMut) RecordID() *RecordIDMut
func (*SyncStartedMut) SetRecordID ¶
func (s *SyncStartedMut) SetRecordID(v *RecordID) *SyncStartedMut
func (*SyncStartedMut) SetTimestamp ¶
func (s *SyncStartedMut) SetTimestamp(v int64) *SyncStartedMut
type SyncStopped ¶
type SyncStopped struct {
// contains filtered or unexported fields
}
func (*SyncStopped) Bytes ¶
func (s *SyncStopped) Bytes() []byte
func (*SyncStopped) Clone ¶
func (s *SyncStopped) Clone() *SyncStopped
func (*SyncStopped) MarshalBinary ¶
func (s *SyncStopped) MarshalBinary() ([]byte, error)
func (*SyncStopped) MarshalBinaryTo ¶
func (s *SyncStopped) MarshalBinaryTo(b []byte) []byte
func (*SyncStopped) MarshalMap ¶
func (s *SyncStopped) MarshalMap(m map[string]interface{}) map[string]interface{}
func (*SyncStopped) Message ¶
func (s *SyncStopped) Message() *String64
func (*SyncStopped) Mut ¶
func (s *SyncStopped) Mut() *SyncStoppedMut
func (*SyncStopped) Progress ¶
func (s *SyncStopped) Progress() *SyncProgress
func (*SyncStopped) Reason ¶
func (s *SyncStopped) Reason() SyncStoppedReason
func (*SyncStopped) String ¶
func (s *SyncStopped) String() string
func (*SyncStopped) UnmarshalBinary ¶
func (s *SyncStopped) UnmarshalBinary(b []byte) error
type SyncStoppedMut ¶
type SyncStoppedMut struct {
SyncStopped
}
func (*SyncStoppedMut) Clone ¶
func (s *SyncStoppedMut) Clone() *SyncStoppedMut
func (*SyncStoppedMut) Freeze ¶
func (s *SyncStoppedMut) Freeze() *SyncStopped
func (*SyncStoppedMut) Message ¶
func (s *SyncStoppedMut) Message() *String64Mut
func (*SyncStoppedMut) Progress ¶
func (s *SyncStoppedMut) Progress() *SyncProgressMut
func (*SyncStoppedMut) SetMessage ¶
func (s *SyncStoppedMut) SetMessage(v *String64) *SyncStoppedMut
func (*SyncStoppedMut) SetProgress ¶
func (s *SyncStoppedMut) SetProgress(v *SyncProgress) *SyncStoppedMut
func (*SyncStoppedMut) SetReason ¶
func (s *SyncStoppedMut) SetReason(v SyncStoppedReason) *SyncStoppedMut
type SyncStoppedReason ¶
type SyncStoppedReason byte
type Union ¶
type Union struct {
// contains filtered or unexported fields
}
func (*Union) MarshalBinary ¶
func (*Union) MarshalBinaryTo ¶
func (*Union) MarshalMap ¶
func (*Union) Options ¶
func (s *Union) Options() *UnionOption16List
func (*Union) UnmarshalBinary ¶
type UnionMut ¶
type UnionMut struct {
Union
}
func (*UnionMut) Name ¶
func (s *UnionMut) Name() *String40Mut
func (*UnionMut) Options ¶
func (s *UnionMut) Options() *UnionOption16ListMut
func (*UnionMut) SetOptions ¶
func (s *UnionMut) SetOptions(v *UnionOption16List) *UnionMut
type UnionOption ¶
type UnionOption struct {
// contains filtered or unexported fields
}
func (*UnionOption) Bytes ¶
func (s *UnionOption) Bytes() []byte
func (*UnionOption) Clone ¶
func (s *UnionOption) Clone() *UnionOption
func (*UnionOption) Id ¶
func (s *UnionOption) Id() *String40
func (*UnionOption) Kind ¶
func (s *UnionOption) Kind() Kind
func (*UnionOption) MarshalBinary ¶
func (s *UnionOption) MarshalBinary() ([]byte, error)
func (*UnionOption) MarshalBinaryTo ¶
func (s *UnionOption) MarshalBinaryTo(b []byte) []byte
func (*UnionOption) MarshalMap ¶
func (s *UnionOption) MarshalMap(m map[string]interface{}) map[string]interface{}
func (*UnionOption) Mut ¶
func (s *UnionOption) Mut() *UnionOptionMut
func (*UnionOption) Name ¶
func (s *UnionOption) Name() *String40
func (*UnionOption) String ¶
func (s *UnionOption) String() string
func (*UnionOption) UnmarshalBinary ¶
func (s *UnionOption) UnmarshalBinary(b []byte) error
type UnionOption16List ¶
type UnionOption16List struct {
// contains filtered or unexported fields
}
func (*UnionOption16List) Bytes ¶
func (s *UnionOption16List) Bytes() []byte
func (*UnionOption16List) Cap ¶
func (s *UnionOption16List) Cap() int
func (*UnionOption16List) CopyTo ¶
func (s *UnionOption16List) CopyTo(v []UnionOption) []UnionOption
func (*UnionOption16List) Get ¶
func (s *UnionOption16List) Get(i int) *UnionOption
func (*UnionOption16List) Len ¶
func (s *UnionOption16List) Len() int
func (*UnionOption16List) MarshalBinary ¶
func (s *UnionOption16List) MarshalBinary() ([]byte, error)
func (*UnionOption16List) MarshalBinaryTo ¶
func (s *UnionOption16List) MarshalBinaryTo(b []byte) []byte
func (*UnionOption16List) MarshalMap ¶
func (s *UnionOption16List) MarshalMap(m []map[string]interface{}) []map[string]interface{}
func (*UnionOption16List) Mut ¶
func (s *UnionOption16List) Mut() *UnionOption16ListMut
func (*UnionOption16List) UnmarshalBinary ¶
func (s *UnionOption16List) UnmarshalBinary(b []byte) error
func (*UnionOption16List) Unsafe ¶
func (s *UnionOption16List) Unsafe() []UnionOption
type UnionOption16ListMut ¶
type UnionOption16ListMut struct {
UnionOption16List
}
func (*UnionOption16ListMut) Clear ¶
func (s *UnionOption16ListMut) Clear()
func (*UnionOption16ListMut) Pop ¶
func (s *UnionOption16ListMut) Pop(v *UnionOption) bool
Removes the last item
func (*UnionOption16ListMut) Push ¶
func (s *UnionOption16ListMut) Push(v *UnionOption) bool
func (*UnionOption16ListMut) Shift ¶
func (s *UnionOption16ListMut) Shift(v *UnionOption) bool
Removes the first item
type UnionOptionMut ¶
type UnionOptionMut struct {
UnionOption
}
func (*UnionOptionMut) Clone ¶
func (s *UnionOptionMut) Clone() *UnionOptionMut
func (*UnionOptionMut) Freeze ¶
func (s *UnionOptionMut) Freeze() *UnionOption
func (*UnionOptionMut) Id ¶
func (s *UnionOptionMut) Id() *String40Mut
func (*UnionOptionMut) Name ¶
func (s *UnionOptionMut) Name() *String40Mut
func (*UnionOptionMut) SetId ¶
func (s *UnionOptionMut) SetId(v *String40) *UnionOptionMut
func (*UnionOptionMut) SetKind ¶
func (s *UnionOptionMut) SetKind(v Kind) *UnionOptionMut
func (*UnionOptionMut) SetName ¶
func (s *UnionOptionMut) SetName(v *String40) *UnionOptionMut