Versions in this module Expand all Collapse all v0 v0.5.0 Feb 7, 2020 Changes in this version + func NewGatewayCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewGatewayListCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewGatewayStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewInMemoryGatewayCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewInMemoryGatewayCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewInMemoryGatewayDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewInMemoryGatewayListCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewInMemoryGatewayStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewKafkaGatewayCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewKafkaGatewayCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewKafkaGatewayDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewKafkaGatewayListCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewKafkaGatewayStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewPulsarGatewayCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewPulsarGatewayCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewPulsarGatewayDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewPulsarGatewayListCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewPulsarGatewayStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command + type GatewayListOptions struct + func (opts *GatewayListOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *GatewayListOptions) Validate(ctx context.Context) cli.FieldErrors + type GatewayStatusOptions struct + func (opts *GatewayStatusOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *GatewayStatusOptions) Validate(ctx context.Context) cli.FieldErrors + type InMemoryGatewayCreateOptions struct + DryRun bool + Tail bool + WaitTimeout time.Duration + func (opts *InMemoryGatewayCreateOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *InMemoryGatewayCreateOptions) IsDryRun() bool + func (opts *InMemoryGatewayCreateOptions) Validate(ctx context.Context) cli.FieldErrors + type InMemoryGatewayDeleteOptions struct + func (opts *InMemoryGatewayDeleteOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *InMemoryGatewayDeleteOptions) Validate(ctx context.Context) cli.FieldErrors + type InMemoryGatewayListOptions struct + func (opts *InMemoryGatewayListOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *InMemoryGatewayListOptions) Validate(ctx context.Context) cli.FieldErrors + type InMemoryGatewayStatusOptions struct + func (opts *InMemoryGatewayStatusOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *InMemoryGatewayStatusOptions) Validate(ctx context.Context) cli.FieldErrors + type KafkaGatewayCreateOptions struct + BootstrapServers string + DryRun bool + Tail bool + WaitTimeout time.Duration + func (opts *KafkaGatewayCreateOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *KafkaGatewayCreateOptions) IsDryRun() bool + func (opts *KafkaGatewayCreateOptions) Validate(ctx context.Context) cli.FieldErrors + type KafkaGatewayDeleteOptions struct + func (opts *KafkaGatewayDeleteOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *KafkaGatewayDeleteOptions) Validate(ctx context.Context) cli.FieldErrors + type KafkaGatewayListOptions struct + func (opts *KafkaGatewayListOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *KafkaGatewayListOptions) Validate(ctx context.Context) cli.FieldErrors + type KafkaGatewayStatusOptions struct + func (opts *KafkaGatewayStatusOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *KafkaGatewayStatusOptions) Validate(ctx context.Context) cli.FieldErrors type ProcessorCreateOptions + ContainerRef string + Env []string + EnvFrom []string + Image string + type PulsarGatewayCreateOptions struct + DryRun bool + ServiceURL string + Tail bool + WaitTimeout time.Duration + func (opts *PulsarGatewayCreateOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *PulsarGatewayCreateOptions) IsDryRun() bool + func (opts *PulsarGatewayCreateOptions) Validate(ctx context.Context) cli.FieldErrors + type PulsarGatewayDeleteOptions struct + func (opts *PulsarGatewayDeleteOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *PulsarGatewayDeleteOptions) Validate(ctx context.Context) cli.FieldErrors + type PulsarGatewayListOptions struct + func (opts *PulsarGatewayListOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *PulsarGatewayListOptions) Validate(ctx context.Context) cli.FieldErrors + type PulsarGatewayStatusOptions struct + func (opts *PulsarGatewayStatusOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *PulsarGatewayStatusOptions) Validate(ctx context.Context) cli.FieldErrors type StreamCreateOptions + Gateway string + Tail bool + WaitTimeout time.Duration v0.4.0 Aug 15, 2019 Changes in this version + func NewProcessorCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewProcessorCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewProcessorDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewProcessorListCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewProcessorStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewProcessorTailCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewStreamCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewStreamCreateCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewStreamDeleteCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewStreamListCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewStreamStatusCommand(ctx context.Context, c *cli.Config) *cobra.Command + func NewStreamingCommand(ctx context.Context, c *cli.Config) *cobra.Command + type ProcessorCreateOptions struct + DryRun bool + FunctionRef string + Inputs []string + Outputs []string + Tail bool + WaitTimeout string + func (opts *ProcessorCreateOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *ProcessorCreateOptions) IsDryRun() bool + func (opts *ProcessorCreateOptions) Validate(ctx context.Context) *cli.FieldError + type ProcessorDeleteOptions struct + func (opts *ProcessorDeleteOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *ProcessorDeleteOptions) Validate(ctx context.Context) *cli.FieldError + type ProcessorListOptions struct + func (opts *ProcessorListOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *ProcessorListOptions) Validate(ctx context.Context) *cli.FieldError + type ProcessorStatusOptions struct + func (opts *ProcessorStatusOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *ProcessorStatusOptions) Validate(ctx context.Context) *cli.FieldError + type ProcessorTailOptions struct + Since string + func (opts *ProcessorTailOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *ProcessorTailOptions) Validate(ctx context.Context) *cli.FieldError + type StreamCreateOptions struct + ContentType string + DryRun bool + Provider string + func (opts *StreamCreateOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *StreamCreateOptions) IsDryRun() bool + func (opts *StreamCreateOptions) Validate(ctx context.Context) *cli.FieldError + type StreamDeleteOptions struct + func (opts *StreamDeleteOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *StreamDeleteOptions) Validate(ctx context.Context) *cli.FieldError + type StreamListOptions struct + func (opts *StreamListOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *StreamListOptions) Validate(ctx context.Context) *cli.FieldError + type StreamStatusOptions struct + func (opts *StreamStatusOptions) Exec(ctx context.Context, c *cli.Config) error + func (opts *StreamStatusOptions) Validate(ctx context.Context) *cli.FieldError
Go to main page