Documentation ¶
Index ¶
- Constants
- func CompareTx(tx *pgrepl.Tx, capnptx Tx) error
- func RegisterSchema(reg *schemas.Registry)
- type DealInfo
- func (s DealInfo) Archived() bool
- func (s DealInfo) Cid() (string, error)
- func (s DealInfo) CidBytes() ([]byte, error)
- func (DealInfo) DecodeFromPtr(p capnp.Ptr) DealInfo
- func (s DealInfo) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s DealInfo) ExpiresAt() (string, error)
- func (s DealInfo) ExpiresAtBytes() ([]byte, error)
- func (s DealInfo) HasCid() bool
- func (s DealInfo) HasExpiresAt() bool
- func (s DealInfo) IsValid() bool
- func (s DealInfo) Message() *capnp.Message
- func (s DealInfo) Segment() *capnp.Segment
- func (s DealInfo) SetArchived(v bool)
- func (s DealInfo) SetCid(v string) error
- func (s DealInfo) SetExpiresAt(v string) error
- func (s DealInfo) SetSize(v uint32)
- func (s DealInfo) SetTimestamp(v int64)
- func (s DealInfo) Size() uint32
- func (s DealInfo) String() string
- func (s DealInfo) Timestamp() int64
- func (s DealInfo) ToPtr() capnp.Ptr
- type DealInfo_Future
- type DealInfo_List
- type Schema
- func (s Schema) Columns() (Schema_Column_List, error)
- func (Schema) DecodeFromPtr(p capnp.Ptr) Schema
- func (s Schema) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Schema) HasColumns() bool
- func (s Schema) IsValid() bool
- func (s Schema) Message() *capnp.Message
- func (s Schema) NewColumns(n int32) (Schema_Column_List, error)
- func (s Schema) Segment() *capnp.Segment
- func (s Schema) SetColumns(v Schema_Column_List) error
- func (s Schema) String() string
- func (s Schema) ToPtr() capnp.Ptr
- type Schema_Column
- func (Schema_Column) DecodeFromPtr(p capnp.Ptr) Schema_Column
- func (s Schema_Column) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Schema_Column) HasName() bool
- func (s Schema_Column) HasType() bool
- func (s Schema_Column) IsNullable() bool
- func (s Schema_Column) IsPartOfPrimaryKey() bool
- func (s Schema_Column) IsValid() bool
- func (s Schema_Column) Message() *capnp.Message
- func (s Schema_Column) Name() (string, error)
- func (s Schema_Column) NameBytes() ([]byte, error)
- func (s Schema_Column) Segment() *capnp.Segment
- func (s Schema_Column) SetIsNullable(v bool)
- func (s Schema_Column) SetIsPartOfPrimaryKey(v bool)
- func (s Schema_Column) SetName(v string) error
- func (s Schema_Column) SetType(v string) error
- func (s Schema_Column) String() string
- func (s Schema_Column) ToPtr() capnp.Ptr
- func (s Schema_Column) Type() (string, error)
- func (s Schema_Column) TypeBytes() ([]byte, error)
- type Schema_Column_Future
- type Schema_Column_List
- type Schema_Future
- type Schema_List
- type Tx
- func (s Tx) CommitLSN() uint64
- func (Tx) DecodeFromPtr(p capnp.Ptr) Tx
- func (s Tx) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Tx) HasRecords() bool
- func (s Tx) IsValid() bool
- func (s Tx) Message() *capnp.Message
- func (s Tx) NewRecords(n int32) (Tx_Record_List, error)
- func (s Tx) Records() (Tx_Record_List, error)
- func (s Tx) Segment() *capnp.Segment
- func (s Tx) SetCommitLSN(v uint64)
- func (s Tx) SetRecords(v Tx_Record_List) error
- func (s Tx) String() string
- func (s Tx) ToPtr() capnp.Ptr
- type Tx_Future
- type Tx_List
- type Tx_Record
- func (s Tx_Record) Action() (string, error)
- func (s Tx_Record) ActionBytes() ([]byte, error)
- func (s Tx_Record) Columns() (Tx_Record_Column_List, error)
- func (Tx_Record) DecodeFromPtr(p capnp.Ptr) Tx_Record
- func (s Tx_Record) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Tx_Record) HasAction() bool
- func (s Tx_Record) HasColumns() bool
- func (s Tx_Record) HasPrimaryKey() bool
- func (s Tx_Record) HasSchema() bool
- func (s Tx_Record) HasTable() bool
- func (s Tx_Record) HasTimestamp() bool
- func (s Tx_Record) IsValid() bool
- func (s Tx_Record) Message() *capnp.Message
- func (s Tx_Record) NewColumns(n int32) (Tx_Record_Column_List, error)
- func (s Tx_Record) NewPrimaryKey(n int32) (Tx_Record_PrimaryKey_List, error)
- func (s Tx_Record) PrimaryKey() (Tx_Record_PrimaryKey_List, error)
- func (s Tx_Record) Schema() (string, error)
- func (s Tx_Record) SchemaBytes() ([]byte, error)
- func (s Tx_Record) Segment() *capnp.Segment
- func (s Tx_Record) SetAction(v string) error
- func (s Tx_Record) SetColumns(v Tx_Record_Column_List) error
- func (s Tx_Record) SetPrimaryKey(v Tx_Record_PrimaryKey_List) error
- func (s Tx_Record) SetSchema(v string) error
- func (s Tx_Record) SetTable(v string) error
- func (s Tx_Record) SetTimestamp(v string) error
- func (s Tx_Record) String() string
- func (s Tx_Record) Table() (string, error)
- func (s Tx_Record) TableBytes() ([]byte, error)
- func (s Tx_Record) Timestamp() (string, error)
- func (s Tx_Record) TimestampBytes() ([]byte, error)
- func (s Tx_Record) ToPtr() capnp.Ptr
- type Tx_Record_Column
- func (Tx_Record_Column) DecodeFromPtr(p capnp.Ptr) Tx_Record_Column
- func (s Tx_Record_Column) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Tx_Record_Column) HasName() bool
- func (s Tx_Record_Column) HasType() bool
- func (s Tx_Record_Column) HasValue() bool
- func (s Tx_Record_Column) IsValid() bool
- func (s Tx_Record_Column) Message() *capnp.Message
- func (s Tx_Record_Column) Name() (string, error)
- func (s Tx_Record_Column) NameBytes() ([]byte, error)
- func (s Tx_Record_Column) Segment() *capnp.Segment
- func (s Tx_Record_Column) SetName(v string) error
- func (s Tx_Record_Column) SetType(v string) error
- func (s Tx_Record_Column) SetValue(v []byte) error
- func (s Tx_Record_Column) String() string
- func (s Tx_Record_Column) ToPtr() capnp.Ptr
- func (s Tx_Record_Column) Type() (string, error)
- func (s Tx_Record_Column) TypeBytes() ([]byte, error)
- func (s Tx_Record_Column) Value() ([]byte, error)
- type Tx_Record_Column_Future
- type Tx_Record_Column_List
- type Tx_Record_Future
- type Tx_Record_List
- type Tx_Record_PrimaryKey
- func (Tx_Record_PrimaryKey) DecodeFromPtr(p capnp.Ptr) Tx_Record_PrimaryKey
- func (s Tx_Record_PrimaryKey) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
- func (s Tx_Record_PrimaryKey) HasName() bool
- func (s Tx_Record_PrimaryKey) HasType() bool
- func (s Tx_Record_PrimaryKey) IsValid() bool
- func (s Tx_Record_PrimaryKey) Message() *capnp.Message
- func (s Tx_Record_PrimaryKey) Name() (string, error)
- func (s Tx_Record_PrimaryKey) NameBytes() ([]byte, error)
- func (s Tx_Record_PrimaryKey) Segment() *capnp.Segment
- func (s Tx_Record_PrimaryKey) SetName(v string) error
- func (s Tx_Record_PrimaryKey) SetType(v string) error
- func (s Tx_Record_PrimaryKey) String() string
- func (s Tx_Record_PrimaryKey) ToPtr() capnp.Ptr
- func (s Tx_Record_PrimaryKey) Type() (string, error)
- func (s Tx_Record_PrimaryKey) TypeBytes() ([]byte, error)
- type Tx_Record_PrimaryKey_Future
- type Tx_Record_PrimaryKey_List
Constants ¶
const DealInfo_TypeID = 0xc69bf7c475bb2886
DealInfo_TypeID is the unique identifier for the type DealInfo.
const Schema_Column_TypeID = 0xc6ee33dc50be1a5a
Schema_Column_TypeID is the unique identifier for the type Schema_Column.
const Schema_TypeID = 0xb2c63295c6bcc643
Schema_TypeID is the unique identifier for the type Schema.
const Tx_Record_Column_TypeID = 0xdaf0d54cc25988fc
Tx_Record_Column_TypeID is the unique identifier for the type Tx_Record_Column.
const Tx_Record_PrimaryKey_TypeID = 0x9722004316c0ea9f
Tx_Record_PrimaryKey_TypeID is the unique identifier for the type Tx_Record_PrimaryKey.
const Tx_Record_TypeID = 0xadfa24e64cb4fa48
Tx_Record_TypeID is the unique identifier for the type Tx_Record.
const Tx_TypeID = 0xe9135d071d75f95f
Tx_TypeID is the unique identifier for the type Tx.
Variables ¶
This section is empty.
Functions ¶
func RegisterSchema ¶
Types ¶
type DealInfo ¶
func (DealInfo) ExpiresAtBytes ¶
func (DealInfo) HasExpiresAt ¶
func (DealInfo) SetArchived ¶
func (DealInfo) SetExpiresAt ¶
func (DealInfo) SetTimestamp ¶
type DealInfo_Future ¶
DealInfo_Future is a wrapper for a DealInfo promised by a client call.
func (DealInfo_Future) Struct ¶
func (f DealInfo_Future) Struct() (DealInfo, error)
type DealInfo_List ¶
type DealInfo_List = capnp.StructList[DealInfo]
DealInfo_List is a list of DealInfo.
func NewDealInfo_List ¶
func NewDealInfo_List(s *capnp.Segment, sz int32) (DealInfo_List, error)
NewDealInfo creates a new list of DealInfo.
type Schema ¶
func (Schema) Columns ¶
func (s Schema) Columns() (Schema_Column_List, error)
func (Schema) HasColumns ¶
func (Schema) NewColumns ¶
func (s Schema) NewColumns(n int32) (Schema_Column_List, error)
NewColumns sets the columns field to a newly allocated Schema_Column_List, preferring placement in s's segment.
func (Schema) SetColumns ¶
func (s Schema) SetColumns(v Schema_Column_List) error
type Schema_Column ¶
func NewRootSchema_Column ¶
func NewRootSchema_Column(s *capnp.Segment) (Schema_Column, error)
func NewSchema_Column ¶
func NewSchema_Column(s *capnp.Segment) (Schema_Column, error)
func ReadRootSchema_Column ¶
func ReadRootSchema_Column(msg *capnp.Message) (Schema_Column, error)
func (Schema_Column) DecodeFromPtr ¶
func (Schema_Column) DecodeFromPtr(p capnp.Ptr) Schema_Column
func (Schema_Column) EncodeAsPtr ¶
func (s Schema_Column) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Schema_Column) HasName ¶
func (s Schema_Column) HasName() bool
func (Schema_Column) HasType ¶
func (s Schema_Column) HasType() bool
func (Schema_Column) IsNullable ¶
func (s Schema_Column) IsNullable() bool
func (Schema_Column) IsPartOfPrimaryKey ¶
func (s Schema_Column) IsPartOfPrimaryKey() bool
func (Schema_Column) IsValid ¶
func (s Schema_Column) IsValid() bool
func (Schema_Column) Message ¶
func (s Schema_Column) Message() *capnp.Message
func (Schema_Column) Name ¶
func (s Schema_Column) Name() (string, error)
func (Schema_Column) NameBytes ¶
func (s Schema_Column) NameBytes() ([]byte, error)
func (Schema_Column) Segment ¶
func (s Schema_Column) Segment() *capnp.Segment
func (Schema_Column) SetIsNullable ¶
func (s Schema_Column) SetIsNullable(v bool)
func (Schema_Column) SetIsPartOfPrimaryKey ¶
func (s Schema_Column) SetIsPartOfPrimaryKey(v bool)
func (Schema_Column) SetName ¶
func (s Schema_Column) SetName(v string) error
func (Schema_Column) SetType ¶
func (s Schema_Column) SetType(v string) error
func (Schema_Column) String ¶
func (s Schema_Column) String() string
func (Schema_Column) ToPtr ¶
func (s Schema_Column) ToPtr() capnp.Ptr
func (Schema_Column) Type ¶
func (s Schema_Column) Type() (string, error)
func (Schema_Column) TypeBytes ¶
func (s Schema_Column) TypeBytes() ([]byte, error)
type Schema_Column_Future ¶
Schema_Column_Future is a wrapper for a Schema_Column promised by a client call.
func (Schema_Column_Future) Struct ¶
func (f Schema_Column_Future) Struct() (Schema_Column, error)
type Schema_Column_List ¶
type Schema_Column_List = capnp.StructList[Schema_Column]
Schema_Column_List is a list of Schema_Column.
func NewSchema_Column_List ¶
func NewSchema_Column_List(s *capnp.Segment, sz int32) (Schema_Column_List, error)
NewSchema_Column creates a new list of Schema_Column.
type Schema_Future ¶
Schema_Future is a wrapper for a Schema promised by a client call.
func (Schema_Future) Struct ¶
func (f Schema_Future) Struct() (Schema, error)
type Schema_List ¶
type Schema_List = capnp.StructList[Schema]
Schema_List is a list of Schema.
func NewSchema_List ¶
func NewSchema_List(s *capnp.Segment, sz int32) (Schema_List, error)
NewSchema creates a new list of Schema.
type Tx ¶
func FromPgReplTx ¶
FromPgReplTx converts Tx to its capnp verson.
func (Tx) HasRecords ¶
func (Tx) NewRecords ¶
func (s Tx) NewRecords(n int32) (Tx_Record_List, error)
NewRecords sets the records field to a newly allocated Tx_Record_List, preferring placement in s's segment.
func (Tx) Records ¶
func (s Tx) Records() (Tx_Record_List, error)
func (Tx) SetCommitLSN ¶
func (Tx) SetRecords ¶
func (s Tx) SetRecords(v Tx_Record_List) error
type Tx_Record ¶
func (Tx_Record) ActionBytes ¶
func (Tx_Record) Columns ¶
func (s Tx_Record) Columns() (Tx_Record_Column_List, error)
func (Tx_Record) HasColumns ¶
func (Tx_Record) HasPrimaryKey ¶
func (Tx_Record) HasTimestamp ¶
func (Tx_Record) NewColumns ¶
func (s Tx_Record) NewColumns(n int32) (Tx_Record_Column_List, error)
NewColumns sets the columns field to a newly allocated Tx_Record_Column_List, preferring placement in s's segment.
func (Tx_Record) NewPrimaryKey ¶
func (s Tx_Record) NewPrimaryKey(n int32) (Tx_Record_PrimaryKey_List, error)
NewPrimaryKey sets the primaryKey field to a newly allocated Tx_Record_PrimaryKey_List, preferring placement in s's segment.
func (Tx_Record) PrimaryKey ¶
func (s Tx_Record) PrimaryKey() (Tx_Record_PrimaryKey_List, error)
func (Tx_Record) SchemaBytes ¶
func (Tx_Record) SetColumns ¶
func (s Tx_Record) SetColumns(v Tx_Record_Column_List) error
func (Tx_Record) SetPrimaryKey ¶
func (s Tx_Record) SetPrimaryKey(v Tx_Record_PrimaryKey_List) error
func (Tx_Record) SetTimestamp ¶
func (Tx_Record) TableBytes ¶
func (Tx_Record) TimestampBytes ¶
type Tx_Record_Column ¶
func NewRootTx_Record_Column ¶
func NewRootTx_Record_Column(s *capnp.Segment) (Tx_Record_Column, error)
func NewTx_Record_Column ¶
func NewTx_Record_Column(s *capnp.Segment) (Tx_Record_Column, error)
func ReadRootTx_Record_Column ¶
func ReadRootTx_Record_Column(msg *capnp.Message) (Tx_Record_Column, error)
func (Tx_Record_Column) DecodeFromPtr ¶
func (Tx_Record_Column) DecodeFromPtr(p capnp.Ptr) Tx_Record_Column
func (Tx_Record_Column) EncodeAsPtr ¶
func (s Tx_Record_Column) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Tx_Record_Column) HasName ¶
func (s Tx_Record_Column) HasName() bool
func (Tx_Record_Column) HasType ¶
func (s Tx_Record_Column) HasType() bool
func (Tx_Record_Column) HasValue ¶
func (s Tx_Record_Column) HasValue() bool
func (Tx_Record_Column) IsValid ¶
func (s Tx_Record_Column) IsValid() bool
func (Tx_Record_Column) Message ¶
func (s Tx_Record_Column) Message() *capnp.Message
func (Tx_Record_Column) Name ¶
func (s Tx_Record_Column) Name() (string, error)
func (Tx_Record_Column) NameBytes ¶
func (s Tx_Record_Column) NameBytes() ([]byte, error)
func (Tx_Record_Column) Segment ¶
func (s Tx_Record_Column) Segment() *capnp.Segment
func (Tx_Record_Column) SetName ¶
func (s Tx_Record_Column) SetName(v string) error
func (Tx_Record_Column) SetType ¶
func (s Tx_Record_Column) SetType(v string) error
func (Tx_Record_Column) SetValue ¶
func (s Tx_Record_Column) SetValue(v []byte) error
func (Tx_Record_Column) String ¶
func (s Tx_Record_Column) String() string
func (Tx_Record_Column) ToPtr ¶
func (s Tx_Record_Column) ToPtr() capnp.Ptr
func (Tx_Record_Column) Type ¶
func (s Tx_Record_Column) Type() (string, error)
func (Tx_Record_Column) TypeBytes ¶
func (s Tx_Record_Column) TypeBytes() ([]byte, error)
func (Tx_Record_Column) Value ¶
func (s Tx_Record_Column) Value() ([]byte, error)
type Tx_Record_Column_Future ¶
Tx_Record_Column_Future is a wrapper for a Tx_Record_Column promised by a client call.
func (Tx_Record_Column_Future) Struct ¶
func (f Tx_Record_Column_Future) Struct() (Tx_Record_Column, error)
type Tx_Record_Column_List ¶
type Tx_Record_Column_List = capnp.StructList[Tx_Record_Column]
Tx_Record_Column_List is a list of Tx_Record_Column.
func NewTx_Record_Column_List ¶
func NewTx_Record_Column_List(s *capnp.Segment, sz int32) (Tx_Record_Column_List, error)
NewTx_Record_Column creates a new list of Tx_Record_Column.
type Tx_Record_Future ¶
Tx_Record_Future is a wrapper for a Tx_Record promised by a client call.
func (Tx_Record_Future) Struct ¶
func (f Tx_Record_Future) Struct() (Tx_Record, error)
type Tx_Record_List ¶
type Tx_Record_List = capnp.StructList[Tx_Record]
Tx_Record_List is a list of Tx_Record.
func NewTx_Record_List ¶
func NewTx_Record_List(s *capnp.Segment, sz int32) (Tx_Record_List, error)
NewTx_Record creates a new list of Tx_Record.
type Tx_Record_PrimaryKey ¶
func NewRootTx_Record_PrimaryKey ¶
func NewRootTx_Record_PrimaryKey(s *capnp.Segment) (Tx_Record_PrimaryKey, error)
func NewTx_Record_PrimaryKey ¶
func NewTx_Record_PrimaryKey(s *capnp.Segment) (Tx_Record_PrimaryKey, error)
func ReadRootTx_Record_PrimaryKey ¶
func ReadRootTx_Record_PrimaryKey(msg *capnp.Message) (Tx_Record_PrimaryKey, error)
func (Tx_Record_PrimaryKey) DecodeFromPtr ¶
func (Tx_Record_PrimaryKey) DecodeFromPtr(p capnp.Ptr) Tx_Record_PrimaryKey
func (Tx_Record_PrimaryKey) EncodeAsPtr ¶
func (s Tx_Record_PrimaryKey) EncodeAsPtr(seg *capnp.Segment) capnp.Ptr
func (Tx_Record_PrimaryKey) HasName ¶
func (s Tx_Record_PrimaryKey) HasName() bool
func (Tx_Record_PrimaryKey) HasType ¶
func (s Tx_Record_PrimaryKey) HasType() bool
func (Tx_Record_PrimaryKey) IsValid ¶
func (s Tx_Record_PrimaryKey) IsValid() bool
func (Tx_Record_PrimaryKey) Message ¶
func (s Tx_Record_PrimaryKey) Message() *capnp.Message
func (Tx_Record_PrimaryKey) Name ¶
func (s Tx_Record_PrimaryKey) Name() (string, error)
func (Tx_Record_PrimaryKey) NameBytes ¶
func (s Tx_Record_PrimaryKey) NameBytes() ([]byte, error)
func (Tx_Record_PrimaryKey) Segment ¶
func (s Tx_Record_PrimaryKey) Segment() *capnp.Segment
func (Tx_Record_PrimaryKey) SetName ¶
func (s Tx_Record_PrimaryKey) SetName(v string) error
func (Tx_Record_PrimaryKey) SetType ¶
func (s Tx_Record_PrimaryKey) SetType(v string) error
func (Tx_Record_PrimaryKey) String ¶
func (s Tx_Record_PrimaryKey) String() string
func (Tx_Record_PrimaryKey) ToPtr ¶
func (s Tx_Record_PrimaryKey) ToPtr() capnp.Ptr
func (Tx_Record_PrimaryKey) Type ¶
func (s Tx_Record_PrimaryKey) Type() (string, error)
func (Tx_Record_PrimaryKey) TypeBytes ¶
func (s Tx_Record_PrimaryKey) TypeBytes() ([]byte, error)
type Tx_Record_PrimaryKey_Future ¶
Tx_Record_PrimaryKey_Future is a wrapper for a Tx_Record_PrimaryKey promised by a client call.
func (Tx_Record_PrimaryKey_Future) Struct ¶
func (f Tx_Record_PrimaryKey_Future) Struct() (Tx_Record_PrimaryKey, error)
type Tx_Record_PrimaryKey_List ¶
type Tx_Record_PrimaryKey_List = capnp.StructList[Tx_Record_PrimaryKey]
Tx_Record_PrimaryKey_List is a list of Tx_Record_PrimaryKey.
func NewTx_Record_PrimaryKey_List ¶
func NewTx_Record_PrimaryKey_List(s *capnp.Segment, sz int32) (Tx_Record_PrimaryKey_List, error)
NewTx_Record_PrimaryKey creates a new list of Tx_Record_PrimaryKey.