noop

Documentation

Index

• type PBQNoOpStore
  • func NewPBQNoOpStore() (*PBQNoOpStore, error)
  • func (p *PBQNoOpStore) Close() error
  • func (p *PBQNoOpStore) GC() error
  • func (p *PBQNoOpStore) Read(size int64) ([]*isb.Message, bool, error)
  • func (p *PBQNoOpStore) Write(msg *isb.Message) error

Types

type PBQNoOpStore

type PBQNoOpStore struct {
}

PBQNoOpStore is a no-op pbq store which does not do any operation but can be safely invoked.

func NewPBQNoOpStore

func NewPBQNoOpStore() (*PBQNoOpStore, error)

func (*PBQNoOpStore) Close

func (p *PBQNoOpStore) Close() error

func (*PBQNoOpStore) GC

func (p *PBQNoOpStore) GC() error

func (*PBQNoOpStore) Read

func (p *PBQNoOpStore) Read(size int64) ([]*isb.Message, bool, error)

func (*PBQNoOpStore) Write

func (p *PBQNoOpStore) Write(msg *isb.Message) error