cache

func (*Store) Close ¶

func (b *Store) Close() error

func (*Store) RemoveAllData ¶

func (b *Store) RemoveAllData() error

func (b *bboltStore) SaveToken(token string) error {
	return b.bdb.Update(func(tx *bolt.Tx) error {
		// 如果 bucket 不存在则，创建一个 bucket
		bucket, err := tx.CreateBucketIfNotExists(StringToBytesUnsafe(b.host))
		if err != nil {
			return perr.WithMessage(err, "create bucket")
		}

		// 将 key-value 写入到 bucket 中
		err = bucket.Put(KeyToken, []byte(token))
		if err != nil {
			return perr.WithMessage(err, "bucket put")
		}
		return nil
	})
}

// Endpoint gives access to the Endpoint data management layer

func (b *bboltStore) Endpoint() *endpoint.Service {
	return b.EndpointService
}

func (b *bboltStore) GetToken() (string, error) {
	val, err := b.get(Token)
	if err != nil {
		return "", err
	}
	return BytesToString(val), nil
}

func (b *bboltStore) get(key string) ([]byte, error) {
	var result []byte
	var err error
	err = b.bdb.View(func(tx *bolt.Tx) error {
		buc := tx.Bucket(StringToBytes(b.host))

		// 将 key-value 写入到 bucket 中
		result = buc.Get(StringToBytes(key))
		return nil
	})

	if err != nil {
		return []byte{}, err
	}

	return result, nil
}

删除全部当前 host 下的数据