topiccsm

Documentation

Index

• type T
  • func Spawn(parentActDesc *actor.Descriptor, group string, childSpec dispatcher.ChildSpec, ...) *T
  • func (tc *T) Messages() chan<- consumer.Message
  • func (tc *T) String() string
  • func (tc *T) Topic() string

Types

type T

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

T serves consume requests received from childSpec.Requests() channel with messages received from Messages() channel. The topic consumer expires and shuts itself down when either of the following happens:

• there has been no requests for Consumer.SubscriptionTimeout and isSafe2StopFn returns true;
• there has been no requests for max value of Consumer.SubscriptionTimeout and Consumer.AckTimeout

implements `multiplexer.Out`.

func Spawn

func Spawn(parentActDesc *actor.Descriptor, group string, childSpec dispatcher.ChildSpec,
	cfg *config.Proxy, lifespanCh chan<- *T, isSafe2StopFn func() bool,
) *T

Spawn creates and starts a topic consumer instance.

func (*T) Messages

func (tc *T) Messages() chan<- consumer.Message

implements `multiplexer.Out`

func (*T) String

func (tc *T) String() string

func (*T) Topic

func (tc *T) Topic() string

Topic returns the topic name this topic consumer is responsible for.