instrumented

Documentation

Index

• type AsyncMessageSink
  • func NewAsyncMessageSink(sink substrate.AsyncMessageSink, counterOpts prometheus.CounterOpts, ...) *AsyncMessageSink
  • func (ams *AsyncMessageSink) Close() error
  • func (ams *AsyncMessageSink) PublishMessages(ctx context.Context, acks chan<- substrate.Message, ...) (rerr error)
  • func (ams *AsyncMessageSink) Status() (*substrate.Status, error)
• type AsyncMessageSource
  • func NewAsyncMessageSource(source substrate.AsyncMessageSource, counterOpts prometheus.CounterOpts, ...) *AsyncMessageSource
  • func (ams *AsyncMessageSource) Close() error
  • func (ams *AsyncMessageSource) ConsumeMessages(ctx context.Context, messages chan<- substrate.Message, ...) error
  • func (ams *AsyncMessageSource) Status() (*substrate.Status, error)

Types

type AsyncMessageSink

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

AsyncMessageSink is an instrumented message sink The counter vector will have the labels "status" and "topic"

func NewAsyncMessageSink

func NewAsyncMessageSink(sink substrate.AsyncMessageSink, counterOpts prometheus.CounterOpts, topic string) *AsyncMessageSink

NewAsyncMessageSink returns a pointer to a new AsyncMessageSink

func (*AsyncMessageSink) Close

func (ams *AsyncMessageSink) Close() error

Close closes the message sink

func (*AsyncMessageSink) PublishMessages

func (ams *AsyncMessageSink) PublishMessages(ctx context.Context, acks chan<- substrate.Message, messages <-chan substrate.Message) (rerr error)

PublishMessages implements message publshing wrapped in instrumentation

func (*AsyncMessageSink) Status

func (ams *AsyncMessageSink) Status() (*substrate.Status, error)

Status returns the status of this sink, or an error if the status could not be determined.

type AsyncMessageSource

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

AsyncMessageSource is an instrumented message source The counter vector will have the labels "status" and "topic"

func NewAsyncMessageSource

func NewAsyncMessageSource(source substrate.AsyncMessageSource, counterOpts prometheus.CounterOpts, topic string) *AsyncMessageSource

NewAsyncMessageSource returns a pointer to a new AsyncMessageSource

func (*AsyncMessageSource) Close

func (ams *AsyncMessageSource) Close() error

Close closes the message source

func (*AsyncMessageSource) ConsumeMessages

func (ams *AsyncMessageSource) ConsumeMessages(ctx context.Context, messages chan<- substrate.Message, acks <-chan substrate.Message) error

ConsumeMessages implements message consuming wrapped in instrumentation

func (*AsyncMessageSource) Status

func (ams *AsyncMessageSource) Status() (*substrate.Status, error)

Status returns the status of this source, or an error if the status could not be determined.