Documentation ¶
Index ¶
- Constants
- Variables
- type Enum
- type Model1
- func (x *Model1) Clone() *Model1
- func (x *Model1) DeepCopy(z *Model1)
- func (*Model1) Descriptor() ([]byte, []int)deprecated
- func (x *Model1) GetEnum() Enum
- func (x *Model1) GetID() int32
- func (x *Model1) GetP1() string
- func (x *Model1) GetP2() []string
- func (x *Model1) GetP5() uint64
- func (x *Model1) GetShardKey() int32
- func (x *Model1) HasP2(xx string) bool
- func (x *Model1) Marshal() ([]byte, error)
- func (x *Model1) MarshalJSON() ([]byte, error)
- func (*Model1) ProtoMessage()
- func (x *Model1) ProtoReflect() protoreflect.Message
- func (x *Model1) PushToContext(ctx *edge.RequestCtx)
- func (x *Model1) Reset()
- func (x *Model1) String() string
- func (x *Model1) Unmarshal(b []byte) error
- func (x *Model1) UnmarshalJSON(b []byte) error
- type Model1CustomerSortPK
- type Model1CustomerSortPartKey
- type Model1GlobalRepo
- func (r *Model1GlobalRepo) CustomerSort() *table.Table
- func (r *Model1GlobalRepo) Delete(id int32, shardKey int32, enum Enum) error
- func (r *Model1GlobalRepo) Get(id int32, shardKey int32, enum Enum, m *Model1) (*Model1, error)
- func (r *Model1GlobalRepo) GetByCustomerSort(enum Enum, shardKey int32, id int32, m *Model1) (*Model1, error)
- func (r *Model1GlobalRepo) Insert(m *Model1, replace bool) error
- func (r *Model1GlobalRepo) List(pk Model1PartitionKey, limit uint) ([]*Model1, error)
- func (r *Model1GlobalRepo) T() *table.Table
- func (r *Model1GlobalRepo) Table() *table.Table
- func (r *Model1GlobalRepo) Update(m *Model1) error
- type Model1LocalRepo
- func (r *Model1LocalRepo) Create(m *Model1) error
- func (r *Model1LocalRepo) CreateWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Model1) (err error)
- func (r *Model1LocalRepo) Delete(id int32, shardKey int32, enum Enum) error
- func (r *Model1LocalRepo) DeleteWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, id int32, shardKey int32, ...) error
- func (r *Model1LocalRepo) Iter(pk Model1PrimaryKey, ito *store.IterOption, cb func(m *Model1) bool) error
- func (r *Model1LocalRepo) IterWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, offset Model1PrimaryKey, ...) error
- func (r *Model1LocalRepo) List(pk Model1PrimaryKey, lo *store.ListOption, cond func(m *Model1) bool) ([]*Model1, error)
- func (r *Model1LocalRepo) ListByP1(p1 string, lo *store.ListOption, cond func(*Model1) bool) ([]*Model1, error)
- func (r *Model1LocalRepo) ListByP2(p2 string, lo *store.ListOption, cond func(*Model1) bool) ([]*Model1, error)
- func (r *Model1LocalRepo) ListWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, offset Model1PrimaryKey, ...) ([]*Model1, error)
- func (r *Model1LocalRepo) Read(id int32, shardKey int32, enum Enum, m *Model1) (*Model1, error)
- func (r *Model1LocalRepo) ReadByCustomerSort(enum Enum, shardKey int32, id int32, m *Model1) (*Model1, error)
- func (r *Model1LocalRepo) ReadByCustomerSortWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, enum Enum, shardKey int32, ...) (*Model1, error)
- func (r *Model1LocalRepo) ReadWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, id int32, shardKey int32, ...) (*Model1, error)
- func (r *Model1LocalRepo) Save(m *Model1) error
- func (r *Model1LocalRepo) SaveWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Model1) (err error)
- func (r *Model1LocalRepo) Update(id int32, shardKey int32, enum Enum, m *Model1) error
- func (r *Model1LocalRepo) UpdateWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Model1) error
- type Model1PK
- type Model1PartKey
- type Model1PartitionKey
- type Model1PrimaryKey
- type Model2
- func (x *Model2) Clone() *Model2
- func (x *Model2) DeepCopy(z *Model2)
- func (*Model2) Descriptor() ([]byte, []int)deprecated
- func (x *Model2) GetID() int64
- func (x *Model2) GetP1() string
- func (x *Model2) GetP2() []string
- func (x *Model2) GetP5() uint64
- func (x *Model2) GetShardKey() int32
- func (x *Model2) HasP2(xx string) bool
- func (x *Model2) Marshal() ([]byte, error)
- func (x *Model2) MarshalJSON() ([]byte, error)
- func (*Model2) ProtoMessage()
- func (x *Model2) ProtoReflect() protoreflect.Message
- func (x *Model2) PushToContext(ctx *edge.RequestCtx)
- func (x *Model2) Reset()
- func (x *Model2) String() string
- func (x *Model2) Unmarshal(b []byte) error
- func (x *Model2) UnmarshalJSON(b []byte) error
- type Model2GlobalRepo
- func (r *Model2GlobalRepo) Delete(id int64, shardKey int32, p1 string) error
- func (r *Model2GlobalRepo) Get(id int64, shardKey int32, p1 string, m *Model2) (*Model2, error)
- func (r *Model2GlobalRepo) GetByP1ShardKeyID(p1 string, shardKey int32, id int64, m *Model2) (*Model2, error)
- func (r *Model2GlobalRepo) Insert(m *Model2, replace bool) error
- func (r *Model2GlobalRepo) List(pk Model2PartitionKey, limit uint) ([]*Model2, error)
- func (r *Model2GlobalRepo) MVP1ShardKeyID() *table.Table
- func (r *Model2GlobalRepo) T() *table.Table
- func (r *Model2GlobalRepo) Table() *table.Table
- func (r *Model2GlobalRepo) Update(m *Model2) error
- type Model2LocalRepo
- func (r *Model2LocalRepo) Create(m *Model2) error
- func (r *Model2LocalRepo) CreateWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Model2) (err error)
- func (r *Model2LocalRepo) Delete(id int64, shardKey int32, p1 string) error
- func (r *Model2LocalRepo) DeleteWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, id int64, shardKey int32, ...) error
- func (r *Model2LocalRepo) Iter(pk Model2PrimaryKey, ito *store.IterOption, cb func(m *Model2) bool) error
- func (r *Model2LocalRepo) IterWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, offset Model2PrimaryKey, ...) error
- func (r *Model2LocalRepo) List(pk Model2PrimaryKey, lo *store.ListOption, cond func(m *Model2) bool) ([]*Model2, error)
- func (r *Model2LocalRepo) ListWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, offset Model2PrimaryKey, ...) ([]*Model2, error)
- func (r *Model2LocalRepo) Read(id int64, shardKey int32, p1 string, m *Model2) (*Model2, error)
- func (r *Model2LocalRepo) ReadByP1ShardKeyID(p1 string, shardKey int32, id int64, m *Model2) (*Model2, error)
- func (r *Model2LocalRepo) ReadByP1ShardKeyIDWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, p1 string, shardKey int32, ...) (*Model2, error)
- func (r *Model2LocalRepo) ReadWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, id int64, shardKey int32, ...) (*Model2, error)
- func (r *Model2LocalRepo) Save(m *Model2) error
- func (r *Model2LocalRepo) SaveWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Model2) (err error)
- func (r *Model2LocalRepo) Update(id int64, shardKey int32, p1 string, m *Model2) error
- func (r *Model2LocalRepo) UpdateWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Model2) error
- type Model2P1ShardKeyIDPK
- type Model2P1ShardKeyIDPartKey
- type Model2PK
- type Model2PartKey
- type Model2PartitionKey
- type Model2PrimaryKey
- type Model3
- func (x *Model3) Clone() *Model3
- func (x *Model3) DeepCopy(z *Model3)
- func (*Model3) Descriptor() ([]byte, []int)deprecated
- func (x *Model3) GetID() int64
- func (x *Model3) GetP1() []byte
- func (x *Model3) GetP2() []string
- func (x *Model3) GetP5() [][]byte
- func (x *Model3) GetShardKey() int32
- func (x *Model3) HasP2(xx string) bool
- func (x *Model3) HasP5(xx []byte) bool
- func (x *Model3) Marshal() ([]byte, error)
- func (x *Model3) MarshalJSON() ([]byte, error)
- func (*Model3) ProtoMessage()
- func (x *Model3) ProtoReflect() protoreflect.Message
- func (x *Model3) PushToContext(ctx *edge.RequestCtx)
- func (x *Model3) Reset()
- func (x *Model3) String() string
- func (x *Model3) Unmarshal(b []byte) error
- func (x *Model3) UnmarshalJSON(b []byte) error
- type Model3GlobalRepo
- func (r *Model3GlobalRepo) Delete(id int64, shardKey int32, p1 []byte) error
- func (r *Model3GlobalRepo) Get(id int64, shardKey int32, p1 []byte, m *Model3) (*Model3, error)
- func (r *Model3GlobalRepo) GetByP1IDShardKey(p1 []byte, id int64, shardKey int32, m *Model3) (*Model3, error)
- func (r *Model3GlobalRepo) GetByP1ShardKeyID(p1 []byte, shardKey int32, id int64, m *Model3) (*Model3, error)
- func (r *Model3GlobalRepo) Insert(m *Model3, replace bool) error
- func (r *Model3GlobalRepo) List(pk Model3PartitionKey, limit uint) ([]*Model3, error)
- func (r *Model3GlobalRepo) MVP1IDShardKey() *table.Table
- func (r *Model3GlobalRepo) MVP1ShardKeyID() *table.Table
- func (r *Model3GlobalRepo) T() *table.Table
- func (r *Model3GlobalRepo) Table() *table.Table
- func (r *Model3GlobalRepo) Update(m *Model3) error
- type Model3LocalRepo
- func (r *Model3LocalRepo) Create(m *Model3) error
- func (r *Model3LocalRepo) CreateWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Model3) (err error)
- func (r *Model3LocalRepo) Delete(id int64, shardKey int32, p1 []byte) error
- func (r *Model3LocalRepo) DeleteWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, id int64, shardKey int32, ...) error
- func (r *Model3LocalRepo) Iter(pk Model3PrimaryKey, ito *store.IterOption, cb func(m *Model3) bool) error
- func (r *Model3LocalRepo) IterWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, offset Model3PrimaryKey, ...) error
- func (r *Model3LocalRepo) List(pk Model3PrimaryKey, lo *store.ListOption, cond func(m *Model3) bool) ([]*Model3, error)
- func (r *Model3LocalRepo) ListByP5(p5 []byte, lo *store.ListOption, cond func(*Model3) bool) ([]*Model3, error)
- func (r *Model3LocalRepo) ListWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, offset Model3PrimaryKey, ...) ([]*Model3, error)
- func (r *Model3LocalRepo) Read(id int64, shardKey int32, p1 []byte, m *Model3) (*Model3, error)
- func (r *Model3LocalRepo) ReadByP1IDShardKey(p1 []byte, id int64, shardKey int32, m *Model3) (*Model3, error)
- func (r *Model3LocalRepo) ReadByP1IDShardKeyWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, p1 []byte, id int64, ...) (*Model3, error)
- func (r *Model3LocalRepo) ReadByP1ShardKeyID(p1 []byte, shardKey int32, id int64, m *Model3) (*Model3, error)
- func (r *Model3LocalRepo) ReadByP1ShardKeyIDWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, p1 []byte, shardKey int32, ...) (*Model3, error)
- func (r *Model3LocalRepo) ReadWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, id int64, shardKey int32, ...) (*Model3, error)
- func (r *Model3LocalRepo) Save(m *Model3) error
- func (r *Model3LocalRepo) SaveWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Model3) (err error)
- func (r *Model3LocalRepo) Update(id int64, shardKey int32, p1 []byte, m *Model3) error
- func (r *Model3LocalRepo) UpdateWithTxn(txn *rony.StoreTxn, alloc *tools.Allocator, m *Model3) error
- type Model3P1IDShardKeyPK
- type Model3P1IDShardKeyPartKey
- type Model3P1ShardKeyIDPK
- type Model3P1ShardKeyIDPartKey
- type Model3PK
- type Model3PartKey
- type Model3PartitionKey
- type Model3PrimaryKey
Constants ¶
View Source
const C_Model1 uint64 = 4836552447521021952
View Source
const C_Model2 uint64 = 4741976855346241536
View Source
const C_Model3 uint64 = 4647401263171461120
Variables ¶
View Source
var ( Enum_name = map[int32]string{ 0: "None", 1: "Something", 2: "Else", } Enum_value = map[string]int32{ "None": 0, "Something": 1, "Else": 2, } )
Enum value maps for Enum.
View Source
var File_model_proto protoreflect.FileDescriptor
View Source
var PoolModel1 = poolModel1{}
View Source
var PoolModel2 = poolModel2{}
View Source
var PoolModel3 = poolModel3{}
Functions ¶
This section is empty.
Types ¶
type Enum ¶ added in v0.3.9
type Enum int32
func (Enum) Descriptor ¶ added in v0.3.9
func (Enum) Descriptor() protoreflect.EnumDescriptor
func (Enum) EnumDescriptor
deprecated
added in
v0.3.9
func (Enum) Number ¶ added in v0.3.9
func (x Enum) Number() protoreflect.EnumNumber
func (Enum) Type ¶ added in v0.3.9
func (Enum) Type() protoreflect.EnumType
type Model1 ¶
type Model1 struct { ID int32 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` ShardKey int32 `protobuf:"varint,2,opt,name=ShardKey,proto3" json:"ShardKey,omitempty"` P1 string `protobuf:"bytes,3,opt,name=P1,proto3" json:"P1,omitempty"` P2 []string `protobuf:"bytes,4,rep,name=P2,proto3" json:"P2,omitempty"` P5 uint64 `protobuf:"varint,5,opt,name=P5,proto3" json:"P5,omitempty"` Enum Enum `protobuf:"varint,7,opt,name=Enum,proto3,enum=model.Enum" json:"Enum,omitempty"` // contains filtered or unexported fields }
func (*Model1) Descriptor
deprecated
func (*Model1) GetShardKey ¶
func (*Model1) MarshalJSON ¶ added in v0.10.3
func (*Model1) ProtoMessage ¶
func (*Model1) ProtoMessage()
func (*Model1) ProtoReflect ¶
func (x *Model1) ProtoReflect() protoreflect.Message
func (*Model1) PushToContext ¶
func (x *Model1) PushToContext(ctx *edge.RequestCtx)
func (*Model1) UnmarshalJSON ¶ added in v0.10.3
type Model1CustomerSortPK ¶ added in v0.12.0
type Model1CustomerSortPartKey ¶ added in v0.12.6
type Model1CustomerSortPartKey struct {
Enum Enum
}
type Model1GlobalRepo ¶ added in v0.12.34
type Model1GlobalRepo struct {
// contains filtered or unexported fields
}
func NewModel1GlobalRepo ¶ added in v0.12.34
func NewModel1GlobalRepo(s gocqlx.Session) *Model1GlobalRepo
func (*Model1GlobalRepo) CustomerSort ¶ added in v0.12.34
func (r *Model1GlobalRepo) CustomerSort() *table.Table
func (*Model1GlobalRepo) Delete ¶ added in v0.12.34
func (r *Model1GlobalRepo) Delete(id int32, shardKey int32, enum Enum) error
func (*Model1GlobalRepo) GetByCustomerSort ¶ added in v0.12.34
func (*Model1GlobalRepo) Insert ¶ added in v0.12.34
func (r *Model1GlobalRepo) Insert(m *Model1, replace bool) error
func (*Model1GlobalRepo) List ¶ added in v0.12.34
func (r *Model1GlobalRepo) List(pk Model1PartitionKey, limit uint) ([]*Model1, error)
func (*Model1GlobalRepo) T ¶ added in v0.12.34
func (r *Model1GlobalRepo) T() *table.Table
func (*Model1GlobalRepo) Table ¶ added in v0.12.34
func (r *Model1GlobalRepo) Table() *table.Table
func (*Model1GlobalRepo) Update ¶ added in v0.12.34
func (r *Model1GlobalRepo) Update(m *Model1) error
type Model1LocalRepo ¶ added in v0.12.0
type Model1LocalRepo struct {
// contains filtered or unexported fields
}
func NewModel1LocalRepo ¶ added in v0.12.0
func NewModel1LocalRepo(s rony.Store) *Model1LocalRepo
func (*Model1LocalRepo) Create ¶ added in v0.12.0
func (r *Model1LocalRepo) Create(m *Model1) error
func (*Model1LocalRepo) CreateWithTxn ¶ added in v0.12.0
func (*Model1LocalRepo) Delete ¶ added in v0.12.0
func (r *Model1LocalRepo) Delete(id int32, shardKey int32, enum Enum) error
func (*Model1LocalRepo) DeleteWithTxn ¶ added in v0.12.0
func (*Model1LocalRepo) Iter ¶ added in v0.12.0
func (r *Model1LocalRepo) Iter( pk Model1PrimaryKey, ito *store.IterOption, cb func(m *Model1) bool, ) error
func (*Model1LocalRepo) IterWithTxn ¶ added in v0.12.0
func (r *Model1LocalRepo) IterWithTxn( txn *rony.StoreTxn, alloc *tools.Allocator, offset Model1PrimaryKey, ito *store.IterOption, cb func(m *Model1) bool, ) error
func (*Model1LocalRepo) List ¶ added in v0.12.0
func (r *Model1LocalRepo) List( pk Model1PrimaryKey, lo *store.ListOption, cond func(m *Model1) bool, ) ([]*Model1, error)
func (*Model1LocalRepo) ListByP1 ¶ added in v0.12.1
func (r *Model1LocalRepo) ListByP1(p1 string, lo *store.ListOption, cond func(*Model1) bool) ([]*Model1, error)
func (*Model1LocalRepo) ListByP2 ¶ added in v0.12.1
func (r *Model1LocalRepo) ListByP2(p2 string, lo *store.ListOption, cond func(*Model1) bool) ([]*Model1, error)
func (*Model1LocalRepo) ListWithTxn ¶ added in v0.12.0
func (r *Model1LocalRepo) ListWithTxn( txn *rony.StoreTxn, alloc *tools.Allocator, offset Model1PrimaryKey, lo *store.ListOption, cond func(m *Model1) bool, ) ([]*Model1, error)
func (*Model1LocalRepo) ReadByCustomerSort ¶ added in v0.12.0
func (*Model1LocalRepo) ReadByCustomerSortWithTxn ¶ added in v0.12.0
func (*Model1LocalRepo) ReadWithTxn ¶ added in v0.12.0
func (*Model1LocalRepo) Save ¶ added in v0.12.0
func (r *Model1LocalRepo) Save(m *Model1) error
func (*Model1LocalRepo) SaveWithTxn ¶ added in v0.12.0
func (*Model1LocalRepo) UpdateWithTxn ¶ added in v0.12.0
type Model1PartKey ¶ added in v0.12.1
type Model1PartKey struct {
ID int32
}
type Model1PartitionKey ¶ added in v0.12.6
type Model1PartitionKey interface {
// contains filtered or unexported methods
}
type Model1PrimaryKey ¶ added in v0.12.2
type Model1PrimaryKey interface {
// contains filtered or unexported methods
}
type Model2 ¶
type Model2 struct { ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` ShardKey int32 `protobuf:"varint,2,opt,name=ShardKey,proto3" json:"ShardKey,omitempty"` P1 string `protobuf:"bytes,3,opt,name=P1,proto3" json:"P1,omitempty"` P2 []string `protobuf:"bytes,4,rep,name=P2,proto3" json:"P2,omitempty"` P5 uint64 `protobuf:"varint,5,opt,name=P5,proto3" json:"P5,omitempty"` // contains filtered or unexported fields }
func (*Model2) Descriptor
deprecated
func (*Model2) GetShardKey ¶
func (*Model2) MarshalJSON ¶ added in v0.10.3
func (*Model2) ProtoMessage ¶
func (*Model2) ProtoMessage()
func (*Model2) ProtoReflect ¶
func (x *Model2) ProtoReflect() protoreflect.Message
func (*Model2) PushToContext ¶
func (x *Model2) PushToContext(ctx *edge.RequestCtx)
func (*Model2) UnmarshalJSON ¶ added in v0.10.3
type Model2GlobalRepo ¶ added in v0.12.34
type Model2GlobalRepo struct {
// contains filtered or unexported fields
}
func NewModel2GlobalRepo ¶ added in v0.12.34
func NewModel2GlobalRepo(s gocqlx.Session) *Model2GlobalRepo
func (*Model2GlobalRepo) Delete ¶ added in v0.12.34
func (r *Model2GlobalRepo) Delete(id int64, shardKey int32, p1 string) error
func (*Model2GlobalRepo) GetByP1ShardKeyID ¶ added in v0.12.34
func (*Model2GlobalRepo) Insert ¶ added in v0.12.34
func (r *Model2GlobalRepo) Insert(m *Model2, replace bool) error
func (*Model2GlobalRepo) List ¶ added in v0.12.34
func (r *Model2GlobalRepo) List(pk Model2PartitionKey, limit uint) ([]*Model2, error)
func (*Model2GlobalRepo) MVP1ShardKeyID ¶ added in v0.12.34
func (r *Model2GlobalRepo) MVP1ShardKeyID() *table.Table
func (*Model2GlobalRepo) T ¶ added in v0.12.34
func (r *Model2GlobalRepo) T() *table.Table
func (*Model2GlobalRepo) Table ¶ added in v0.12.34
func (r *Model2GlobalRepo) Table() *table.Table
func (*Model2GlobalRepo) Update ¶ added in v0.12.34
func (r *Model2GlobalRepo) Update(m *Model2) error
type Model2LocalRepo ¶ added in v0.12.0
type Model2LocalRepo struct {
// contains filtered or unexported fields
}
func NewModel2LocalRepo ¶ added in v0.12.0
func NewModel2LocalRepo(s rony.Store) *Model2LocalRepo
func (*Model2LocalRepo) Create ¶ added in v0.12.0
func (r *Model2LocalRepo) Create(m *Model2) error
func (*Model2LocalRepo) CreateWithTxn ¶ added in v0.12.0
func (*Model2LocalRepo) Delete ¶ added in v0.12.0
func (r *Model2LocalRepo) Delete(id int64, shardKey int32, p1 string) error
func (*Model2LocalRepo) DeleteWithTxn ¶ added in v0.12.0
func (*Model2LocalRepo) Iter ¶ added in v0.12.0
func (r *Model2LocalRepo) Iter( pk Model2PrimaryKey, ito *store.IterOption, cb func(m *Model2) bool, ) error
func (*Model2LocalRepo) IterWithTxn ¶ added in v0.12.0
func (r *Model2LocalRepo) IterWithTxn( txn *rony.StoreTxn, alloc *tools.Allocator, offset Model2PrimaryKey, ito *store.IterOption, cb func(m *Model2) bool, ) error
func (*Model2LocalRepo) List ¶ added in v0.12.0
func (r *Model2LocalRepo) List( pk Model2PrimaryKey, lo *store.ListOption, cond func(m *Model2) bool, ) ([]*Model2, error)
func (*Model2LocalRepo) ListWithTxn ¶ added in v0.12.0
func (r *Model2LocalRepo) ListWithTxn( txn *rony.StoreTxn, alloc *tools.Allocator, offset Model2PrimaryKey, lo *store.ListOption, cond func(m *Model2) bool, ) ([]*Model2, error)
func (*Model2LocalRepo) ReadByP1ShardKeyID ¶ added in v0.12.0
func (*Model2LocalRepo) ReadByP1ShardKeyIDWithTxn ¶ added in v0.12.0
func (*Model2LocalRepo) ReadWithTxn ¶ added in v0.12.0
func (*Model2LocalRepo) Save ¶ added in v0.12.0
func (r *Model2LocalRepo) Save(m *Model2) error
func (*Model2LocalRepo) SaveWithTxn ¶ added in v0.12.0
func (*Model2LocalRepo) UpdateWithTxn ¶ added in v0.12.0
type Model2P1ShardKeyIDPK ¶ added in v0.12.0
type Model2P1ShardKeyIDPartKey ¶ added in v0.12.6
type Model2P1ShardKeyIDPartKey struct {
P1 string
}
type Model2PartKey ¶ added in v0.12.1
type Model2PartitionKey ¶ added in v0.12.6
type Model2PartitionKey interface {
// contains filtered or unexported methods
}
type Model2PrimaryKey ¶ added in v0.12.2
type Model2PrimaryKey interface {
// contains filtered or unexported methods
}
type Model3 ¶ added in v0.11.1
type Model3 struct { ID int64 `protobuf:"varint,1,opt,name=ID,proto3" json:"ID,omitempty"` ShardKey int32 `protobuf:"varint,2,opt,name=ShardKey,proto3" json:"ShardKey,omitempty"` P1 []byte `protobuf:"bytes,3,opt,name=P1,proto3" json:"P1,omitempty"` P2 []string `protobuf:"bytes,4,rep,name=P2,proto3" json:"P2,omitempty"` P5 [][]byte `protobuf:"bytes,5,rep,name=P5,proto3" json:"P5,omitempty"` // contains filtered or unexported fields }
func (*Model3) Descriptor
deprecated
added in
v0.11.1
func (*Model3) GetShardKey ¶ added in v0.11.1
func (*Model3) MarshalJSON ¶ added in v0.11.1
func (*Model3) ProtoMessage ¶ added in v0.11.1
func (*Model3) ProtoMessage()
func (*Model3) ProtoReflect ¶ added in v0.11.1
func (x *Model3) ProtoReflect() protoreflect.Message
func (*Model3) PushToContext ¶ added in v0.11.1
func (x *Model3) PushToContext(ctx *edge.RequestCtx)
func (*Model3) UnmarshalJSON ¶ added in v0.11.1
type Model3GlobalRepo ¶ added in v0.12.34
type Model3GlobalRepo struct {
// contains filtered or unexported fields
}
func NewModel3GlobalRepo ¶ added in v0.12.34
func NewModel3GlobalRepo(s gocqlx.Session) *Model3GlobalRepo
func (*Model3GlobalRepo) Delete ¶ added in v0.12.34
func (r *Model3GlobalRepo) Delete(id int64, shardKey int32, p1 []byte) error
func (*Model3GlobalRepo) GetByP1IDShardKey ¶ added in v0.12.34
func (*Model3GlobalRepo) GetByP1ShardKeyID ¶ added in v0.12.34
func (*Model3GlobalRepo) Insert ¶ added in v0.12.34
func (r *Model3GlobalRepo) Insert(m *Model3, replace bool) error
func (*Model3GlobalRepo) List ¶ added in v0.12.34
func (r *Model3GlobalRepo) List(pk Model3PartitionKey, limit uint) ([]*Model3, error)
func (*Model3GlobalRepo) MVP1IDShardKey ¶ added in v0.12.34
func (r *Model3GlobalRepo) MVP1IDShardKey() *table.Table
func (*Model3GlobalRepo) MVP1ShardKeyID ¶ added in v0.12.34
func (r *Model3GlobalRepo) MVP1ShardKeyID() *table.Table
func (*Model3GlobalRepo) T ¶ added in v0.12.34
func (r *Model3GlobalRepo) T() *table.Table
func (*Model3GlobalRepo) Table ¶ added in v0.12.34
func (r *Model3GlobalRepo) Table() *table.Table
func (*Model3GlobalRepo) Update ¶ added in v0.12.34
func (r *Model3GlobalRepo) Update(m *Model3) error
type Model3LocalRepo ¶ added in v0.12.0
type Model3LocalRepo struct {
// contains filtered or unexported fields
}
func NewModel3LocalRepo ¶ added in v0.12.0
func NewModel3LocalRepo(s rony.Store) *Model3LocalRepo
func (*Model3LocalRepo) Create ¶ added in v0.12.0
func (r *Model3LocalRepo) Create(m *Model3) error
func (*Model3LocalRepo) CreateWithTxn ¶ added in v0.12.0
func (*Model3LocalRepo) Delete ¶ added in v0.12.0
func (r *Model3LocalRepo) Delete(id int64, shardKey int32, p1 []byte) error
func (*Model3LocalRepo) DeleteWithTxn ¶ added in v0.12.0
func (*Model3LocalRepo) Iter ¶ added in v0.12.0
func (r *Model3LocalRepo) Iter( pk Model3PrimaryKey, ito *store.IterOption, cb func(m *Model3) bool, ) error
func (*Model3LocalRepo) IterWithTxn ¶ added in v0.12.0
func (r *Model3LocalRepo) IterWithTxn( txn *rony.StoreTxn, alloc *tools.Allocator, offset Model3PrimaryKey, ito *store.IterOption, cb func(m *Model3) bool, ) error
func (*Model3LocalRepo) List ¶ added in v0.12.0
func (r *Model3LocalRepo) List( pk Model3PrimaryKey, lo *store.ListOption, cond func(m *Model3) bool, ) ([]*Model3, error)
func (*Model3LocalRepo) ListByP5 ¶ added in v0.12.1
func (r *Model3LocalRepo) ListByP5(p5 []byte, lo *store.ListOption, cond func(*Model3) bool) ([]*Model3, error)
func (*Model3LocalRepo) ListWithTxn ¶ added in v0.12.0
func (r *Model3LocalRepo) ListWithTxn( txn *rony.StoreTxn, alloc *tools.Allocator, offset Model3PrimaryKey, lo *store.ListOption, cond func(m *Model3) bool, ) ([]*Model3, error)
func (*Model3LocalRepo) ReadByP1IDShardKey ¶ added in v0.12.6
func (*Model3LocalRepo) ReadByP1IDShardKeyWithTxn ¶ added in v0.12.6
func (*Model3LocalRepo) ReadByP1ShardKeyID ¶ added in v0.12.0
func (*Model3LocalRepo) ReadByP1ShardKeyIDWithTxn ¶ added in v0.12.0
func (*Model3LocalRepo) ReadWithTxn ¶ added in v0.12.0
func (*Model3LocalRepo) Save ¶ added in v0.12.0
func (r *Model3LocalRepo) Save(m *Model3) error
func (*Model3LocalRepo) SaveWithTxn ¶ added in v0.12.0
func (*Model3LocalRepo) UpdateWithTxn ¶ added in v0.12.0
type Model3P1IDShardKeyPK ¶ added in v0.12.6
type Model3P1IDShardKeyPartKey ¶ added in v0.12.6
type Model3P1IDShardKeyPartKey struct {
P1 []byte
}
type Model3P1ShardKeyIDPK ¶ added in v0.12.0
type Model3P1ShardKeyIDPartKey ¶ added in v0.12.6
type Model3P1ShardKeyIDPartKey struct {
P1 []byte
}
type Model3PartKey ¶ added in v0.12.1
type Model3PartitionKey ¶ added in v0.12.6
type Model3PartitionKey interface {
// contains filtered or unexported methods
}
type Model3PrimaryKey ¶ added in v0.12.2
type Model3PrimaryKey interface {
// contains filtered or unexported methods
}
Click to show internal directories.
Click to hide internal directories.