resources

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

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`
)

Functions

func Labels

func Labels(name string) map[string]string

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.