Documentation ¶
Index ¶
- Constants
- type SealedError
- type StoreClient
- func (client *StoreClient) Append(entry []byte) error
- func (client *StoreClient) Fill(address uint64) error
- func (client *StoreClient) Listen() error
- func (client *StoreClient) Read(address uint64) error
- func (client *StoreClient) Reconfigure() error
- func (client *StoreClient) Trim(address uint64) error
- type StoreService
- func (service *StoreService) CreateSystemTable() error
- func (service *StoreService) Delete(address uint64) (bool, fmt.Stringer)
- func (service *StoreService) Listen() error
- func (service *StoreService) Read(epoch uint64, address uint64) ([]byte, fmt.Stringer)
- func (service *StoreService) Seal(epoch uint64) (bool, uint64, fmt.Stringer)
- func (service *StoreService) Write(epoch uint64, address uint64, data []byte) (bool, fmt.Stringer)
Constants ¶
View Source
const DATABASE_FILE_NAME = "corfu.db"
View Source
const SYSTEM_TABLE_NAME = ".system.store"
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SealedError ¶
type SealedError struct {
// contains filtered or unexported fields
}
func (SealedError) String ¶
func (e SealedError) String() string
type StoreClient ¶
type StoreClient struct {
// contains filtered or unexported fields
}
func NewStoreClient ¶
func NewStoreClient() *StoreClient
func (*StoreClient) Append ¶
func (client *StoreClient) Append(entry []byte) error
func (*StoreClient) Fill ¶
func (client *StoreClient) Fill(address uint64) error
func (*StoreClient) Listen ¶
func (client *StoreClient) Listen() error
func (*StoreClient) Read ¶
func (client *StoreClient) Read(address uint64) error
func (*StoreClient) Reconfigure ¶
func (client *StoreClient) Reconfigure() error
func (*StoreClient) Trim ¶
func (client *StoreClient) Trim(address uint64) error
type StoreService ¶
type StoreService struct {
// contains filtered or unexported fields
}
func New ¶
func New() *StoreService
func (*StoreService) CreateSystemTable ¶
func (service *StoreService) CreateSystemTable() error
func (*StoreService) Delete ¶
func (service *StoreService) Delete(address uint64) (bool, fmt.Stringer)
func (*StoreService) Listen ¶
func (service *StoreService) Listen() error
Click to show internal directories.
Click to hide internal directories.