config

Documentation

Index

• Constants
• func AddOrUpdateEgressConfig(ct *contract.Contract, resourceIndex int, egress *contract.Egress, ...) int
• func AddOrUpdateEgressConfigForResource(resource *contract.Resource, egress *contract.Egress, egressIndex int) int
• func AddOrUpdateResourceConfig(contract *contract.Contract, resource *contract.Resource, index int, ...) int
• func BackoffPolicyFromString(backoffPolicy *duck.BackoffPolicyType) contract.BackoffPolicy
• func ContentModeFromString(mode string) contract.ContentMode
• func DeleteResource(ct *contract.Contract, index int)
• func DurationMillisFromISO8601String(durationStr *string, defaultDurationMillis uint64) (uint64, error)
• func EgressConfigFromDelivery(ctx context.Context, resolver *resolver.URIResolver, parent metav1.Object, ...) (*contract.EgressConfig, error)
• func FindEgress(egresses []*contract.Egress, egress types.UID) int
• func FindResource(contract *contract.Contract, resource types.UID) int
• func IncrementContractGeneration(ct *contract.Contract)
• func KeyTypeFromString(s string) contract.KeyType
• func MergeEgressConfig(e0, e1 *contract.EgressConfig) *contract.EgressConfig
• func SetDeadLetterSinkURIFromEgressConfig(dStatus *eventingduck.DeliveryStatus, egressConfig *contract.EgressConfig)
• func SetResourceEgressesFromContract(contract *contract.Contract, resource *contract.Resource, index int)

Constants

const (
	EgressChanged = iota
	EgressUnchanged
)

const (
	ResourceChanged = iota
	ResourceUnchanged
)

const (
	NoEgress = NoResource
)

const (
	// NoResource signals that the broker hasn't been found.
	NoResource = -1
)

Functions

func AddOrUpdateEgressConfig

func AddOrUpdateEgressConfig(ct *contract.Contract, resourceIndex int, egress *contract.Egress, egressIndex int) int

AddOrUpdateEgressConfig adds or updates the given egress to the given contract at the specified indexes.

func AddOrUpdateEgressConfigForResource

func AddOrUpdateEgressConfigForResource(resource *contract.Resource, egress *contract.Egress, egressIndex int) int

AddOrUpdateEgressConfigForResource adds or updates the given egress to the given contract at the specified indexes.

func AddOrUpdateResourceConfig

func AddOrUpdateResourceConfig(contract *contract.Contract, resource *contract.Resource, index int, logger *zap.Logger) int

AddOrUpdateResourceConfig adds or updates the given resourceConfig to the given resources at the specified index.

func BackoffPolicyFromString

func BackoffPolicyFromString(backoffPolicy *duck.BackoffPolicyType) contract.BackoffPolicy

BackoffPolicyFromString returns the BackoffPolicy from the given string.

Default value is contract.BackoffPolicy_Exponential.

func ContentModeFromString

func ContentModeFromString(mode string) contract.ContentMode

ContentModeFromString returns the ContentMode from the given string.

func DeleteResource

func DeleteResource(ct *contract.Contract, index int)

DeleteResource deletes the resource at the given index from Resources.

func DurationMillisFromISO8601String

func DurationMillisFromISO8601String(durationStr *string, defaultDurationMillis uint64) (uint64, error)

DurationMillisFromISO8601String returns the duration in milliseconds from the given string.

Default value is the specified defaultDelay.

func EgressConfigFromDelivery

func EgressConfigFromDelivery(
	ctx context.Context,
	resolver *resolver.URIResolver,
	parent metav1.Object,
	delivery *duck.DeliverySpec,
	defaultBackoffDelayMs uint64,
) (*contract.EgressConfig, error)

func FindEgress

func FindEgress(egresses []*contract.Egress, egress types.UID) int

FindEgress finds the egress with the given UID in the given egresses list.

func FindResource

func FindResource(contract *contract.Contract, resource types.UID) int

FindResource finds the resource with the given UID in the given resources list.

func IncrementContractGeneration

func IncrementContractGeneration(ct *contract.Contract)

Increment contract.Contract.Generation.

func KeyTypeFromString

func KeyTypeFromString(s string) contract.KeyType

KeyTypeFromString returns the contract.KeyType associated to a given string.

func MergeEgressConfig

func MergeEgressConfig(e0, e1 *contract.EgressConfig) *contract.EgressConfig

MergeEgressConfig merges the 2 given egress configs into one egress config prioritizing e0 values.

func SetDeadLetterSinkURIFromEgressConfig

func SetDeadLetterSinkURIFromEgressConfig(dStatus *eventingduck.DeliveryStatus, egressConfig *contract.EgressConfig)

SetDeadLetterSinkURIFromEgressConfig sets eventingduck.DeliveryStatus.DeadLetterSinkURI from a provided contract.EgressConfig.

func SetResourceEgressesFromContract

func SetResourceEgressesFromContract(contract *contract.Contract, resource *contract.Resource, index int)