cherami

Documentation

Index

• func NewBackend(host service.Host) (task.Backend, error)
• func RegisterHyperbahnBootstrapFile(filename string)
• type Backend
  • func (b *Backend) Encoder() task.Encoding
  • func (b *Backend) Enqueue(ctx context.Context, message []byte) error
  • func (b *Backend) ExecuteAsync() error
  • func (b *Backend) Start() error
  • func (b *Backend) Stop() error

Functions

func NewBackend

func NewBackend(host service.Host) (task.Backend, error)

NewBackend creates a Cherami client backend

func RegisterHyperbahnBootstrapFile

func RegisterHyperbahnBootstrapFile(filename string)

RegisterHyperbahnBootstrapFile registers the hyperbahn bootstrap filename required for cherami

Types

type Backend

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

Backend holds cherami data

func (*Backend) Encoder

func (b *Backend) Encoder() task.Encoding

Encoder returns an encoder for cherami messages

func (*Backend) Enqueue

func (b *Backend) Enqueue(ctx context.Context, message []byte) error

Enqueue sends the message to cherami

func (*Backend) ExecuteAsync

func (b *Backend) ExecuteAsync() error

ExecuteAsync spins off workers to consume messages and execute tasks

func (*Backend) Start

func (b *Backend) Start() error

Start the cherami pubsub

func (*Backend) Stop

func (b *Backend) Stop() error

Stop closes and cleans up cherami resources