Documentation ¶
Index ¶
- Constants
- func NewController(ctx context.Context, cmw configmap.Watcher) *controller.Impl
- 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)
- func (c *PubSubBase) UnmarshalJobTerminationMessage(ctx context.Context, namespace, name string, v interface{}) error
- type Reconciler
Constants ¶
View Source
const (
// ReconcilerName is the name of the reconciler
ReconcilerName = "PubSub"
)
Variables ¶
This section is empty.
Functions ¶
func NewController ¶ added in v0.10.0
NewController initializes the controller and is called by the generated code Registers event handlers to enqueue events
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)
func (*PubSubBase) UnmarshalJobTerminationMessage ¶ added in v0.10.0
func (c *PubSubBase) UnmarshalJobTerminationMessage(ctx context.Context, namespace, name string, v interface{}) error
UnmarshalJobTerminationMessage unmarshals the job pod termination message.
type Reconciler ¶ added in v0.10.0
type Reconciler struct { *reconciler.Base // contains filtered or unexported fields }
Reconciler is the controller implementation for the PubSub source.
Click to show internal directories.
Click to hide internal directories.