Versions in this module Expand all Collapse all v1 v1.0.0 Dec 7, 2025 Changes in this version + var BusBrokers []string + var ControlBus string + var StatusBus string + func BusConfig() *sarama.Config + func Main(group string) + func OpenControlSubscription(group string) (*pubsub.Subscription, error) + func OpenControlTopic() (*pubsub.Topic, error) + type Builder struct + func NewBuilder(id uuid.UUID, revision int) *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 struct + ReplicaSet string + func (x Loader) Exec(l *component.L)
Go to main page