resources

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