subscriber

Documentation

Index

• func RegisterGoCloudSubscribers(ctx context.Context) error
• func RegisterRedisSubscribers(ctx context.Context) error
• func RegisterSubscriber(ctx context.Context, scheme string, f SubscriberInitializeFunc) error
• func RegisterTailFileSubscribers(ctx context.Context) error
• func RegisterTickerSubscribers(ctx context.Context) error
• func SubscriberSchemes() []string
• type ChannelSubscriber
  • func (sub *ChannelSubscriber) Close() error
  • func (sub *ChannelSubscriber) Listen(ctx context.Context, messages_ch chan string) error
• type GoCloudSubscriber
  • func (sub *GoCloudSubscriber) Close() error
  • func (sub *GoCloudSubscriber) Listen(ctx context.Context, msg_ch chan string) error
• type RedisSubscriber
  • func (s *RedisSubscriber) Close() error
  • func (s *RedisSubscriber) Listen(ctx context.Context, messages_ch chan string) error
• type Subscriber
  • func NewChannelSubscriberWithChannel(ctx context.Context, ch chan string) (Subscriber, error)
  • func NewGoCloudSubscriber(ctx context.Context, uri string) (Subscriber, error)
  • func NewRedisSubscriber(ctx context.Context, uri string) (Subscriber, error)
  • func NewSubscriber(ctx context.Context, uri string) (Subscriber, error)
  • func NewTailFileSubscriber(ctx context.Context, uri string) (Subscriber, error)
  • func NewTickerSubscriber(ctx context.Context, uri string) (Subscriber, error)
• type SubscriberInitializeFunc
• type TailFileSubscriber
  • func (pub *TailFileSubscriber) Close() error
  • func (sub *TailFileSubscriber) Listen(ctx context.Context, messages_ch chan string) error
• type TickerSubscriber
  • func (sub *TickerSubscriber) Close() error
  • func (sub *TickerSubscriber) Listen(ctx context.Context, messages_ch chan string) error

Functions

func RegisterGoCloudSubscribers

func RegisterGoCloudSubscribers(ctx context.Context) error

func RegisterRedisSubscribers

func RegisterRedisSubscribers(ctx context.Context) error

func RegisterSubscriber

func RegisterSubscriber(ctx context.Context, scheme string, f SubscriberInitializeFunc) error

func RegisterTailFileSubscribers

func RegisterTailFileSubscribers(ctx context.Context) error

func RegisterTickerSubscribers

func RegisterTickerSubscribers(ctx context.Context) error

func SubscriberSchemes

func SubscriberSchemes() []string

Types

type ChannelSubscriber

type ChannelSubscriber struct {
	Subscriber
	// contains filtered or unexported fields
}

func (*ChannelSubscriber) Close

func (sub *ChannelSubscriber) Close() error

func (*ChannelSubscriber) Listen

func (sub *ChannelSubscriber) Listen(ctx context.Context, messages_ch chan string) error

type GoCloudSubscriber

type GoCloudSubscriber struct {
	Subscriber
	// contains filtered or unexported fields
}

func (*GoCloudSubscriber) Close

func (sub *GoCloudSubscriber) Close() error

func (*GoCloudSubscriber) Listen

func (sub *GoCloudSubscriber) Listen(ctx context.Context, msg_ch chan string) error

type RedisSubscriber

type RedisSubscriber struct {
	Subscriber
	// contains filtered or unexported fields
}

func (*RedisSubscriber) Close

func (s *RedisSubscriber) Close() error

func (*RedisSubscriber) Listen

func (s *RedisSubscriber) Listen(ctx context.Context, messages_ch chan string) error

type Subscriber

type Subscriber interface {
	Listen(context.Context, chan string) error
	Close() error
}

func NewChannelSubscriberWithChannel

func NewChannelSubscriberWithChannel(ctx context.Context, ch chan string) (Subscriber, error)

func NewGoCloudSubscriber

func NewGoCloudSubscriber(ctx context.Context, uri string) (Subscriber, error)

func NewRedisSubscriber

func NewRedisSubscriber(ctx context.Context, uri string) (Subscriber, error)

func NewSubscriber

func NewSubscriber(ctx context.Context, uri string) (Subscriber, error)

func NewTailFileSubscriber

func NewTailFileSubscriber(ctx context.Context, uri string) (Subscriber, error)

func NewTickerSubscriber

func NewTickerSubscriber(ctx context.Context, uri string) (Subscriber, error)

type SubscriberInitializeFunc

type SubscriberInitializeFunc func(ctx context.Context, uri string) (Subscriber, error)

type TailFileSubscriber

type TailFileSubscriber struct {
	Subscriber
	// contains filtered or unexported fields
}

func (*TailFileSubscriber) Close

func (pub *TailFileSubscriber) Close() error

func (*TailFileSubscriber) Listen

func (sub *TailFileSubscriber) Listen(ctx context.Context, messages_ch chan string) error

type TickerSubscriber

type TickerSubscriber struct {
	Subscriber
	// contains filtered or unexported fields
}

func (*TickerSubscriber) Close

func (sub *TickerSubscriber) Close() error

func (*TickerSubscriber) Listen

func (sub *TickerSubscriber) Listen(ctx context.Context, messages_ch chan string) error