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
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AdapterName ¶
func AdapterName(source *sourcesv1alpha1.RedisStreamSource) string
func MakeReceiveAdapter ¶
func MakeReceiveAdapter(source *sourcesv1alpha1.RedisStreamSource, image string, sinkURI string, numConsumers 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
Types ¶
This section is empty.
Source Files
Click to show internal directories.
Click to hide internal directories.