archive

Documentation

Index

• type Archive
  • func Open(ctx context.Context, log *slog.Logger, opts OpenOptions) (*Archive, error)
  • func (a *Archive) Append(ctx context.Context, sm *statemate.StateMate[uint64]) error
  • func (a *Archive) Read(ctx context.Context, from, count uint64, ...) error
• type CacheManager
  • func NewCacheManager(cacheSizeLimit uint64) *CacheManager
• type OpenOptions

Types

type Archive

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

func Open

func Open(
	ctx context.Context,
	log *slog.Logger,
	opts OpenOptions,
) (*Archive, error)

func (*Archive) Append

func (a *Archive) Append(ctx context.Context, sm *statemate.StateMate[uint64]) error

func (*Archive) Read

func (a *Archive) Read(
	ctx context.Context,
	from, count uint64,
	readFn func(ctx context.Context, index uint64, data []byte) error,
) error

type CacheManager

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

func NewCacheManager

func NewCacheManager(cacheSizeLimit uint64) *CacheManager

type OpenOptions

type OpenOptions struct {
	S3Client     *s3.Client
	S3Bucket     string
	Name         string
	BlobmapCache *blobmapcache.BlobmapCache
	WorkDir      string
}