Documentation
¶
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func Manifold ¶
func Manifold(config ManifoldConfig) dependency.Manifold
Manifold returns a dependency manifold that runs a pubsub worker, using the resource names defined in the supplied config.
func NewWorker ¶
func NewWorker(config WorkerConfig) (worker.Worker, error)
NewWorker creates a new presence worker that responds to pubsub connection messages.
Types ¶
type Logger ¶
type Logger interface {
Errorf(message string, args ...interface{})
Infof(message string, args ...interface{})
Debugf(message string, args ...interface{})
Tracef(message string, args ...interface{})
IsTraceEnabled() bool
}
Logger represents the logging methods called.
type ManifoldConfig ¶
type ManifoldConfig struct {
AgentName string
CentralHubName string
Recorder presence.Recorder
Logger Logger
NewWorker func(WorkerConfig) (worker.Worker, error)
}
ManifoldConfig defines the names of the manifolds on which a Manifold will depend.
func (*ManifoldConfig) Validate ¶
func (c *ManifoldConfig) Validate() error
Validate ensures that the required values are set in the structure.
type WorkerConfig ¶
type WorkerConfig struct {
Origin string
Hub *pubsub.StructuredHub
Recorder presence.Recorder
Logger Logger
}
WorkerConfig defines the configuration values that the pubsub worker needs to operate.
func (*WorkerConfig) Validate ¶
func (c *WorkerConfig) Validate() error
Validate ensures that the required values are set in the structure.
Source Files
Click to show internal directories.
Click to hide internal directories.