storage

Documentation

Index

• type ClauseBuilder
  • func NewClauseBuilder() *ClauseBuilder
  • func (b *ClauseBuilder) AddError(error) error
  • func (b *ClauseBuilder) AddVar(w clause.Writer, values ...interface{})
  • func (b *ClauseBuilder) WriteQuoted(field interface{})
• type DatabaseStorage
  • func NewDatabaseStorage(db *gorm.DB, table string, readOnly bool) *DatabaseStorage
  • func (s *DatabaseStorage) Count(ctx context.Context, name string, condition *sharding.Condition) int64
  • func (s *DatabaseStorage) Del(ctx context.Context, name string, condition *sharding.Condition)
  • func (s *DatabaseStorage) Exist(ctx context.Context, name string, condition *sharding.Condition) bool
  • func (s *DatabaseStorage) Get(ctx context.Context, name string, condition *sharding.Condition, ...) ([]*sharding.Item, error)
  • func (s *DatabaseStorage) Put(ctx context.Context, name string, condition *sharding.Condition, ...) error
• type MemoryStorage
  • func NewMemoryStorage() *MemoryStorage
  • func (s *MemoryStorage) Count(ctx context.Context, name string, condition *sharding.Condition) int64
  • func (s *MemoryStorage) Del(ctx context.Context, name string, condition *sharding.Condition)
  • func (s *MemoryStorage) Exist(ctx context.Context, name string, condition *sharding.Condition) bool
  • func (s *MemoryStorage) Get(ctx context.Context, name string, condition *sharding.Condition, ...) ([]*sharding.Item, error)
  • func (s *MemoryStorage) Put(ctx context.Context, name string, condition *sharding.Condition, ...) error

Types

type ClauseBuilder

type ClauseBuilder struct {
	bytes.Buffer
}

func NewClauseBuilder

func NewClauseBuilder() *ClauseBuilder

func (*ClauseBuilder) AddError

func (b *ClauseBuilder) AddError(error) error

func (*ClauseBuilder) AddVar

func (b *ClauseBuilder) AddVar(w clause.Writer, values ...interface{})

func (*ClauseBuilder) WriteQuoted

func (b *ClauseBuilder) WriteQuoted(field interface{})

type DatabaseStorage

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

func NewDatabaseStorage

func NewDatabaseStorage(db *gorm.DB, table string, readOnly bool) *DatabaseStorage

func (*DatabaseStorage) Count

func (s *DatabaseStorage) Count(ctx context.Context, name string, condition *sharding.Condition) int64

func (*DatabaseStorage) Del

func (s *DatabaseStorage) Del(ctx context.Context, name string, condition *sharding.Condition)

func (*DatabaseStorage) Exist

func (s *DatabaseStorage) Exist(ctx context.Context, name string, condition *sharding.Condition) bool

func (*DatabaseStorage) Get

func (s *DatabaseStorage) Get(ctx context.Context, name string, condition *sharding.Condition, offset, limit int) ([]*sharding.Item, error)

func (*DatabaseStorage) Put

func (s *DatabaseStorage) Put(ctx context.Context, name string, condition *sharding.Condition, items []*sharding.Item) error

type MemoryStorage

type MemoryStorage struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewMemoryStorage

func NewMemoryStorage() *MemoryStorage

func (*MemoryStorage) Count

func (s *MemoryStorage) Count(ctx context.Context, name string, condition *sharding.Condition) int64

func (*MemoryStorage) Del

func (s *MemoryStorage) Del(ctx context.Context, name string, condition *sharding.Condition)

func (*MemoryStorage) Exist

func (s *MemoryStorage) Exist(ctx context.Context, name string, condition *sharding.Condition) bool

func (*MemoryStorage) Get

func (s *MemoryStorage) Get(ctx context.Context, name string, condition *sharding.Condition, offset, limit int) ([]*sharding.Item, error)

func (*MemoryStorage) Put

func (s *MemoryStorage) Put(ctx context.Context, name string, condition *sharding.Condition, items []*sharding.Item) error