memstreamer

package

v0.3.2 Latest Latest Go to latest Published: Apr 25, 2025 License: BSD-3-Clause Imports: 6 Imported by: 1

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/luno/workflow

Links

Open Source Insights

Documentation ¶

Index ¶

func NewConnector(events []workflow.ConnectorEvent, opts ...Option) *connector
type Option
- func WithClock(clock clock.Clock) Option
type Stream
type StreamConstructor
- func New(opts ...Option) *StreamConstructor
- func (s StreamConstructor) NewReceiver(ctx context.Context, topic string, name string, ...) (workflow.EventReceiver, error)
- func (s StreamConstructor) NewSender(ctx context.Context, topic string) (workflow.EventSender, error)

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewConnector ¶ added in v0.1.2

func NewConnector(events []workflow.ConnectorEvent, opts ...Option) *connector

Types ¶

type Option ¶

type Option func(o *options)

func WithClock ¶

func WithClock(clock clock.Clock) Option

type Stream ¶

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

func (*Stream) Close ¶

func (s *Stream) Close() error

func (*Stream) Recv ¶

func (s *Stream) Recv(ctx context.Context) (*workflow.Event, workflow.Ack, error)

func (*Stream) Send ¶

func (s *Stream) Send(ctx context.Context, foreignID string, statusType int, headers map[workflow.Header]string) error

type StreamConstructor ¶

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

func New ¶

func New(opts ...Option) *StreamConstructor

func (StreamConstructor) NewReceiver ¶ added in v0.2.6

func (s StreamConstructor) NewReceiver(
	ctx context.Context,
	topic string,
	name string,
	opts ...workflow.ReceiverOption,
) (workflow.EventReceiver, error)

func (StreamConstructor) NewSender ¶ added in v0.2.6

func (s StreamConstructor) NewSender(ctx context.Context, topic string) (workflow.EventSender, error)

Source Files ¶

View all Source files

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