utils

Documentation

Index

• func CalcRequestTimeout(numDelivered int, ackWait time.Duration) time.Duration
• func CalculateNakDelayForRetryNumber(attemptNum int, config *kncloudevents.RetryConfig) time.Duration
• func ConsumerName(subUID string) string
• func ConsumerSubjectName(namespace, name, uid string) string
• func ConvertDeliverPolicy(in v1alpha1.DeliverPolicy, def nats.DeliverPolicy) nats.DeliverPolicy
• func ConvertDiscardPolicy(in v1alpha1.DiscardPolicy, def nats.DiscardPolicy) nats.DiscardPolicy
• func ConvertJsDeliverPolicy(in v1alpha1.DeliverPolicy, def jetstream.DeliverPolicy) jetstream.DeliverPolicy
• func ConvertJsReplayPolicy(in v1alpha1.ReplayPolicy, def jetstream.ReplayPolicy) jetstream.ReplayPolicy
• func ConvertPlacement(in *v1alpha1.StreamPlacement) *nats.Placement
• func ConvertReplayPolicy(in v1alpha1.ReplayPolicy, def nats.ReplayPolicy) nats.ReplayPolicy
• func ConvertRetentionPolicy(in v1alpha1.RetentionPolicy, def nats.RetentionPolicy) nats.RetentionPolicy
• func ConvertStorage(in v1alpha1.Storage, def nats.StorageType) nats.StorageType
• func ConvertStreamSource(in *v1alpha1.StreamSource) *nats.StreamSource
• func ConvertStreamSources(in []v1alpha1.StreamSource) []*nats.StreamSource
• func ExpBackoff(attemptNum int, delayDuration time.Duration) time.Duration
• func LinearBackoff(attemptNum int, delayDuration time.Duration) time.Duration
• func PublishSubjectName(namespace, name string) string
• func StreamName(nc *v1alpha1.NatsJetStreamChannel) string

Functions

func CalcRequestTimeout

func CalcRequestTimeout(numDelivered int, ackWait time.Duration) time.Duration

func CalculateNakDelayForRetryNumber

func CalculateNakDelayForRetryNumber(attemptNum int, config *kncloudevents.RetryConfig) time.Duration

func ConsumerName

func ConsumerName(subUID string) string

func ConsumerSubjectName

func ConsumerSubjectName(namespace, name, uid string) string

ConsumerSubjectName generates a shareable subject name to bind to NATS Consumers for each Knative subscriber. This can be used by multiple dispatcher replicas to share delivery of

func ConvertDeliverPolicy

func ConvertDeliverPolicy(in v1alpha1.DeliverPolicy, def nats.DeliverPolicy) nats.DeliverPolicy

func ConvertDiscardPolicy

func ConvertDiscardPolicy(in v1alpha1.DiscardPolicy, def nats.DiscardPolicy) nats.DiscardPolicy

func ConvertJsDeliverPolicy

func ConvertJsDeliverPolicy(in v1alpha1.DeliverPolicy, def jetstream.DeliverPolicy) jetstream.DeliverPolicy

func ConvertJsReplayPolicy

func ConvertJsReplayPolicy(in v1alpha1.ReplayPolicy, def jetstream.ReplayPolicy) jetstream.ReplayPolicy

func ConvertPlacement

func ConvertPlacement(in *v1alpha1.StreamPlacement) *nats.Placement

func ConvertReplayPolicy

func ConvertReplayPolicy(in v1alpha1.ReplayPolicy, def nats.ReplayPolicy) nats.ReplayPolicy

func ConvertRetentionPolicy

func ConvertRetentionPolicy(in v1alpha1.RetentionPolicy, def nats.RetentionPolicy) nats.RetentionPolicy

func ConvertStorage

func ConvertStorage(in v1alpha1.Storage, def nats.StorageType) nats.StorageType

func ConvertStreamSource

func ConvertStreamSource(in *v1alpha1.StreamSource) *nats.StreamSource

func ConvertStreamSources

func ConvertStreamSources(in []v1alpha1.StreamSource) []*nats.StreamSource

func ExpBackoff

func ExpBackoff(attemptNum int, delayDuration time.Duration) time.Duration

func LinearBackoff

func LinearBackoff(attemptNum int, delayDuration time.Duration) time.Duration

func PublishSubjectName

func PublishSubjectName(namespace, name string) string

func StreamName

func StreamName(nc *v1alpha1.NatsJetStreamChannel) string

StreamName builds a valid NATS Jetstream stream name from a *v1alpha1.NatsJetStreamChannel. If overrideName is not set, the format is KN_NAMESPACE__NAME, where hyphens in the namespace or name are replaced with _.

For example: - "default/channel" => "KN_DEFAULT__CHANNEL" - "knative-eventing/my-channel" => "KN_KNATIVE_EVENTING__MY_CHANNEL"