reqstore

Documentation

Overview

Package reqstore is an implementation of the RequestStore utilized by the samples. Depending on your application, it may or may not be appropriate. In particular, if your application wants to retain the requests rather than simply apply and discard them, you may wish to write your own or adapt this one.

Index

• type Store
  • func Open(dirPath string) (*Store, error)
  • func (s *Store) Close()
  • func (s *Store) Commit(ack *msgs.RequestAck) error
  • func (s *Store) GetAllocation(clientID, reqNo uint64) ([]byte, error)
  • func (s *Store) GetRequest(requestAck *msgs.RequestAck) ([]byte, error)
  • func (s *Store) PutAllocation(clientID, reqNo uint64, digest []byte) error
  • func (s *Store) PutRequest(requestAck *msgs.RequestAck, data []byte) error
  • func (s *Store) Sync() error

Types

type Store

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

func Open

func Open(dirPath string) (*Store, error)

func (*Store) Close

func (s *Store) Close()

func (*Store) Commit

func (s *Store) Commit(ack *msgs.RequestAck) error

func (*Store) GetAllocation

func (s *Store) GetAllocation(clientID, reqNo uint64) ([]byte, error)

func (*Store) GetRequest

func (s *Store) GetRequest(requestAck *msgs.RequestAck) ([]byte, error)

func (*Store) PutAllocation

func (s *Store) PutAllocation(clientID, reqNo uint64, digest []byte) error

func (*Store) PutRequest

func (s *Store) PutRequest(requestAck *msgs.RequestAck, data []byte) error

func (*Store) Sync

func (s *Store) Sync() error