model

package
v0.14.24 Latest Latest
Warning

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

 Go to latest Published: Oct 26, 2021 License: BSD-3-Clause Imports: 17 Imported by: 0

Documentation

Index

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
const (
	Enum_None      Enum = 0
	Enum_Something Enum = 1
	Enum_Else      Enum = 2
)

func (Enum) Descriptor added in v0.3.9 

func (Enum) Descriptor() protoreflect.EnumDescriptor

func (Enum) Enum added in v0.3.9 

func (x Enum) Enum() *Enum

func (Enum) EnumDescriptor deprecated added in v0.3.9 

func (Enum) EnumDescriptor() ([]byte, []int)

Deprecated: Use Enum.Descriptor instead.

func (Enum) Number added in v0.3.9 

func (x Enum) Number() protoreflect.EnumNumber

func (Enum) String added in v0.3.9 

func (x Enum) String() string

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) Clone added in v0.12.0 

func (x *Model1) Clone() *Model1

func (*Model1) DeepCopy 

func (x *Model1) DeepCopy(z *Model1)

func (*Model1) Descriptor deprecated 

func (*Model1) Descriptor() ([]byte, []int)

Deprecated: Use Model1.ProtoReflect.Descriptor instead.

func (*Model1) GetEnum added in v0.3.9 

func (x *Model1) GetEnum() Enum

func (*Model1) GetID 

func (x *Model1) GetID() int32

func (*Model1) GetP1 

func (x *Model1) GetP1() string

func (*Model1) GetP2 

func (x *Model1) GetP2() []string

func (*Model1) GetP5 

func (x *Model1) GetP5() uint64

func (*Model1) GetShardKey 

func (x *Model1) GetShardKey() int32

func (*Model1) HasP2 added in v0.3.8 

func (x *Model1) HasP2(xx string) bool

func (*Model1) Marshal 

func (x *Model1) Marshal() ([]byte, error)

func (*Model1) MarshalJSON added in v0.10.3 

func (x *Model1) MarshalJSON() ([]byte, error)

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

func (x *Model1) Reset()

func (*Model1) String 

func (x *Model1) String() string

func (*Model1) Unmarshal 

func (x *Model1) Unmarshal(b []byte) error

func (*Model1) UnmarshalJSON added in v0.10.3 

func (x *Model1) UnmarshalJSON(b []byte) error

type Model1CustomerSortPK added in v0.12.0 

type Model1CustomerSortPK struct {
	Enum     Enum
	ShardKey int32
	ID       int32
}

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) Get added in v0.12.34 

func (r *Model1GlobalRepo) Get(id int32, shardKey int32, enum Enum, m *Model1) (*Model1, error)

func (*Model1GlobalRepo) GetByCustomerSort added in v0.12.34 

func (r *Model1GlobalRepo) GetByCustomerSort(enum Enum, shardKey int32, id int32, m *Model1) (*Model1, error)

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 *store.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 (r *Model1LocalRepo) CreateWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, m *Model1,
) (err error)

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 (r *Model1LocalRepo) DeleteWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	id int32, shardKey int32, enum Enum,
) error

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) Read added in v0.12.0 

func (r *Model1LocalRepo) Read(id int32, shardKey int32, enum Enum, m *Model1) (*Model1, error)

func (*Model1LocalRepo) ReadByCustomerSort added in v0.12.0 

func (r *Model1LocalRepo) ReadByCustomerSort(enum Enum, shardKey int32, id int32, m *Model1) (*Model1, error)

func (*Model1LocalRepo) ReadByCustomerSortWithTxn added in v0.12.0 

func (r *Model1LocalRepo) ReadByCustomerSortWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	enum Enum, shardKey int32, id int32, m *Model1,
) (*Model1, error)

func (*Model1LocalRepo) ReadWithTxn added in v0.12.0 

func (r *Model1LocalRepo) ReadWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	id int32, shardKey int32, enum Enum, m *Model1,
) (*Model1, error)

func (*Model1LocalRepo) Save added in v0.12.0 

func (r *Model1LocalRepo) Save(m *Model1) error

func (*Model1LocalRepo) SaveWithTxn added in v0.12.0 

func (r *Model1LocalRepo) SaveWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, m *Model1,
) (err error)

func (*Model1LocalRepo) Update added in v0.12.0 

func (r *Model1LocalRepo) Update(id int32, shardKey int32, enum Enum, m *Model1) error

func (*Model1LocalRepo) UpdateWithTxn added in v0.12.0 

func (r *Model1LocalRepo) UpdateWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, m *Model1,
) error

type Model1PK added in v0.12.0 

type Model1PK struct {
	ID       int32
	ShardKey int32
	Enum     Enum
}

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) Clone added in v0.12.0 

func (x *Model2) Clone() *Model2

func (*Model2) DeepCopy 

func (x *Model2) DeepCopy(z *Model2)

func (*Model2) Descriptor deprecated 

func (*Model2) Descriptor() ([]byte, []int)

Deprecated: Use Model2.ProtoReflect.Descriptor instead.

func (*Model2) GetID 

func (x *Model2) GetID() int64

func (*Model2) GetP1 

func (x *Model2) GetP1() string

func (*Model2) GetP2 

func (x *Model2) GetP2() []string

func (*Model2) GetP5 

func (x *Model2) GetP5() uint64

func (*Model2) GetShardKey 

func (x *Model2) GetShardKey() int32

func (*Model2) HasP2 added in v0.3.8 

func (x *Model2) HasP2(xx string) bool

func (*Model2) Marshal 

func (x *Model2) Marshal() ([]byte, error)

func (*Model2) MarshalJSON added in v0.10.3 

func (x *Model2) MarshalJSON() ([]byte, error)

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

func (x *Model2) Reset()

func (*Model2) String 

func (x *Model2) String() string

func (*Model2) Unmarshal 

func (x *Model2) Unmarshal(b []byte) error

func (*Model2) UnmarshalJSON added in v0.10.3 

func (x *Model2) UnmarshalJSON(b []byte) error

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) Get added in v0.12.34 

func (r *Model2GlobalRepo) Get(id int64, shardKey int32, p1 string, m *Model2) (*Model2, error)

func (*Model2GlobalRepo) GetByP1ShardKeyID added in v0.12.34 

func (r *Model2GlobalRepo) GetByP1ShardKeyID(p1 string, shardKey int32, id int64, m *Model2) (*Model2, error)

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 *store.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 (r *Model2LocalRepo) CreateWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, m *Model2,
) (err error)

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 (r *Model2LocalRepo) DeleteWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	id int64, shardKey int32, p1 string,
) error

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) Read added in v0.12.0 

func (r *Model2LocalRepo) Read(id int64, shardKey int32, p1 string, m *Model2) (*Model2, error)

func (*Model2LocalRepo) ReadByP1ShardKeyID added in v0.12.0 

func (r *Model2LocalRepo) ReadByP1ShardKeyID(p1 string, shardKey int32, id int64, m *Model2) (*Model2, error)

func (*Model2LocalRepo) ReadByP1ShardKeyIDWithTxn added in v0.12.0 

func (r *Model2LocalRepo) ReadByP1ShardKeyIDWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	p1 string, shardKey int32, id int64, m *Model2,
) (*Model2, error)

func (*Model2LocalRepo) ReadWithTxn added in v0.12.0 

func (r *Model2LocalRepo) ReadWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	id int64, shardKey int32, p1 string, m *Model2,
) (*Model2, error)

func (*Model2LocalRepo) Save added in v0.12.0 

func (r *Model2LocalRepo) Save(m *Model2) error

func (*Model2LocalRepo) SaveWithTxn added in v0.12.0 

func (r *Model2LocalRepo) SaveWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, m *Model2,
) (err error)

func (*Model2LocalRepo) Update added in v0.12.0 

func (r *Model2LocalRepo) Update(id int64, shardKey int32, p1 string, m *Model2) error

func (*Model2LocalRepo) UpdateWithTxn added in v0.12.0 

func (r *Model2LocalRepo) UpdateWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, m *Model2,
) error

type Model2P1ShardKeyIDPK added in v0.12.0 

type Model2P1ShardKeyIDPK struct {
	P1       string
	ShardKey int32
	ID       int64
}

type Model2P1ShardKeyIDPartKey added in v0.12.6 

type Model2P1ShardKeyIDPartKey struct {
	P1 string
}

type Model2PK added in v0.12.0 

type Model2PK struct {
	ID       int64
	ShardKey int32
	P1       string
}

type Model2PartKey added in v0.12.1 

type Model2PartKey struct {
	ID       int64
	ShardKey int32
}

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) Clone added in v0.12.0 

func (x *Model3) Clone() *Model3

func (*Model3) DeepCopy added in v0.11.1 

func (x *Model3) DeepCopy(z *Model3)

func (*Model3) Descriptor deprecated added in v0.11.1 

func (*Model3) Descriptor() ([]byte, []int)

Deprecated: Use Model3.ProtoReflect.Descriptor instead.

func (*Model3) GetID added in v0.11.1 

func (x *Model3) GetID() int64

func (*Model3) GetP1 added in v0.11.1 

func (x *Model3) GetP1() []byte

func (*Model3) GetP2 added in v0.11.1 

func (x *Model3) GetP2() []string

func (*Model3) GetP5 added in v0.11.1 

func (x *Model3) GetP5() [][]byte

func (*Model3) GetShardKey added in v0.11.1 

func (x *Model3) GetShardKey() int32

func (*Model3) HasP2 added in v0.11.1 

func (x *Model3) HasP2(xx string) bool

func (*Model3) HasP5 added in v0.11.1 

func (x *Model3) HasP5(xx []byte) bool

func (*Model3) Marshal added in v0.11.1 

func (x *Model3) Marshal() ([]byte, error)

func (*Model3) MarshalJSON added in v0.11.1 

func (x *Model3) MarshalJSON() ([]byte, error)

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) Reset added in v0.11.1 

func (x *Model3) Reset()

func (*Model3) String added in v0.11.1 

func (x *Model3) String() string

func (*Model3) Unmarshal added in v0.11.1 

func (x *Model3) Unmarshal(b []byte) error

func (*Model3) UnmarshalJSON added in v0.11.1 

func (x *Model3) UnmarshalJSON(b []byte) error

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) Get added in v0.12.34 

func (r *Model3GlobalRepo) Get(id int64, shardKey int32, p1 []byte, m *Model3) (*Model3, error)

func (*Model3GlobalRepo) GetByP1IDShardKey added in v0.12.34 

func (r *Model3GlobalRepo) GetByP1IDShardKey(p1 []byte, id int64, shardKey int32, m *Model3) (*Model3, error)

func (*Model3GlobalRepo) GetByP1ShardKeyID added in v0.12.34 

func (r *Model3GlobalRepo) GetByP1ShardKeyID(p1 []byte, shardKey int32, id int64, m *Model3) (*Model3, error)

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 *store.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 (r *Model3LocalRepo) CreateWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, m *Model3,
) (err error)

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 (r *Model3LocalRepo) DeleteWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	id int64, shardKey int32, p1 []byte,
) error

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) Read added in v0.12.0 

func (r *Model3LocalRepo) Read(id int64, shardKey int32, p1 []byte, m *Model3) (*Model3, error)

func (*Model3LocalRepo) ReadByP1IDShardKey added in v0.12.6 

func (r *Model3LocalRepo) ReadByP1IDShardKey(p1 []byte, id int64, shardKey int32, m *Model3) (*Model3, error)

func (*Model3LocalRepo) ReadByP1IDShardKeyWithTxn added in v0.12.6 

func (r *Model3LocalRepo) ReadByP1IDShardKeyWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	p1 []byte, id int64, shardKey int32, m *Model3,
) (*Model3, error)

func (*Model3LocalRepo) ReadByP1ShardKeyID added in v0.12.0 

func (r *Model3LocalRepo) ReadByP1ShardKeyID(p1 []byte, shardKey int32, id int64, m *Model3) (*Model3, error)

func (*Model3LocalRepo) ReadByP1ShardKeyIDWithTxn added in v0.12.0 

func (r *Model3LocalRepo) ReadByP1ShardKeyIDWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	p1 []byte, shardKey int32, id int64, m *Model3,
) (*Model3, error)

func (*Model3LocalRepo) ReadWithTxn added in v0.12.0 

func (r *Model3LocalRepo) ReadWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	id int64, shardKey int32, p1 []byte, m *Model3,
) (*Model3, error)

func (*Model3LocalRepo) Save added in v0.12.0 

func (r *Model3LocalRepo) Save(m *Model3) error

func (*Model3LocalRepo) SaveWithTxn added in v0.12.0 

func (r *Model3LocalRepo) SaveWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, m *Model3,
) (err error)

func (*Model3LocalRepo) Update added in v0.12.0 

func (r *Model3LocalRepo) Update(id int64, shardKey int32, p1 []byte, m *Model3) error

func (*Model3LocalRepo) UpdateWithTxn added in v0.12.0 

func (r *Model3LocalRepo) UpdateWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator, m *Model3,
) error

type Model3P1IDShardKeyPK added in v0.12.6 

type Model3P1IDShardKeyPK struct {
	P1       []byte
	ID       int64
	ShardKey int32
}

type Model3P1IDShardKeyPartKey added in v0.12.6 

type Model3P1IDShardKeyPartKey struct {
	P1 []byte
}

type Model3P1ShardKeyIDPK added in v0.12.0 

type Model3P1ShardKeyIDPK struct {
	P1       []byte
	ShardKey int32
	ID       int64
}

type Model3P1ShardKeyIDPartKey added in v0.12.6 

type Model3P1ShardKeyIDPartKey struct {
	P1 []byte
}

type Model3PK added in v0.12.0 

type Model3PK struct {
	ID       int64
	ShardKey int32
	P1       []byte
}

type Model3PartKey added in v0.12.1 

type Model3PartKey struct {
	ID       int64
	ShardKey int32
}

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
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.