pubsubpublisher

Documentation

Index

• func GetMapFuncAnyToPublishResults(p *Publisher) func(context.Context, interface{}) (interface{}, error)
• type Publisher
  • func NewIntervalPublisher(ctx context.Context, topic *pubsub.Topic, publishInterval time.Duration) (*Publisher, error)
  • func (p *Publisher) RegisterPublishableObj(obj common.Publishable)
  • func (p *Publisher) StartPublishIntervalLoop(ctx context.Context, publishInterval time.Duration)

Functions

func GetMapFuncAnyToPublishResults

func GetMapFuncAnyToPublishResults(p *Publisher) func(context.Context, interface{}) (interface{}, error)

Types

type Publisher

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

func NewIntervalPublisher

func NewIntervalPublisher(ctx context.Context, topic *pubsub.Topic, publishInterval time.Duration) (*Publisher, error)

func (*Publisher) RegisterPublishableObj

func (p *Publisher) RegisterPublishableObj(obj common.Publishable)

func (*Publisher) StartPublishIntervalLoop

func (p *Publisher) StartPublishIntervalLoop(ctx context.Context, publishInterval time.Duration)