resources

Documentation

Index

• func Labels(name string) map[string]string
• func NewReceiveAdapter(ctx context.Context, args *ReceiveAdapterArgs) (*v1.Deployment, error)
• func NewServiceAccount(src *v1alpha1.HorizonSource, labels map[string]string) *corev1.ServiceAccount
• type ReceiveAdapterArgs

Functions

func Labels

func Labels(name string) map[string]string

func NewReceiveAdapter

func NewReceiveAdapter(ctx context.Context, args *ReceiveAdapterArgs) (*v1.Deployment, error)

NewReceiveAdapter generates the Receive Adapter Deployment for Horizon sources

func NewServiceAccount

func NewServiceAccount(src *v1alpha1.HorizonSource, labels map[string]string) *corev1.ServiceAccount

Types

type ReceiveAdapterArgs

type ReceiveAdapterArgs struct {
	Image         string
	Labels        map[string]string
	Source        *v1alpha1.HorizonSource
	SinkURI       string
	LoggingConfig string
	MetricsConfig string
}

ReceiveAdapterArgs are the arguments needed to create a Horizon source Receive Adapter. Every field is required.