persisters

Documentation

Index

• type MetadataPersister
  • func NewMetadataPersister(dbPath string) *MetadataPersister
  • func (p *MetadataPersister) DeleteHeader(ctx context.Context, name string, lastknownrecord, lastknownblock int64) (*config.Header, error)
  • func (p *MetadataPersister) GetHeader(ctx context.Context, name string) (*config.Header, error)
  • func (p *MetadataPersister) GetHeaderByLinkname(ctx context.Context, linkname string) (*config.Header, error)
  • func (p *MetadataPersister) GetHeaderChildren(ctx context.Context, name string) ([]*config.Header, error)
  • func (p *MetadataPersister) GetHeaderDirectChildren(ctx context.Context, name string, limit int) ([]*config.Header, error)
  • func (p *MetadataPersister) GetHeaders(ctx context.Context) ([]*config.Header, error)
  • func (p *MetadataPersister) GetLastIndexedRecordAndBlock(ctx context.Context, recordSize int) (int64, int64, error)
  • func (p *MetadataPersister) GetRootPath(ctx context.Context) (string, error)
  • func (p *MetadataPersister) MoveHeader(ctx context.Context, oldName string, newName string, ...) error
  • func (p *MetadataPersister) Open() error
  • func (p *MetadataPersister) PurgeAllHeaders(ctx context.Context) error
  • func (p *MetadataPersister) UpdateHeaderMetadata(ctx context.Context, dbhdr *config.Header) error
  • func (p *MetadataPersister) UpsertHeader(ctx context.Context, dbhdr *config.Header, initializing bool) error

Types

type MetadataPersister

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

func NewMetadataPersister

func NewMetadataPersister(dbPath string) *MetadataPersister

func (*MetadataPersister) DeleteHeader

func (p *MetadataPersister) DeleteHeader(ctx context.Context, name string, lastknownrecord, lastknownblock int64) (*config.Header, error)

func (*MetadataPersister) GetHeader

func (p *MetadataPersister) GetHeader(ctx context.Context, name string) (*config.Header, error)

func (*MetadataPersister) GetHeaderByLinkname

func (p *MetadataPersister) GetHeaderByLinkname(ctx context.Context, linkname string) (*config.Header, error)

func (*MetadataPersister) GetHeaderChildren

func (p *MetadataPersister) GetHeaderChildren(ctx context.Context, name string) ([]*config.Header, error)

func (*MetadataPersister) GetHeaderDirectChildren

func (p *MetadataPersister) GetHeaderDirectChildren(ctx context.Context, name string, limit int) ([]*config.Header, error)

func (*MetadataPersister) GetHeaders

func (p *MetadataPersister) GetHeaders(ctx context.Context) ([]*config.Header, error)

func (*MetadataPersister) GetLastIndexedRecordAndBlock

func (p *MetadataPersister) GetLastIndexedRecordAndBlock(ctx context.Context, recordSize int) (int64, int64, error)

func (*MetadataPersister) GetRootPath

func (p *MetadataPersister) GetRootPath(ctx context.Context) (string, error)

func (*MetadataPersister) MoveHeader

func (p *MetadataPersister) MoveHeader(ctx context.Context, oldName string, newName string, lastknownrecord, lastknownblock int64) error

func (*MetadataPersister) Open

func (p *MetadataPersister) Open() error

func (*MetadataPersister) PurgeAllHeaders

func (p *MetadataPersister) PurgeAllHeaders(ctx context.Context) error

func (*MetadataPersister) UpdateHeaderMetadata

func (p *MetadataPersister) UpdateHeaderMetadata(ctx context.Context, dbhdr *config.Header) error

func (*MetadataPersister) UpsertHeader

func (p *MetadataPersister) UpsertHeader(ctx context.Context, dbhdr *config.Header, initializing bool) error