stream

Documentation

Index

• type Bus
• type Delta
• type Hub
  • func NewHub(bus Bus) *Hub
  • func (h *Hub) Publish(ctx context.Context, execID uuid.UUID, d Delta) error
  • func (h *Hub) Start(ctx context.Context) error
  • func (h *Hub) Subscribe(execID uuid.UUID) (<-chan Delta, func())
• type MemoryBus
  • func NewMemoryBus() *MemoryBus
  • func (b *MemoryBus) Publish(ctx context.Context, execID uuid.UUID, d Delta) error
  • func (b *MemoryBus) Start(ctx context.Context, deliver func(uuid.UUID, Delta)) error
• type PostgresBus
  • func NewPostgresBus(pool *pgxpool.Pool, log *slog.Logger) *PostgresBus
  • func (b *PostgresBus) Publish(ctx context.Context, execID uuid.UUID, d Delta) error
  • func (b *PostgresBus) Start(ctx context.Context, deliver func(execID uuid.UUID, d Delta)) error

Types

type Bus

type Bus interface {
	Publish(ctx context.Context, execID uuid.UUID, d Delta) error
	Start(ctx context.Context, deliver func(execID uuid.UUID, d Delta)) error
}

type Delta

type Delta struct {
	StepID string `json:"step_id"`
	Seq    int64  `json:"seq"`
	Data   string `json:"data"`
}

type Hub

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

func NewHub

func NewHub(bus Bus) *Hub

func (*Hub) Publish

func (h *Hub) Publish(ctx context.Context, execID uuid.UUID, d Delta) error

func (*Hub) Start

func (h *Hub) Start(ctx context.Context) error

func (*Hub) Subscribe

func (h *Hub) Subscribe(execID uuid.UUID) (<-chan Delta, func())

type MemoryBus

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

func NewMemoryBus

func NewMemoryBus() *MemoryBus

func (*MemoryBus) Publish

func (b *MemoryBus) Publish(ctx context.Context, execID uuid.UUID, d Delta) error

func (*MemoryBus) Start

func (b *MemoryBus) Start(ctx context.Context, deliver func(uuid.UUID, Delta)) error

type PostgresBus

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

func NewPostgresBus

func NewPostgresBus(pool *pgxpool.Pool, log *slog.Logger) *PostgresBus

func (*PostgresBus) Publish

func (b *PostgresBus) Publish(ctx context.Context, execID uuid.UUID, d Delta) error

func (*PostgresBus) Start

func (b *PostgresBus) Start(ctx context.Context, deliver func(execID uuid.UUID, d Delta)) error