loopback

Documentation

Index

• Variables
• type Loopback
  • func NewLoopback(cfg service.Config, l logging.Writer) *Loopback
  • func (l *Loopback) Publish(_ context.Context, _ string, message []byte) error
  • func (l *Loopback) Subscribe(ctx context.Context, _ string) error

Variables

var LoopbackChannel = make(chan []byte) //nolint: gochecknoglobals

Types

type Loopback

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

func NewLoopback

func NewLoopback(cfg service.Config, l logging.Writer) *Loopback

func (*Loopback) Publish

func (l *Loopback) Publish(_ context.Context, _ string, message []byte) error

func (*Loopback) Subscribe

func (l *Loopback) Subscribe(ctx context.Context, _ string) error