Documentation
¶
Index ¶
- Variables
- func BusConfig() *sarama.Config
- func Main(group string)
- func OpenControlSubscription(group string) (*pubsub.Subscription, error)
- func OpenControlTopic() (*pubsub.Topic, error)
- type Builder
- func (b *Builder) Broadcast(ctx context.Context, topic *pubsub.Topic) error
- func (b *Builder) Claim(d *component.Descriptor, options any) error
- func (b *Builder) Location(location ...string)
- func (b *Builder) Metadata(metadata string)
- func (b *Builder) Name(name string)
- func (b *Builder) Observe(ctx context.Context, d *component.Descriptor, aspect string) (target *pubsub.Subscription, err error)
- type Loader
Constants ¶
This section is empty.
Variables ¶
View Source
var ( // BusBrokers provides an alternative to kafkalinker.Brokers, to allow for a // different set of brokers for footprint messages. BusBrokers []string // -footprint-brokers | $FOOTPRINT_BROKERS // ControlBus names the Kafka topic for broadcast footprints ControlBus string // -footprint-control | $FOOTPRINT_CONTROL // StatusBus names the Kafka topic for broadcast footprint statuses like // acknowledgements and errors StatusBus string // -footprint-status | $FOOTPRINT_STATUS )
Functions ¶
func BusConfig ¶
BusConfig returns a Kafka configuration for footprint bus consumers and producers. It shares kafkalinker.Config.ClientID and kafkalinker.Config.Version.
func OpenControlSubscription ¶
func OpenControlSubscription(group string) (*pubsub.Subscription, error)
func OpenControlTopic ¶
Types ¶
type Builder ¶
type Builder struct {
// contains filtered or unexported fields
}
func (*Builder) Observe ¶
func (b *Builder) Observe(ctx context.Context, d *component.Descriptor, aspect string) (target *pubsub.Subscription, err error)
Observe subscribes the author of this footprint to the target given by the provided aspect of the provided descriptor. It panics if that descriptor is not part of the footprint, or the aspect is not defined in its footprint.
Source Files
Click to show internal directories.
Click to hide internal directories.