pubsub

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

• type Consumer
  • func CreateConsumer[T any, Attributes map[string]string](config providers.ConfigProvider, resourceName string, ...) (*Consumer[T], error)
  • func (c *Consumer[T]) ReceiveMessages(ctx context.Context)
• type MessageHandler
• type PubSubBlockDefinition
• type PubSubBlockSpec
• type PubSubProviderConsumer
• type PubSubTopicSubscriptionSpec
• type Publisher
  • func CreatePublisher[DataType any, Headers map[string]string](config providers.ConfigProvider, resourceName string) (*Publisher[DataType, Headers], error)
  • func (p *Publisher[DataType, Headers]) Close() error
  • func (p *Publisher[DataType, Headers]) Publish(payload PublisherPayload[DataType, Headers]) (string, error)
• type PublisherPayload

Types

type Consumer

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

func CreateConsumer

func CreateConsumer[T any, Attributes map[string]string](config providers.ConfigProvider, resourceName string, handler MessageHandler[T, map[string]string]) (*Consumer[T], error)

func (*Consumer[T]) ReceiveMessages

func (c *Consumer[T]) ReceiveMessages(ctx context.Context)

type MessageHandler

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

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"`
}

type PubSubTopicSubscriptionSpec

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

type Publisher

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

func CreatePublisher

func CreatePublisher[DataType any, Headers map[string]string](config providers.ConfigProvider, resourceName string) (*Publisher[DataType, Headers], error)

func (*Publisher[DataType, Headers]) Close

func (p *Publisher[DataType, Headers]) Close() error

func (*Publisher[DataType, Headers]) Publish

func (p *Publisher[DataType, Headers]) Publish(payload PublisherPayload[DataType, Headers]) (string, error)

type PublisherPayload

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