pubsub

Documentation

Index

• Constants
• type PubSubBase
  • func (c *PubSubBase) EnsureSubscriptionCreated(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, ...) (ops.OpsJobStatus, error)
  • func (c *PubSubBase) EnsureSubscriptionDeleted(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, ...) (ops.OpsJobStatus, error)
  • func (c *PubSubBase) EnsureSubscriptionExists(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, ...) (ops.OpsJobStatus, error)
  • func (c *PubSubBase) EnsureTopicCreated(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, ...) (ops.OpsJobStatus, error)
  • func (c *PubSubBase) EnsureTopicDeleted(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, ...) (ops.OpsJobStatus, error)
  • func (c *PubSubBase) EnsureTopicExists(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, ...) (ops.OpsJobStatus, error)

Constants

const (
	// ReconcilerName is the name of the reconciler
	ReconcilerName = "PubSub"
)

Types

type PubSubBase

type PubSubBase struct {
	*reconciler.Base

	TopicOpsImage        string
	SubscriptionOpsImage string
}

Reconciler implements controller.Reconciler for Channel resources.

func (*PubSubBase) EnsureSubscriptionCreated

func (c *PubSubBase) EnsureSubscriptionCreated(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, project, topic, subscription string, ackDeadline time.Duration, retainAcked bool, retainDuration time.Duration) (ops.OpsJobStatus, error)

func (*PubSubBase) EnsureSubscriptionDeleted

func (c *PubSubBase) EnsureSubscriptionDeleted(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, project, topic, subscription string) (ops.OpsJobStatus, error)

func (*PubSubBase) EnsureSubscriptionExists

func (c *PubSubBase) EnsureSubscriptionExists(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, project, topic, subscription string) (ops.OpsJobStatus, error)

func (*PubSubBase) EnsureTopicCreated

func (c *PubSubBase) EnsureTopicCreated(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, project, topic string) (ops.OpsJobStatus, error)

func (*PubSubBase) EnsureTopicDeleted

func (c *PubSubBase) EnsureTopicDeleted(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, project, topic string) (ops.OpsJobStatus, error)

func (*PubSubBase) EnsureTopicExists

func (c *PubSubBase) EnsureTopicExists(ctx context.Context, owner kmeta.OwnerRefable, secret corev1.SecretKeySelector, project, topic string) (ops.OpsJobStatus, error)