broker

Documentation

Index

• func Consume(ctx context.Context, topic string) <-chan Message
• func Publish(ctx context.Context, topic string, msg []byte) (string, error)
• func Register(i Interface) error
• type Interface
• type Message

Functions

func Consume

func Consume(ctx context.Context, topic string) <-chan Message

func Publish

func Publish(ctx context.Context, topic string, msg []byte) (string, error)

func Register

func Register(i Interface) error

Types

type Interface

type Interface interface {
	Publish(ctx context.Context, topic string, msg []byte) (string, error)
	Consume(ctx context.Context, topic string) <-chan Message
}

type Message

type Message interface {
	Payload() []byte
	Commit() error
}