roque

README

roque

Simple message queue

Documentation

Index

• type Client
• type Dispatcher
  • func NewDispatcher(store Store) *Dispatcher
  • func (d *Dispatcher) CommitContext(ctx context.Context, clientID string, topic message.Topic, idx int) error
  • func (d *Dispatcher) ReadContext(ctx context.Context, clientID string, topic message.Topic, limit int, ...) ([]message.Message, error)
  • func (d *Dispatcher) WriteContext(ctx context.Context, topic string, msgs ...[]byte) error
• type Signal
  • func NewSignal() *Signal
  • func (s *Signal) Emit(topic string)
  • func (s *Signal) WaitContext(ctx context.Context, topic string, timeout time.Duration) bool
• type Store
  • func NewSqliteStore(dsn string) (Store, error)

Types

type Client

type Client interface {
	WriteContext(ctx context.Context, topic message.Topic, msgs ...[]byte) error
	ReadContext(ctx context.Context, clientID string, topic message.Topic, limit int, wait time.Duration) ([]message.Message, error)
	CommitContext(ctx context.Context, clientID string, topic message.Topic, idx int) error
}

type Dispatcher

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

func NewDispatcher

func NewDispatcher(store Store) *Dispatcher

func (*Dispatcher) CommitContext

func (d *Dispatcher) CommitContext(ctx context.Context, clientID string, topic message.Topic, idx int) error

func (*Dispatcher) ReadContext

func (d *Dispatcher) ReadContext(ctx context.Context, clientID string, topic message.Topic, limit int, wait time.Duration) ([]message.Message, error)

func (*Dispatcher) WriteContext

func (d *Dispatcher) WriteContext(ctx context.Context, topic string, msgs ...[]byte) error

type Signal

type Signal struct {
	sync.RWMutex
	// contains filtered or unexported fields
}

func NewSignal

func NewSignal() *Signal

func (*Signal) Emit

func (s *Signal) Emit(topic string)

func (*Signal) WaitContext

func (s *Signal) WaitContext(ctx context.Context, topic string, timeout time.Duration) bool

type Store

type Store interface {
	Append(topic string, msgs ...[]byte) error
	Commit(clientID string, topic string, idx int) error
	FetchNext(clientID string, topic string, limit int) ([]message.Message, error)
}

func NewSqliteStore

func NewSqliteStore(dsn string) (Store, error)