dummy

Documentation

Index

• type Publisher
  • func (pub Publisher) Close() error
  • func (pub Publisher) Publish(ctx context.Context, messages ...any) error
• type Subscriber
  • func (e Subscriber) Close() error
  • func (e Subscriber) Listen(ctx context.Context) error
  • func (e Subscriber) Subscribe(ctx context.Context, r nc.Receiver) error

Types

type Publisher

type Publisher struct{}

Publisher dummy implementation

func (Publisher) Close

func (pub Publisher) Close() error

Close dummy publisher

func (Publisher) Publish

func (pub Publisher) Publish(ctx context.Context, messages ...any) error

Publish messages for dummy space

type Subscriber

type Subscriber struct{}

Subscriber struct

func (Subscriber) Close

func (e Subscriber) Close() error

Close proxy handler

func (Subscriber) Listen

func (e Subscriber) Listen(ctx context.Context) error

Listen process

func (Subscriber) Subscribe

func (e Subscriber) Subscribe(ctx context.Context, r nc.Receiver) error

Subscribe new handler