Documentation
¶
Index ¶
- Constants
- func Labels(name string) map[string]string
- func MakeDropFunction(source *v1alpha1.PostgresSource) string
- func MakeDropTrigger(source *v1alpha1.PostgresSource, table string) string
- func MakeFunction(source *v1alpha1.PostgresSource) string
- func MakeReceiveAdapter(args *ReceiveAdapterArgs) *v1.Deployment
- func MakeRoleBinding(ctx context.Context, src *v1alpha1.PostgresSource) *rbacv1.RoleBinding
- func MakeSQLBinding(ctx context.Context, src *v1alpha1.PostgresSource) *bindingsv1alpha1.SQLBinding
- func MakeServiceAccount(ctx context.Context, src *v1alpha1.PostgresSource) *corev1.ServiceAccount
- func MakeTrigger(source *v1alpha1.PostgresSource, table string) string
- type ReceiveAdapterArgs
Constants ¶
View Source
const ( GetTriggersQuery = `` /* 142-byte string literal not displayed */ GetFunctionQuery = `select proname as function_name from pg_proc where proname = $1` GetTableQuery = `select tablename from pg_catalog.pg_tables where tablename = $1` )
Variables ¶
This section is empty.
Functions ¶
func MakeDropFunction ¶
func MakeDropFunction(source *v1alpha1.PostgresSource) string
func MakeDropTrigger ¶
func MakeDropTrigger(source *v1alpha1.PostgresSource, table string) string
func MakeFunction ¶
func MakeFunction(source *v1alpha1.PostgresSource) string
func MakeReceiveAdapter ¶
func MakeReceiveAdapter(args *ReceiveAdapterArgs) *v1.Deployment
MakeReceiveAdapter generates (but does not insert into K8s) the Receive Adapter Deployment for Sample sources.
func MakeRoleBinding ¶
func MakeRoleBinding(ctx context.Context, src *v1alpha1.PostgresSource) *rbacv1.RoleBinding
MakeRoleBinding creates a RoleBinding object for the receive adapter service account 'sa' in the Namespace 'ns'. This is necessary for the receive adapter to be able to store state in configmaps.
func MakeSQLBinding ¶
func MakeSQLBinding(ctx context.Context, src *v1alpha1.PostgresSource) *bindingsv1alpha1.SQLBinding
func MakeServiceAccount ¶
func MakeServiceAccount(ctx context.Context, src *v1alpha1.PostgresSource) *corev1.ServiceAccount
MakeServiceAccount creates a ServiceAccount object for the Namespace 'ns'.
func MakeTrigger ¶
func MakeTrigger(source *v1alpha1.PostgresSource, table string) string
Types ¶
type ReceiveAdapterArgs ¶
type ReceiveAdapterArgs struct {
Image string
Labels map[string]string
Source *v1alpha1.PostgresSource
EventSource string
NotificationChannel string
ServiceAccount string
}
ReceiveAdapterArgs are the arguments needed to create a Sample Source Receive Adapter. Every field is required.
Source Files
¶
Directories
Click to show internal directories.
Click to hide internal directories.