event

Documentation

Index

• type Broker
  • func NewNopBroker() Broker
• type Publisher
• type Subscriber
• type TaskQueued

Types

type Broker

type Broker interface {
	Publisher
	Subscriber
}

A Broker publishes events and subscribes to them.

func NewNopBroker

func NewNopBroker() Broker

NewNopBroker returns a broker that does nothing.

type Publisher

type Publisher interface {
	Publish(context.Context, []byte) error
}

A Publisher broadcasts events to a topic.

type Subscriber

type Subscriber interface {
	Subscribe(topic string, handler func(context.Context, []byte)) error
}

A Subscriber registers event handlers for events received on a topic.

type TaskQueued

type TaskQueued struct {
	Target      *ent.Target
	Task        *ent.Task
	Credentials []*ent.Credential
	Tags        []*ent.Tag
}

TaskQueued is a struct used to serialize a Task Queued event to pubsub