trans

Dec 12, 2022

Changes in this version

+ type QuicClient struct

+ func NewQuicClient(ctx context.Context, target string, connNum int) *QuicClient

+ func (tc *QuicClient) AllKeysChan(startKey string) (chan string, error)

+ func (tc *QuicClient) CheckSum(key string) (string, error)

+ func (tc *QuicClient) Close()

+ func (tc *QuicClient) Delete(key string) error

+ func (tc *QuicClient) Get(key string) ([]byte, error)

+ func (tc *QuicClient) Has(key string) (bool, error)

+ func (tc *QuicClient) Put(key string, value []byte) error

+ func (tc *QuicClient) Size(key string) (int, error)

+ func (tc *QuicClient) TargetActive() bool

+ type QuicServ struct

+ func NewQuicServ(ctx context.Context, addr string, db kv.KVDB) (*QuicServ, error)

+ func (s *QuicServ) Close()

type Reply

+ func (r *Reply) DumpQuic(w quic.Stream) (n int, err error)

Dec 10, 2022

Changes in this version

+ const QUIC_PROTOCOL

Jul 21, 2022

Changes in this version

+ const VBUF_1M

+ const VBUF_4M

+ func SetVBuf4M()

type Client

+ CheckSum func(string) (string, error)

type ErasureClient

+ func (ec *ErasureClient) CheckSum(key string) (string, error)

type TransClient

+ func (tc *TransClient) CheckSum(key string) (string, error)

Jun 1, 2022

Changes in this version

+ const RecoverMode

+ func ErasueRecover(shards [][]byte, dataShards int, parShards int) (data [][]byte, err error)

+ type ClientWithInfo struct

+ Client Client

+ Index int

+ Recover bool

+ type RecoverClient struct

+ func NewRecoverClient(chunkClients []*ClientWithInfo, dataShards, parShards int) (*RecoverClient, error)

+ func (ec *RecoverClient) Close()

+ func (ec *RecoverClient) ExportAllKeys(startKey, pathToAllKeys string) error

+ func (ec *RecoverClient) Recover(startKey string) (err error)

+ func (ec *RecoverClient) RecoverCheck(pathToAllKeys, pathToUnrecoverKeys string) (err error)

+ func (ec *RecoverClient) RecoverFromFile(startKey, pathToAllKeys string) (err error)

+ func (ec *RecoverClient) RecoverKey(key string) (err error)

type Reply

+ func (r *Reply) Dump(w net.Conn) (n int, err error)

May 16, 2022

Changes in this version

+ var ErrMsgFormat = fmt.Errorf("message format broken")

+ var ErrNotFound = fmt.Errorf("trans - key not found")

+ var ErrReplyFormat = fmt.Errorf("reply format broken")

+ var ErrTimeout = fmt.Errorf("read or write timeout")

+ var ReadBodyTimeout = time.Second * 20

+ var ReadHeaderTimeout = time.Second * 15

+ var WriteBodyTimeout = time.Second * 20

+ var WriteHeaderTimeout = time.Second * 15

+ func ErasueDecode(shards [][]byte, dataShards int, parShards int) (data []byte, err error)

+ func ErasueEncode(data []byte, dataShards int, parShards int) (shards [][]byte, err error)

+ func NewEraBS(esclient Client, batch int) (*blostore, error)

+ func NewErasureBlockstore(ctx context.Context, servAddrs []string, connNum int, ...) (*blostore, error)

+ type Chunker struct

+ func NewChunker(r io.Reader, size int) *Chunker

+ func (k *Chunker) NextBytes() ([]byte, error)

+ type Client interface

+ AllKeysChan func(string) (chan string, error)

+ Close func()

+ Delete func(string) error

+ Get func(string) ([]byte, error)

+ Has func(string) (bool, error)

+ Put func(string, []byte) error

+ Size func(string) (int, error)

+ TargetActive func() bool

+ type ErasureClient struct

+ func NewErasureClient(chunkClients []Client, dataShards, parShards int) (*ErasureClient, error)

+ func (ec *ErasureClient) AllKeysChan(startKey string) (chan string, error)

+ func (ec *ErasureClient) Close()

+ func (ec *ErasureClient) Delete(key string) (err error)

+ func (ec *ErasureClient) Get(key string) (value []byte, err error)

+ func (ec *ErasureClient) Has(key string) (has bool, err error)

+ func (ec *ErasureClient) Put(key string, value []byte) (err error)

+ func (ec *ErasureClient) Size(key string) (n int, err error)

+ func (ec *ErasureClient) TargetActive() bool

+ type Head struct

+ Act action

+ KSize uint32

+ VSize uint32

+ func HeadFrom(buf []byte) (h *Head, err error)

+ type Msg struct

+ Act action

+ Key string

+ Value []byte

+ func (m *Msg) Encode() []byte

+ func (m *Msg) From(h *Head, buf []byte)

+ func (m *Msg) FromBytes(buf []byte) (err error)

+ type PServ struct

+ func NewPServ(ctx context.Context, attr string, db kv.KVDB) (*PServ, error)

+ func (s *PServ) Close()

+ type Reply struct

+ Body []byte

+ Code repcode

+ func (r *Reply) Encode() []byte

+ func (r *Reply) From(h *ReplyHead, buf []byte)

+ type ReplyHead struct

+ BodySize uint32

+ Code repcode

+ func ReplyHeadFrom(buf []byte) (h *ReplyHead, err error)

+ type TransClient struct

+ func NewTransClient(ctx context.Context, target string, connNum int) *TransClient

+ func (tc *TransClient) AllKeysChan(startKey string) (chan string, error)

+ func (tc *TransClient) Close()

+ func (tc *TransClient) Delete(key string) error

+ func (tc *TransClient) Get(key string) ([]byte, error)

+ func (tc *TransClient) Has(key string) (bool, error)

+ func (tc *TransClient) Put(key string, value []byte) error

+ func (tc *TransClient) Size(key string) (int, error)

+ func (tc *TransClient) TargetActive() bool