luigiutils

package

v0.2.1 Latest Latest Go to latest Published: Aug 5, 2021 License: MIT Imports: 7 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/cryptoscope/ssb

Links

Open Source Insights

Documentation ¶

Index ¶

func NewBendyStreamSink(w *muxrpc.ByteSink) luigi.Sink
func NewGabbyStreamSink(w *muxrpc.ByteSink) luigi.Sink
func NewSinkCounter(counter *int, sink luigi.Sink) luigi.FuncSink
type MultiSink
- func NewMultiSink(seq int64) *MultiSink

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func NewBendyStreamSink ¶ added in v0.2.1

func NewBendyStreamSink(w *muxrpc.ByteSink) luigi.Sink

func NewGabbyStreamSink ¶

func NewGabbyStreamSink(w *muxrpc.ByteSink) luigi.Sink

NewGabbyStreamSink expects the values passing through to be of type multimsg.MultiMessage it then unpacks them as gabygrove, reencodes the transfer object to bytes and passes those as muxrpc codec.Body to the wrapped sink

func NewSinkCounter ¶

func NewSinkCounter(counter *int, sink luigi.Sink) luigi.FuncSink

NewSinkCounter returns a new Sink which increases the given counter when poured to. warning: also counts errored pour calls on the wrapped sink

Types ¶

type MultiSink ¶

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

MultiSink takes each message poured into it, and passes it on to all registered sinks.

MultiSink is like luigi.Broadcaster but with context support.

func NewMultiSink ¶

func NewMultiSink(seq int64) *MultiSink

func (*MultiSink) Close ¶

func (f *MultiSink) Close() error

func (*MultiSink) Count ¶

func (f *MultiSink) Count() uint

Count returns the number of registerd sinks

func (*MultiSink) Register ¶

func (f *MultiSink) Register(
	ctx context.Context,
	sink *muxrpc.ByteSink,
	until int64,
)

Register adds a sink to propagate messages to upto the 'until'th sequence.

func (*MultiSink) Send ¶

func (f *MultiSink) Send(msg []byte)

func (*MultiSink) Seq ¶

func (f *MultiSink) Seq() int64

func (*MultiSink) Unregister ¶

func (f *MultiSink) Unregister(
	sink *muxrpc.ByteSink,
)

Source Files ¶

View all Source files

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