v1alpha1

Documentation

Index

• Variables
• type MessageListenerInterface
  • func MessageListenerInterfaceNew(config *rest.Config, httpClient *http.Client) (MessageListenerInterface, error)
• type MessageTriggeredJobInterface
  • func MessageTriggeredJobInterfaceNew(config *rest.Config, httpClient *http.Client) (MessageTriggeredJobInterface, error)

Variables

var (
	Scheme         = runtime.NewScheme()
	Codecs         = serializer.NewCodecFactory(Scheme)
	ParameterCodec = runtime.NewParameterCodec(Scheme)

	AddToScheme = localSchemeBuilder.AddToScheme
)

Types

type MessageListenerInterface

type MessageListenerInterface interface {
	Create(ctx context.Context, messagelistener *ltypes.MessageListener) (*ltypes.MessageListener, error)
	Update(ctx context.Context, messagelistener *ltypes.MessageListener) (*ltypes.MessageListener, error)
	Delete(ctx context.Context, namespace string, name string, options *metav1.DeleteOptions) error
	Get(ctx context.Context, namespace string, name string, options metav1.GetOptions) (*ltypes.MessageListener, error)
	List(ctx context.Context, namespace string, options metav1.ListOptions) (*ltypes.MessageListenerList, error)
	Watch(ctx context.Context, namespace string, options metav1.ListOptions) (watch.Interface, error)
}

func MessageListenerInterfaceNew

func MessageListenerInterfaceNew(config *rest.Config, httpClient *http.Client) (MessageListenerInterface, error)

type MessageTriggeredJobInterface

type MessageTriggeredJobInterface interface {
	Create(ctx context.Context, job *jtypes.MessageTriggeredJob) (*jtypes.MessageTriggeredJob, error)
	Update(ctx context.Context, job *jtypes.MessageTriggeredJob) (*jtypes.MessageTriggeredJob, error)
	Delete(ctx context.Context, namespace string, name string, options *metav1.DeleteOptions) error
	Get(ctx context.Context, namespace string, name string, options metav1.GetOptions) (*jtypes.MessageTriggeredJob, error)
	List(ctx context.Context, namespace string, options metav1.ListOptions) (*jtypes.MessageTriggeredJobList, error)
	Watch(ctx context.Context, namespace string, options metav1.ListOptions) (watch.Interface, error)
}

func MessageTriggeredJobInterfaceNew

func MessageTriggeredJobInterfaceNew(config *rest.Config, httpClient *http.Client) (MessageTriggeredJobInterface, error)