rawdb

Documentation

Index

• Constants
• type AliyunDB
  • func NewAliyunDB(endpoint, accKey, accessKeySecret, bktPrefix string) (*AliyunDB, error)
  • func (a *AliyunDB) Close() (err error)
  • func (a *AliyunDB) Delete(bucket, key string) (err error)
  • func (a *AliyunDB) Exist(bucket, key string) bool
  • func (a *AliyunDB) Get(bucket, key string) (data []byte, err error)
  • func (a *AliyunDB) GetAllKey(bucket string) (keys []string, err error)
  • func (a *AliyunDB) GetStream(bucket, key string) (data *os.File, err error)
  • func (a *AliyunDB) Put(bucket, key string, value interface{}) (err error)
  • func (a *AliyunDB) Type() string
• type BoltDB
  • func NewBoltDB(boltDirPath string) (*BoltDB, error)
  • func (s *BoltDB) Close() (err error)
  • func (s *BoltDB) Delete(bucket, key string) (err error)
  • func (s *BoltDB) Exist(bucket, key string) bool
  • func (s *BoltDB) Get(bucket, key string) (data []byte, err error)
  • func (s *BoltDB) GetAllKey(bucket string) (keys []string, err error)
  • func (s *BoltDB) GetStream(bucket, key string) (data *os.File, err error)
  • func (s *BoltDB) Put(bucket, key string, value interface{}) (err error)
  • func (s *BoltDB) Type() string
• type KeyValueDB
• type MongoDB
  • func NewMongoDB(ctx context.Context, uri string) (*MongoDB, error)
  • func (m *MongoDB) Close() (err error)
  • func (m *MongoDB) Delete(bucket, key string) (err error)
  • func (m *MongoDB) Exist(bucket, key string) bool
  • func (m *MongoDB) Get(bucket, key string) (data []byte, err error)
  • func (m *MongoDB) GetAllKey(bucket string) (keys []string, err error)
  • func (m *MongoDB) GetStream(bucket, key string) (data *os.File, err error)
  • func (m *MongoDB) Put(bucket, key string, value interface{}) (err error)
  • func (m *MongoDB) Type() string
• type S3DB
  • func NewS3DB(accKey, secretKey, region, bktPrefix, endpoint string) (*S3DB, error)
  • func (s *S3DB) Close() (err error)
  • func (s *S3DB) Delete(bucket, key string) (err error)
  • func (s *S3DB) Exist(bucket, key string) bool
  • func (s *S3DB) Get(bucket, key string) (data []byte, err error)
  • func (s *S3DB) GetAllKey(bucket string) (keys []string, err error)
  • func (s *S3DB) GetStream(bucket, key string) (data *os.File, err error)
  • func (s *S3DB) Put(bucket, key string, value interface{}) (err error)
  • func (s *S3DB) Type() string

Constants

const (
	K           = "_id"
	V           = "_value"
	MongoDBType = "MongoDB"
)

const (
	ForeverLandEndpoint = "https://endpoint.4everland.co"
	S3Type              = "s3"
)

const (
	AliyunType = "aliyun"
)

refer https://help.aliyun.com/document_detail/32157.html?spm=a2c4g.11186623.0.0.1a4b32bcxaC4kR

const (
	BoltType = "boltdb"
)

Types

type AliyunDB

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

func NewAliyunDB

func NewAliyunDB(endpoint, accKey, accessKeySecret, bktPrefix string) (*AliyunDB, error)

func (*AliyunDB) Close

func (a *AliyunDB) Close() (err error)

func (*AliyunDB) Delete

func (a *AliyunDB) Delete(bucket, key string) (err error)

func (*AliyunDB) Exist

func (a *AliyunDB) Exist(bucket, key string) bool

func (*AliyunDB) Get

func (a *AliyunDB) Get(bucket, key string) (data []byte, err error)

func (*AliyunDB) GetAllKey

func (a *AliyunDB) GetAllKey(bucket string) (keys []string, err error)

func (*AliyunDB) GetStream

func (a *AliyunDB) GetStream(bucket, key string) (data *os.File, err error)

func (*AliyunDB) Put

func (a *AliyunDB) Put(bucket, key string, value interface{}) (err error)

func (*AliyunDB) Type

func (a *AliyunDB) Type() string

type BoltDB

type BoltDB struct {
	Db *bolt.DB
}

func NewBoltDB

func NewBoltDB(boltDirPath string) (*BoltDB, error)

func (*BoltDB) Close

func (s *BoltDB) Close() (err error)

func (*BoltDB) Delete

func (s *BoltDB) Delete(bucket, key string) (err error)

func (*BoltDB) Exist

func (s *BoltDB) Exist(bucket, key string) bool

func (*BoltDB) Get

func (s *BoltDB) Get(bucket, key string) (data []byte, err error)

func (*BoltDB) GetAllKey

func (s *BoltDB) GetAllKey(bucket string) (keys []string, err error)

func (*BoltDB) GetStream

func (s *BoltDB) GetStream(bucket, key string) (data *os.File, err error)

func (*BoltDB) Put

func (s *BoltDB) Put(bucket, key string, value interface{}) (err error)

func (*BoltDB) Type

func (s *BoltDB) Type() string

type KeyValueDB

type KeyValueDB interface {
	Put(bucket, key string, value interface{}) (err error)

	Get(bucket, key string) (data []byte, err error)

	GetStream(bucket, key string) (data *os.File, err error)

	GetAllKey(bucket string) (keys []string, err error)

	Delete(bucket, key string) (err error)

	Close() (err error)

	Type() string

	Exist(bucket, key string) bool
}

type MongoDB

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

func NewMongoDB

func NewMongoDB(ctx context.Context, uri string) (*MongoDB, error)

NewMongoDB uri be like mongodb://user:password@localhost:27017

func (*MongoDB) Close

func (m *MongoDB) Close() (err error)

func (*MongoDB) Delete

func (m *MongoDB) Delete(bucket, key string) (err error)

func (*MongoDB) Exist

func (m *MongoDB) Exist(bucket, key string) bool

func (*MongoDB) Get

func (m *MongoDB) Get(bucket, key string) (data []byte, err error)

func (*MongoDB) GetAllKey

func (m *MongoDB) GetAllKey(bucket string) (keys []string, err error)

func (*MongoDB) GetStream

func (m *MongoDB) GetStream(bucket, key string) (data *os.File, err error)

func (*MongoDB) Put

func (m *MongoDB) Put(bucket, key string, value interface{}) (err error)

func (*MongoDB) Type

func (m *MongoDB) Type() string

type S3DB

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

func NewS3DB

func NewS3DB(accKey, secretKey, region, bktPrefix, endpoint string) (*S3DB, error)

func (*S3DB) Close

func (s *S3DB) Close() (err error)

func (*S3DB) Delete

func (s *S3DB) Delete(bucket, key string) (err error)

func (*S3DB) Exist

func (s *S3DB) Exist(bucket, key string) bool

func (*S3DB) Get

func (s *S3DB) Get(bucket, key string) (data []byte, err error)

func (*S3DB) GetAllKey

func (s *S3DB) GetAllKey(bucket string) (keys []string, err error)

func (*S3DB) GetStream

func (s *S3DB) GetStream(bucket, key string) (data *os.File, err error)

func (*S3DB) Put

func (s *S3DB) Put(bucket, key string, value interface{}) (err error)

func (*S3DB) Type

func (s *S3DB) Type() string