inmem

package

v0.3.1 Latest Latest Go to latest Published: Mar 14, 2024 License: Apache-2.0 Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/enverbisevac/libs

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Config
type Option
type OptionFunc
- func (f OptionFunc) Apply(config *Config)
type PubSub
- func New(options ...Option) *PubSub

Constants ¶

This section is empty.

Variables ¶

View Source

var (
	ErrClosed = errors.New("pubsub: subscriber is closed")
)

Functions ¶

This section is empty.

Types ¶

type Config ¶

type Config struct {
	App       string
	Namespace string

	SendTimeout time.Duration
	ChannelSize int
}

type Option ¶

type Option interface {
	Apply(*Config)
}

An Option configures a pubsub instance.

func WithApp ¶

func WithApp(value string) Option

WithApp returns an option that set config app name.

func WithNamespace ¶

func WithNamespace(value string) Option

WithNamespace returns an option that set config namespace.

func WithSendTimeout ¶

func WithSendTimeout(value time.Duration) Option

WithSendTimeout specifies the pubsub send timeout after which the message is dropped.

func WithSize ¶

func WithSize(value int) Option

WithSize specifies the Go chan size in config that is used to buffer incoming messages.

type OptionFunc ¶

type OptionFunc func(*Config)

OptionFunc is a function that configures a pubsub config.

func (OptionFunc) Apply ¶

func (f OptionFunc) Apply(config *Config)

Apply calls f(config).

type PubSub ¶

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

func New ¶

func New(options ...Option) *PubSub

New create an instance of memory pubsub implementation.

func (*PubSub) Close ¶

func (r *PubSub) Close(_ context.Context) error

func (*PubSub) Publish ¶

func (ps *PubSub) Publish(ctx context.Context, topic string, payload []byte, opts ...pubsub.PublishOption) error

Publish event to message broker with payload.

func (ps *PubSub) Subscribe(
	ctx context.Context,
	topic string,
	handler func(payload *pubsub.Msg) error,
	options ...pubsub.SubscribeOption,
) pubsub.Consumer

Subscribe consumer to process the event with payload.

func (*PubSub) SubscribeChan ¶

func (ps *PubSub) SubscribeChan(
	ctx context.Context,
	topic string,
	options ...pubsub.SubscribeOption,
) (pubsub.Consumer, <-chan *pubsub.Msg)

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL