mq

Documentation

Index

• type MQ
  • func New(ctx context.Context, uri string, root string, maxPending int, db *dao.DB) (*MQ, error)
  • func (mq *MQ) Close()
  • func (mq *MQ) Done() <-chan struct{}
  • func (mq *MQ) SnapsDone() <-chan struct{}
  • func (mq *MQ) StartSchemaAPI() error
  • func (mq *MQ) StartSchemaStream(stream <-chan creek.SchemaMsg) *SchemaStream
  • func (mq *MQ) StartSnapshotAPI() error
  • func (mq *MQ) StartWalStream(stream <-chan creek.WAL) *WalStream
• type SchemaStream
  • func (s *SchemaStream) Done() <-chan struct{}
• type WalStream
  • func (w *WalStream) Done() <-chan struct{}

Types

type MQ

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

func New

func New(ctx context.Context, uri string, root string, maxPending int, db *dao.DB) (*MQ, error)

func (*MQ) Close

func (mq *MQ) Close()

func (*MQ) Done

func (mq *MQ) Done() <-chan struct{}

func (*MQ) SnapsDone

func (mq *MQ) SnapsDone() <-chan struct{}

func (*MQ) StartSchemaAPI

func (mq *MQ) StartSchemaAPI() error

func (*MQ) StartSchemaStream

func (mq *MQ) StartSchemaStream(stream <-chan creek.SchemaMsg) *SchemaStream

func (*MQ) StartSnapshotAPI

func (mq *MQ) StartSnapshotAPI() error

func (*MQ) StartWalStream

func (mq *MQ) StartWalStream(stream <-chan creek.WAL) *WalStream

type SchemaStream

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

func (*SchemaStream) Done

func (s *SchemaStream) Done() <-chan struct{}

type WalStream

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

func (*WalStream) Done

func (w *WalStream) Done() <-chan struct{}