commands

package
v0.5.0 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Feb 7, 2020 License: Apache-2.0 Imports: 19 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewGatewayCommand added in v0.5.0 

func NewGatewayCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewGatewayListCommand added in v0.5.0 

func NewGatewayListCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewGatewayStatusCommand added in v0.5.0 

func NewGatewayStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewInMemoryGatewayCommand added in v0.5.0 

func NewInMemoryGatewayCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewInMemoryGatewayCreateCommand added in v0.5.0 

func NewInMemoryGatewayCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewInMemoryGatewayDeleteCommand added in v0.5.0 

func NewInMemoryGatewayDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewInMemoryGatewayListCommand added in v0.5.0 

func NewInMemoryGatewayListCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewInMemoryGatewayStatusCommand added in v0.5.0 

func NewInMemoryGatewayStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewKafkaGatewayCommand added in v0.5.0 

func NewKafkaGatewayCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewKafkaGatewayCreateCommand added in v0.5.0 

func NewKafkaGatewayCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewKafkaGatewayDeleteCommand added in v0.5.0 

func NewKafkaGatewayDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewKafkaGatewayListCommand added in v0.5.0 

func NewKafkaGatewayListCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewKafkaGatewayStatusCommand added in v0.5.0 

func NewKafkaGatewayStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewProcessorCommand 

func NewProcessorCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewProcessorCreateCommand 

func NewProcessorCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewProcessorDeleteCommand 

func NewProcessorDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewProcessorListCommand 

func NewProcessorListCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewProcessorStatusCommand 

func NewProcessorStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewProcessorTailCommand 

func NewProcessorTailCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewPulsarGatewayCommand added in v0.5.0 

func NewPulsarGatewayCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewPulsarGatewayCreateCommand added in v0.5.0 

func NewPulsarGatewayCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewPulsarGatewayDeleteCommand added in v0.5.0 

func NewPulsarGatewayDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewPulsarGatewayListCommand added in v0.5.0 

func NewPulsarGatewayListCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewPulsarGatewayStatusCommand added in v0.5.0 

func NewPulsarGatewayStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewStreamCommand 

func NewStreamCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewStreamCreateCommand 

func NewStreamCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewStreamDeleteCommand 

func NewStreamDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewStreamListCommand 

func NewStreamListCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewStreamStatusCommand 

func NewStreamStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command

func NewStreamingCommand 

func NewStreamingCommand(ctx context.Context, c *cli.Config) *cobra.Command

Types

type GatewayListOptions added in v0.5.0 

type GatewayListOptions struct {
	options.ListOptions
}

func (*GatewayListOptions) Exec added in v0.5.0 

func (opts *GatewayListOptions) Exec(ctx context.Context, c *cli.Config) error

func (*GatewayListOptions) Validate added in v0.5.0 

func (opts *GatewayListOptions) Validate(ctx context.Context) cli.FieldErrors

type GatewayStatusOptions added in v0.5.0 

type GatewayStatusOptions struct {
	options.ResourceOptions
}

func (*GatewayStatusOptions) Exec added in v0.5.0 

func (opts *GatewayStatusOptions) Exec(ctx context.Context, c *cli.Config) error

func (*GatewayStatusOptions) Validate added in v0.5.0 

func (opts *GatewayStatusOptions) Validate(ctx context.Context) cli.FieldErrors

type InMemoryGatewayCreateOptions added in v0.5.0 

type InMemoryGatewayCreateOptions struct {
	options.ResourceOptions

	DryRun bool

	Tail        bool
	WaitTimeout time.Duration
}

func (*InMemoryGatewayCreateOptions) Exec added in v0.5.0 

func (opts *InMemoryGatewayCreateOptions) Exec(ctx context.Context, c *cli.Config) error

func (*InMemoryGatewayCreateOptions) IsDryRun added in v0.5.0 

func (opts *InMemoryGatewayCreateOptions) IsDryRun() bool

func (*InMemoryGatewayCreateOptions) Validate added in v0.5.0 

func (opts *InMemoryGatewayCreateOptions) Validate(ctx context.Context) cli.FieldErrors

type InMemoryGatewayDeleteOptions added in v0.5.0 

type InMemoryGatewayDeleteOptions struct {
	options.DeleteOptions
}

func (*InMemoryGatewayDeleteOptions) Exec added in v0.5.0 

func (opts *InMemoryGatewayDeleteOptions) Exec(ctx context.Context, c *cli.Config) error

func (*InMemoryGatewayDeleteOptions) Validate added in v0.5.0 

func (opts *InMemoryGatewayDeleteOptions) Validate(ctx context.Context) cli.FieldErrors

type InMemoryGatewayListOptions added in v0.5.0 

type InMemoryGatewayListOptions struct {
	options.ListOptions
}

func (*InMemoryGatewayListOptions) Exec added in v0.5.0 

func (opts *InMemoryGatewayListOptions) Exec(ctx context.Context, c *cli.Config) error

func (*InMemoryGatewayListOptions) Validate added in v0.5.0 

func (opts *InMemoryGatewayListOptions) Validate(ctx context.Context) cli.FieldErrors

type InMemoryGatewayStatusOptions added in v0.5.0 

type InMemoryGatewayStatusOptions struct {
	options.ResourceOptions
}

func (*InMemoryGatewayStatusOptions) Exec added in v0.5.0 

func (opts *InMemoryGatewayStatusOptions) Exec(ctx context.Context, c *cli.Config) error

func (*InMemoryGatewayStatusOptions) Validate added in v0.5.0 

func (opts *InMemoryGatewayStatusOptions) Validate(ctx context.Context) cli.FieldErrors

type KafkaGatewayCreateOptions added in v0.5.0 

type KafkaGatewayCreateOptions struct {
	options.ResourceOptions

	BootstrapServers string

	DryRun bool

	Tail        bool
	WaitTimeout time.Duration
}

func (*KafkaGatewayCreateOptions) Exec added in v0.5.0 

func (opts *KafkaGatewayCreateOptions) Exec(ctx context.Context, c *cli.Config) error

func (*KafkaGatewayCreateOptions) IsDryRun added in v0.5.0 

func (opts *KafkaGatewayCreateOptions) IsDryRun() bool

func (*KafkaGatewayCreateOptions) Validate added in v0.5.0 

func (opts *KafkaGatewayCreateOptions) Validate(ctx context.Context) cli.FieldErrors

type KafkaGatewayDeleteOptions added in v0.5.0 

type KafkaGatewayDeleteOptions struct {
	options.DeleteOptions
}

func (*KafkaGatewayDeleteOptions) Exec added in v0.5.0 

func (opts *KafkaGatewayDeleteOptions) Exec(ctx context.Context, c *cli.Config) error

func (*KafkaGatewayDeleteOptions) Validate added in v0.5.0 

func (opts *KafkaGatewayDeleteOptions) Validate(ctx context.Context) cli.FieldErrors

type KafkaGatewayListOptions added in v0.5.0 

type KafkaGatewayListOptions struct {
	options.ListOptions
}

func (*KafkaGatewayListOptions) Exec added in v0.5.0 

func (opts *KafkaGatewayListOptions) Exec(ctx context.Context, c *cli.Config) error

func (*KafkaGatewayListOptions) Validate added in v0.5.0 

func (opts *KafkaGatewayListOptions) Validate(ctx context.Context) cli.FieldErrors

type KafkaGatewayStatusOptions added in v0.5.0 

type KafkaGatewayStatusOptions struct {
	options.ResourceOptions
}

func (*KafkaGatewayStatusOptions) Exec added in v0.5.0 

func (opts *KafkaGatewayStatusOptions) Exec(ctx context.Context, c *cli.Config) error

func (*KafkaGatewayStatusOptions) Validate added in v0.5.0 

func (opts *KafkaGatewayStatusOptions) Validate(ctx context.Context) cli.FieldErrors

type ProcessorCreateOptions 

type ProcessorCreateOptions struct {
	options.ResourceOptions

	Image        string
	ContainerRef string
	FunctionRef  string

	Env     []string
	EnvFrom []string

	Inputs  []string
	Outputs []string

	Tail        bool
	WaitTimeout string

	DryRun bool
}

func (*ProcessorCreateOptions) Exec 

func (opts *ProcessorCreateOptions) Exec(ctx context.Context, c *cli.Config) error

func (*ProcessorCreateOptions) IsDryRun 

func (opts *ProcessorCreateOptions) IsDryRun() bool

func (*ProcessorCreateOptions) Validate 

func (opts *ProcessorCreateOptions) Validate(ctx context.Context) cli.FieldErrors

type ProcessorDeleteOptions 

type ProcessorDeleteOptions struct {
	options.DeleteOptions
}

func (*ProcessorDeleteOptions) Exec 

func (opts *ProcessorDeleteOptions) Exec(ctx context.Context, c *cli.Config) error

func (*ProcessorDeleteOptions) Validate 

func (opts *ProcessorDeleteOptions) Validate(ctx context.Context) cli.FieldErrors

type ProcessorListOptions 

type ProcessorListOptions struct {
	options.ListOptions
}

func (*ProcessorListOptions) Exec 

func (opts *ProcessorListOptions) Exec(ctx context.Context, c *cli.Config) error

func (*ProcessorListOptions) Validate 

func (opts *ProcessorListOptions) Validate(ctx context.Context) cli.FieldErrors

type ProcessorStatusOptions 

type ProcessorStatusOptions struct {
	options.ResourceOptions
}

func (*ProcessorStatusOptions) Exec 

func (opts *ProcessorStatusOptions) Exec(ctx context.Context, c *cli.Config) error

func (*ProcessorStatusOptions) Validate 

func (opts *ProcessorStatusOptions) Validate(ctx context.Context) cli.FieldErrors

type ProcessorTailOptions 

type ProcessorTailOptions struct {
	options.ResourceOptions

	Since string
}

func (*ProcessorTailOptions) Exec 

func (opts *ProcessorTailOptions) Exec(ctx context.Context, c *cli.Config) error

func (*ProcessorTailOptions) Validate 

func (opts *ProcessorTailOptions) Validate(ctx context.Context) cli.FieldErrors

type PulsarGatewayCreateOptions added in v0.5.0 

type PulsarGatewayCreateOptions struct {
	options.ResourceOptions

	ServiceURL string

	DryRun bool

	Tail        bool
	WaitTimeout time.Duration
}

func (*PulsarGatewayCreateOptions) Exec added in v0.5.0 

func (opts *PulsarGatewayCreateOptions) Exec(ctx context.Context, c *cli.Config) error

func (*PulsarGatewayCreateOptions) IsDryRun added in v0.5.0 

func (opts *PulsarGatewayCreateOptions) IsDryRun() bool

func (*PulsarGatewayCreateOptions) Validate added in v0.5.0 

func (opts *PulsarGatewayCreateOptions) Validate(ctx context.Context) cli.FieldErrors

type PulsarGatewayDeleteOptions added in v0.5.0 

type PulsarGatewayDeleteOptions struct {
	options.DeleteOptions
}

func (*PulsarGatewayDeleteOptions) Exec added in v0.5.0 

func (opts *PulsarGatewayDeleteOptions) Exec(ctx context.Context, c *cli.Config) error

func (*PulsarGatewayDeleteOptions) Validate added in v0.5.0 

func (opts *PulsarGatewayDeleteOptions) Validate(ctx context.Context) cli.FieldErrors

type PulsarGatewayListOptions added in v0.5.0 

type PulsarGatewayListOptions struct {
	options.ListOptions
}

func (*PulsarGatewayListOptions) Exec added in v0.5.0 

func (opts *PulsarGatewayListOptions) Exec(ctx context.Context, c *cli.Config) error

func (*PulsarGatewayListOptions) Validate added in v0.5.0 

func (opts *PulsarGatewayListOptions) Validate(ctx context.Context) cli.FieldErrors

type PulsarGatewayStatusOptions added in v0.5.0 

type PulsarGatewayStatusOptions struct {
	options.ResourceOptions
}

func (*PulsarGatewayStatusOptions) Exec added in v0.5.0 

func (opts *PulsarGatewayStatusOptions) Exec(ctx context.Context, c *cli.Config) error

func (*PulsarGatewayStatusOptions) Validate added in v0.5.0 

func (opts *PulsarGatewayStatusOptions) Validate(ctx context.Context) cli.FieldErrors

type StreamCreateOptions 

type StreamCreateOptions struct {
	options.ResourceOptions

	Gateway     string
	ContentType string

	DryRun bool

	Tail        bool
	WaitTimeout time.Duration
}

func (*StreamCreateOptions) Exec 

func (opts *StreamCreateOptions) Exec(ctx context.Context, c *cli.Config) error

func (*StreamCreateOptions) IsDryRun 

func (opts *StreamCreateOptions) IsDryRun() bool

func (*StreamCreateOptions) Validate 

func (opts *StreamCreateOptions) Validate(ctx context.Context) cli.FieldErrors

type StreamDeleteOptions 

type StreamDeleteOptions struct {
	options.DeleteOptions
}

func (*StreamDeleteOptions) Exec 

func (opts *StreamDeleteOptions) Exec(ctx context.Context, c *cli.Config) error

func (*StreamDeleteOptions) Validate 

func (opts *StreamDeleteOptions) Validate(ctx context.Context) cli.FieldErrors

type StreamListOptions 

type StreamListOptions struct {
	options.ListOptions
}

func (*StreamListOptions) Exec 

func (opts *StreamListOptions) Exec(ctx context.Context, c *cli.Config) error

func (*StreamListOptions) Validate 

func (opts *StreamListOptions) Validate(ctx context.Context) cli.FieldErrors

type StreamStatusOptions 

type StreamStatusOptions struct {
	options.ResourceOptions
}

func (*StreamStatusOptions) Exec 

func (opts *StreamStatusOptions) Exec(ctx context.Context, c *cli.Config) error

func (*StreamStatusOptions) Validate 

func (opts *StreamStatusOptions) Validate(ctx context.Context) cli.FieldErrors

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.