Documentation ¶
Overview ¶
* Copyright 2024 Kapeta Inc. * SPDX-License-Identifier: MIT
* Copyright 2024 Kapeta Inc. * SPDX-License-Identifier: MIT
* Copyright 2024 Kapeta Inc. * SPDX-License-Identifier: MIT
* Copyright 2024 Kapeta Inc. * SPDX-License-Identifier: MIT
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Consumer ¶
type Consumer[T any] struct { // contains filtered or unexported fields }
func CreateConsumer ¶
func (*Consumer[T]) ReceiveMessages ¶
type MessageHandler ¶
type PubSubBlockDefinition ¶
type PubSubBlockDefinition struct { Kind string `json:"kind"` Metadata model.Metadata `json:"metadata"` Spec PubSubBlockSpec `json:"spec"` }
type PubSubBlockSpec ¶
type PubSubBlockSpec struct { Providers []PubSubProviderConsumer `json:"providers"` Consumers []PubSubProviderConsumer `json:"consumers"` }
type PubSubProviderConsumer ¶
type PubSubProviderConsumer struct { Metadata model.ResourceMetadata `json:"metadata"` Spec PubSubTopicSubscriptionSpec `json:"spec"` }
Click to show internal directories.
Click to hide internal directories.