resources

Documentation

Index

• func AdapterName(source *sourcesv1alpha1.RedisStreamSource) string
• func Labels(name string) map[string]string
• func MakeReceiveAdapter(source *sourcesv1alpha1.RedisStreamSource, image string, sinkURI string, ...) *appsv1.StatefulSet
• func MakeRoleBinding(source *v1alpha1.RedisStreamSource, clusterRoleName string) *rbacv1.RoleBinding
• func RoleBindingName(source *sourcesv1alpha1.RedisStreamSource) string
• func ServiceAccountName(source kmeta.OwnerRefable) string

Functions

func AdapterName

func AdapterName(source *sourcesv1alpha1.RedisStreamSource) string

func Labels

func Labels(name string) map[string]string

func MakeReceiveAdapter

func MakeReceiveAdapter(source *sourcesv1alpha1.RedisStreamSource, image string, sinkURI string, numConsumers string, tlsCert string) *appsv1.StatefulSet

MakeReceiveAdapter generates (but does not insert into K8s) the Receive Adapter Deployment for RedisStream Sources.

func MakeRoleBinding

func MakeRoleBinding(source *v1alpha1.RedisStreamSource, clusterRoleName string) *rbacv1.RoleBinding

MakeRoleBinding creates a RoleBinding object for the single-tenant receive adapter service account 'sa' in the Namespace 'ns'.

func RoleBindingName

func RoleBindingName(source *sourcesv1alpha1.RedisStreamSource) string

func ServiceAccountName

func ServiceAccountName(source kmeta.OwnerRefable) string