eventbus

type Publisher interface {
	Publish(message interface{}) error
}

type SubscriptionConfig struct {
	ExpirationDays     int
	RetentionDays      int
	AckDeadlineSeconds int
}

type SubscriptionCreator interface {
	CreateSubscription(subscriptionName, topicName, endpoint string, config SubscriptionConfig) error
}

type TopicCreator interface {
	CreateTopic(topicName string) error
}

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