biz

README

Biz

Documentation

Index

• Variables
• type EtcdRepo
• type EtcdUsecase
  • func NewEtcdUsecase(repo EtcdRepo, logger log.Logger) *EtcdUsecase
  • func (s *EtcdUsecase) Delete(key string) error
  • func (s *EtcdUsecase) Get(key string) string
  • func (s *EtcdUsecase) Put(key string, value string) error
• type LevelDBRepo
• type LevelDBUsecase
  • func NewLevelDBUsecase(repo LevelDBRepo, logger log.Logger) *LevelDBUsecase
  • func (s *LevelDBUsecase) CloseDB() error
  • func (s *LevelDBUsecase) Delete(key string) error
  • func (s *LevelDBUsecase) Get(key string) ([]byte, error)
  • func (s *LevelDBUsecase) Iterator(prefix string) (map[string]string, error)
  • func (s *LevelDBUsecase) IteratorOnlyKey(prefix string) ([]string, error)
  • func (s *LevelDBUsecase) NewLevelDBCli(dbname string) error
  • func (s *LevelDBUsecase) OpenDB(bucketName string) (*leveldb.DB, error)
  • func (s *LevelDBUsecase) Set(key string, value []byte) error
  • func (s *LevelDBUsecase) State(value string) (string, error)
• type OssRepo
• type OssUsecase
  • func NewOssUsecase(repo OssRepo, logger log.Logger) *OssUsecase
  • func (s *OssUsecase) GetBytes(bucket string, key string) ([]byte, error)
  • func (s *OssUsecase) PutBytes(bucket string, key string, data []byte) error

Variables

var ProviderSet = wire.NewSet(NewEtcdUsecase, NewLevelDBUsecase, NewOssUsecase)

ProviderSet is biz providers.

Types

type EtcdRepo

type EtcdRepo interface {
	Put(ctx context.Context, key, value string) error
	Get(ctx context.Context, key string) []byte
	Delete(ctx context.Context, key string) error
	DeleteWithPrefix(ctx context.Context, prefix string) error
	GetWithPrefix(ctx context.Context, prefix string) []string
}

EtcdRepo is a Etcd repo.

type EtcdUsecase

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

EtcdUsecase is a Etcd usecase.

func NewEtcdUsecase

func NewEtcdUsecase(repo EtcdRepo, logger log.Logger) *EtcdUsecase

NewEtcdUsecase new a Etcd usecase.

func (*EtcdUsecase) Delete

func (s *EtcdUsecase) Delete(key string) error

func (*EtcdUsecase) Get

func (s *EtcdUsecase) Get(key string) string

func (*EtcdUsecase) Put

func (s *EtcdUsecase) Put(key string, value string) error

type LevelDBRepo

type LevelDBRepo interface {
	NewLevelDBCli(bucketName string) error
	Set(key string, value []byte) error
	Get(key string) ([]byte, error)
	Del(key string) error
	State(value string) (string, error)
	Iterator(prefix string) (map[string]string, error)
	IteratorOnlyKey(prefix string) ([]string, error)
	OpenDB(bucketName string) (*leveldb.DB, error)
	CloseDB() error
}

type LevelDBUsecase

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

LevelDBUsecase is a leveldb usecase.

func NewLevelDBUsecase

func NewLevelDBUsecase(repo LevelDBRepo, logger log.Logger) *LevelDBUsecase

NewLevelDBUsecase new a leveldb usecase.

func (*LevelDBUsecase) CloseDB

func (s *LevelDBUsecase) CloseDB() error

func (*LevelDBUsecase) Delete

func (s *LevelDBUsecase) Delete(key string) error

func (*LevelDBUsecase) Get

func (s *LevelDBUsecase) Get(key string) ([]byte, error)

func (*LevelDBUsecase) Iterator

func (s *LevelDBUsecase) Iterator(prefix string) (map[string]string, error)

func (*LevelDBUsecase) IteratorOnlyKey

func (s *LevelDBUsecase) IteratorOnlyKey(prefix string) ([]string, error)

func (*LevelDBUsecase) NewLevelDBCli

func (s *LevelDBUsecase) NewLevelDBCli(dbname string) error

TODO 提供给用户的接口

func (*LevelDBUsecase) OpenDB

func (s *LevelDBUsecase) OpenDB(bucketName string) (*leveldb.DB, error)

func (*LevelDBUsecase) Set

func (s *LevelDBUsecase) Set(key string, value []byte) error

func (*LevelDBUsecase) State

func (s *LevelDBUsecase) State(value string) (string, error)

type OssRepo

type OssRepo interface {
	PutBytes(bucket string, key string, data []byte) error
	GetBytes(bucket string, key string) ([]byte, error)
}

EtcdRepo is a Etcd repo.

type OssUsecase

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

EtcdUsecase is a Etcd usecase.

func NewOssUsecase

func NewOssUsecase(repo OssRepo, logger log.Logger) *OssUsecase

NewEtcdUsecase new a Etcd usecase.

func (*OssUsecase) GetBytes

func (s *OssUsecase) GetBytes(bucket string, key string) ([]byte, error)

func (*OssUsecase) PutBytes

func (s *OssUsecase) PutBytes(bucket string, key string, data []byte) error