pubsub

type Consumer[T any] struct {
	// contains filtered or unexported fields
}

type MessageHandler[T any, Attributes map[string]string] func(message T, Attributes map[string]string) error

type PubSubBlockDefinition struct {
	Kind     string          `json:"kind"`
	Metadata model.Metadata  `json:"metadata"`
	Spec     PubSubBlockSpec `json:"spec"`
}

type PubSubBlockSpec struct {
	Providers []PubSubProviderConsumer `json:"providers"`
	Consumers []PubSubProviderConsumer `json:"consumers"`
}

type PubSubProviderConsumer struct {
	Metadata model.ResourceMetadata      `json:"metadata"`
	Spec     PubSubTopicSubscriptionSpec `json:"spec"`
}

type PubSubTopicSubscriptionSpec struct {
	Topic        string `json:"topic"`
	Subscription string `json:"subscription"`
}

type Publisher[DataType any, Headers map[string]string] struct {
	// contains filtered or unexported fields
}

type PublisherPayload[DataType any, Headers map[string]string] struct {
	DataType DataType          `json:"data"`
	Headers  map[string]string `json:"headers"`
}