senders

Documentation

Index

• type Sender
  • func NewDynamicSender(client dynamic.Interface) Sender
• type SenderTransport
  • func NewDefaultSenderTansport(sender Sender, sclient, rclient cloudevents.Client) SenderTransport

Types

type Sender

type Sender interface {
	List(namespace string, gvr schema.GroupVersionResource, options metav1.ListOptions) (*unstructured.UnstructuredList, error)
	Watch(namespace string, gvr schema.GroupVersionResource, options metav1.ListOptions) (watch.Interface, error)
}

func NewDynamicSender

func NewDynamicSender(client dynamic.Interface) Sender

type SenderTransport

type SenderTransport interface {
	Run(ctx context.Context)
}

func NewDefaultSenderTansport

func NewDefaultSenderTansport(sender Sender, sclient, rclient cloudevents.Client) SenderTransport