etcdpubsub

Documentation

Index

• Constants
• type Config
• type EtcdPubSub
  • func New(config Config) (*EtcdPubSub, error)
  • func (ps *EtcdPubSub) Publish(ctx context.Context, topic string, msg Msg) error
  • func (ps *EtcdPubSub) Reset(ctx context.Context, topic string) error
  • func (ps *EtcdPubSub) Subscribe(ctx context.Context, topic string) (<-chan Msg, error)
  • func (ps *EtcdPubSub) SubscribeFromRev(ctx context.Context, topic string, rev int64) (<-chan Msg, error)
  • func (ps *EtcdPubSub) SubscribeFromStart(ctx context.Context, topic string) (<-chan Msg, error)
• type Msg

Constants

const DefaultTTLSeconds = 7 * 24 * 3600

Types

type Config

type Config struct {
	Client     *clientv3.Client
	Prefix     string
	TTLSeconds int
}

type EtcdPubSub

type EtcdPubSub struct {
	Config
}

func New

func New(config Config) (*EtcdPubSub, error)

func (*EtcdPubSub) Publish

func (ps *EtcdPubSub) Publish(ctx context.Context, topic string, msg Msg) error

func (*EtcdPubSub) Reset

func (ps *EtcdPubSub) Reset(ctx context.Context, topic string) error

func (*EtcdPubSub) Subscribe

func (ps *EtcdPubSub) Subscribe(ctx context.Context, topic string) (<-chan Msg, error)

Subscribe a topic from now

func (*EtcdPubSub) SubscribeFromRev

func (ps *EtcdPubSub) SubscribeFromRev(ctx context.Context, topic string, rev int64) (<-chan Msg, error)

func (*EtcdPubSub) SubscribeFromStart

func (ps *EtcdPubSub) SubscribeFromStart(ctx context.Context, topic string) (<-chan Msg, error)

Subscribe a topic from start

type Msg

type Msg struct {
	Name string
	Val  string
}