streamhub_memory

Documentation

Overview

Package streamhub-memory is the In-Memory implementation for Streamhub-based programs.

Index

• Variables
• type Bus
  • func NewBus(maxGoroutines int) *Bus
• type ListenerDriver
  • func NewListener(b *Bus) *ListenerDriver
  • func (l *ListenerDriver) ExecuteTask(ctx context.Context, t streamhub.ListenerTask) error
• type Writer
  • func NewWriter(b *Bus) *Writer
  • func (p *Writer) Write(ctx context.Context, message streamhub.Message) error
  • func (p *Writer) WriteBatch(ctx context.Context, messages ...streamhub.Message) (err error)

Variables

var ErrBusNotStarted = errors.New("streamhub: In-memory bus has not been started")

ErrBusNotStarted The in-memory bus has not been started

Types

type Bus

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

Bus is an in-memory message broker to enable interactions between publishers and stream-listeners

func NewBus

func NewBus(maxGoroutines int) *Bus

NewBus allocates a new Bus ready to be used

type ListenerDriver

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

ListenerDriver is the streamhub.ListenerDriver in-memory implementation

func NewListener

func NewListener(b *Bus) *ListenerDriver

NewListener allocates a new ListenerDriver ready to interact with the given Bus

func (*ListenerDriver) ExecuteTask

func (l *ListenerDriver) ExecuteTask(ctx context.Context, t streamhub.ListenerTask) error

ExecuteTask starts the stream-listening job using the internal in-memory Bus

type Writer

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

Writer is the streamhub.Writer in-memory implementation

func NewWriter

func NewWriter(b *Bus) *Writer

NewWriter allocates a new Writer ready to be used with the given Bus

func (*Writer) Write

func (p *Writer) Write(ctx context.Context, message streamhub.Message) error

Write pushes the given message into the internal in-memory Bus

func (*Writer) WriteBatch

func (p *Writer) WriteBatch(ctx context.Context, messages ...streamhub.Message) (err error)

WriteBatch pushes the given set of messages into the internal in-memory Bus