model

package
v0.12.4 Latest Latest
Warning

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

 Go to latest Published: Jul 15, 2021 License: BSD-3-Clause Imports: 15 Imported by: 0

Documentation

Index

Constants

View Source 
const C_Model1 int64 = 2074613123
View Source 
const C_Model2 int64 = 3802219577
View Source 
const C_Model3 int64 = 2510714031

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 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 (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, pk 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, pk 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 Model1PrimaryKey added in v0.12.2 

type Model1PrimaryKey interface {
	// contains filtered or unexported methods
}

type Model1RemoteRepo added in v0.12.0 

type Model1RemoteRepo struct {
	// contains filtered or unexported fields
}

func NewModel1RemoteRepo added in v0.12.0 

func NewModel1RemoteRepo(s gocqlx.Session) *Model1RemoteRepo

func (*Model1RemoteRepo) CustomerSort added in v0.12.0 

func (r *Model1RemoteRepo) CustomerSort() *table.Table

func (*Model1RemoteRepo) Delete added in v0.12.0 

func (r *Model1RemoteRepo) Delete(id int32, shardKey int32, enum Enum) error

func (*Model1RemoteRepo) Get added in v0.12.0 

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

func (*Model1RemoteRepo) GetByCustomerSort added in v0.12.0 

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

func (*Model1RemoteRepo) Insert added in v0.12.0 

func (r *Model1RemoteRepo) Insert(m *Model1, replace bool) error

func (*Model1RemoteRepo) List added in v0.12.0 

func (r *Model1RemoteRepo) List(pk Model1PrimaryKey, limit uint) ([]*Model1, error)

func (*Model1RemoteRepo) T added in v0.12.0 

func (r *Model1RemoteRepo) T() *table.Table

func (*Model1RemoteRepo) Table added in v0.12.0 

func (r *Model1RemoteRepo) Table() *table.Table

func (*Model1RemoteRepo) Update added in v0.12.0 

func (r *Model1RemoteRepo) Update(m *Model1) error

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 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 (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, pk 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, pk 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 Model2PK added in v0.12.0 

type Model2PK struct {
	ID       int64
	ShardKey int32
	P1       string
}

type Model2PrimaryKey added in v0.12.2 

type Model2PrimaryKey interface {
	// contains filtered or unexported methods
}

type Model2RemoteRepo added in v0.12.0 

type Model2RemoteRepo struct {
	// contains filtered or unexported fields
}

func NewModel2RemoteRepo added in v0.12.0 

func NewModel2RemoteRepo(s gocqlx.Session) *Model2RemoteRepo

func (*Model2RemoteRepo) Delete added in v0.12.0 

func (r *Model2RemoteRepo) Delete(id int64, shardKey int32, p1 string) error

func (*Model2RemoteRepo) Get added in v0.12.0 

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

func (*Model2RemoteRepo) GetByP1ShardKeyID added in v0.12.0 

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

func (*Model2RemoteRepo) Insert added in v0.12.0 

func (r *Model2RemoteRepo) Insert(m *Model2, replace bool) error

func (*Model2RemoteRepo) List added in v0.12.0 

func (r *Model2RemoteRepo) List(pk Model2PrimaryKey, limit uint) ([]*Model2, error)

func (*Model2RemoteRepo) MVP1ShardKeyID added in v0.12.0 

func (r *Model2RemoteRepo) MVP1ShardKeyID() *table.Table

func (*Model2RemoteRepo) T added in v0.12.0 

func (r *Model2RemoteRepo) T() *table.Table

func (*Model2RemoteRepo) Table added in v0.12.0 

func (r *Model2RemoteRepo) Table() *table.Table

func (*Model2RemoteRepo) Update added in v0.12.0 

func (r *Model2RemoteRepo) Update(m *Model2) error

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 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 (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, pk 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, pk 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) ReadByP1ID added in v0.12.0 

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

func (*Model3LocalRepo) ReadByP1IDWithTxn added in v0.12.0 

func (r *Model3LocalRepo) ReadByP1IDWithTxn(
	txn *rony.StoreTxn, alloc *tools.Allocator,
	p1 []byte, id int64, 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 Model3P1IDPK added in v0.12.0 

type Model3P1IDPK struct {
	P1 []byte
	ID int64
}

type Model3P1ShardKeyIDPK added in v0.12.0 

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

type Model3PK added in v0.12.0 

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

type Model3PrimaryKey added in v0.12.2 

type Model3PrimaryKey interface {
	// contains filtered or unexported methods
}

type Model3RemoteRepo added in v0.12.0 

type Model3RemoteRepo struct {
	// contains filtered or unexported fields
}

func NewModel3RemoteRepo added in v0.12.0 

func NewModel3RemoteRepo(s gocqlx.Session) *Model3RemoteRepo

func (*Model3RemoteRepo) Delete added in v0.12.0 

func (r *Model3RemoteRepo) Delete(id int64, shardKey int32, p1 []byte) error

func (*Model3RemoteRepo) Get added in v0.12.0 

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

func (*Model3RemoteRepo) GetByP1ID added in v0.12.0 

func (r *Model3RemoteRepo) GetByP1ID(p1 []byte, id int64, m *Model3) (*Model3, error)

func (*Model3RemoteRepo) GetByP1ShardKeyID added in v0.12.0 

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

func (*Model3RemoteRepo) Insert added in v0.12.0 

func (r *Model3RemoteRepo) Insert(m *Model3, replace bool) error

func (*Model3RemoteRepo) List added in v0.12.0 

func (r *Model3RemoteRepo) List(pk Model3PrimaryKey, limit uint) ([]*Model3, error)

func (*Model3RemoteRepo) MVP1ID added in v0.12.0 

func (r *Model3RemoteRepo) MVP1ID() *table.Table

func (*Model3RemoteRepo) MVP1ShardKeyID added in v0.12.0 

func (r *Model3RemoteRepo) MVP1ShardKeyID() *table.Table

func (*Model3RemoteRepo) T added in v0.12.0 

func (r *Model3RemoteRepo) T() *table.Table

func (*Model3RemoteRepo) Table added in v0.12.0 

func (r *Model3RemoteRepo) Table() *table.Table

func (*Model3RemoteRepo) Update added in v0.12.0 

func (r *Model3RemoteRepo) Update(m *Model3) error

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.