stor

Documentation

Index

• type Client
  • func NewClient(conf Config) (*Client, error)
  • func (c *Client) Close() error
  • func (c *Client) LastHash() []byte
  • func (c *Client) ProcessStore(blocks []*schema.TlogBlock) ([]byte, error)
  • func (c *Client) Walk(fromEpoch, toEpoch int64) <-chan *WalkResult
• type Config
  • func ConfigFromConfigSource(source config.Source, vdiskID, privKey string, dataShards, parityShards int) (conf Config, err error)
• type MetaClient
  • func NewMetaClient(endpoints []string) (*MetaClient, error)
  • func (cli *MetaClient) Close() error
  • func (cli *MetaClient) GetMeta(key []byte) ([]byte, error)
  • func (cli *MetaClient) SaveMeta(key, val []byte) error
• type WalkResult

Types

type Client

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

Client defines the 0-stor client

func NewClient

func NewClient(conf Config) (*Client, error)

NewClient creates new client from the given config

func (*Client) Close

func (c *Client) Close() error

func (*Client) LastHash

func (c *Client) LastHash() []byte

func (*Client) ProcessStore

func (c *Client) ProcessStore(blocks []*schema.TlogBlock) ([]byte, error)

ProcessStore processes and then stores the data to 0-stor server

func (*Client) Walk

func (c *Client) Walk(fromEpoch, toEpoch int64) <-chan *WalkResult

Walk walks the history from fromEpoch to toEpoch.

type Config

type Config struct {
	VdiskID         string
	Organization    string
	Namespace       string
	IyoClientID     string
	IyoSecret       string
	ZeroStorShards  []string
	MetaShards      []string
	DataShardsNum   int
	ParityShardsNum int
	EncryptPrivKey  string
}

Config defines the 0-stor client config

func ConfigFromConfigSource

func ConfigFromConfigSource(source config.Source, vdiskID, privKey string, dataShards, parityShards int) (conf Config, err error)

type MetaClient

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

func NewMetaClient

func NewMetaClient(endpoints []string) (*MetaClient, error)

func (*MetaClient) Close

func (cli *MetaClient) Close() error

func (*MetaClient) GetMeta

func (cli *MetaClient) GetMeta(key []byte) ([]byte, error)

func (*MetaClient) SaveMeta

func (cli *MetaClient) SaveMeta(key, val []byte) error

type WalkResult

type WalkResult struct {
	Agg *schema.TlogAggregation
	Err error
}