repository

Documentation

Index

• type WALRepository
  • func NewWALRepository() *WALRepository
  • func (repo *WALRepository) Commit(flowfile *flowfiles.Flowfile, savepoint bool) error
  • func (repo *WALRepository) Read(flowfile *flowfiles.Flowfile) (interface{}, error)
  • func (repo *WALRepository) Remove(flowfile *flowfiles.Flowfile) error
  • func (repo *WALRepository) Rollback(flowfile *flowfiles.Flowfile) error
  • func (repo *WALRepository) Write(flowfile *flowfiles.Flowfile, queueID uuid.UUID, value interface{}) error

Types

type WALRepository

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

func NewWALRepository

func NewWALRepository() *WALRepository

func (*WALRepository) Commit

func (repo *WALRepository) Commit(flowfile *flowfiles.Flowfile, savepoint bool) error

func (*WALRepository) Read

func (repo *WALRepository) Read(flowfile *flowfiles.Flowfile) (interface{}, error)

func (*WALRepository) Remove

func (repo *WALRepository) Remove(flowfile *flowfiles.Flowfile) error

func (*WALRepository) Rollback

func (repo *WALRepository) Rollback(flowfile *flowfiles.Flowfile) error

func (*WALRepository) Write

func (repo *WALRepository) Write(flowfile *flowfiles.Flowfile, queueID uuid.UUID, value interface{}) error