kafka

Documentation

Overview

Package kafka contains commands to inspect and manipulate Fastly service Kafka logging endpoints.

Index

• type CreateCommand
  • func NewCreateCommand(parent cmd.Registerer, globals *config.Data) *CreateCommand
  • func (c *CreateCommand) Exec(in io.Reader, out io.Writer) error
• type DeleteCommand
  • func NewDeleteCommand(parent cmd.Registerer, globals *config.Data) *DeleteCommand
  • func (c *DeleteCommand) Exec(in io.Reader, out io.Writer) error
• type DescribeCommand
  • func NewDescribeCommand(parent cmd.Registerer, globals *config.Data) *DescribeCommand
  • func (c *DescribeCommand) Exec(in io.Reader, out io.Writer) error
• type ListCommand
  • func NewListCommand(parent cmd.Registerer, globals *config.Data) *ListCommand
  • func (c *ListCommand) Exec(in io.Reader, out io.Writer) error
• type RootCommand
  • func NewRootCommand(parent cmd.Registerer, globals *config.Data) *RootCommand
  • func (c *RootCommand) Exec(in io.Reader, out io.Writer) error
• type UpdateCommand
  • func NewUpdateCommand(parent cmd.Registerer, globals *config.Data) *UpdateCommand
  • func (c *UpdateCommand) Exec(in io.Reader, out io.Writer) error

Types

type CreateCommand

type CreateCommand struct {
	cmd.Base

	// required
	EndpointName string // Can't shadow cmd.Base method Name().
	Topic        string
	Brokers      string

	UseTLS            cmd.OptionalBool
	CompressionCodec  cmd.OptionalString
	RequiredACKs      cmd.OptionalString
	TLSCACert         cmd.OptionalString
	TLSClientCert     cmd.OptionalString
	TLSClientKey      cmd.OptionalString
	TLSHostname       cmd.OptionalString
	Format            cmd.OptionalString
	FormatVersion     cmd.OptionalUint
	Placement         cmd.OptionalString
	ResponseCondition cmd.OptionalString
	ParseLogKeyvals   cmd.OptionalBool
	RequestMaxBytes   cmd.OptionalUint
	UseSASL           cmd.OptionalBool
	AuthMethod        cmd.OptionalString
	User              cmd.OptionalString
	Password          cmd.OptionalString
	// contains filtered or unexported fields
}

CreateCommand calls the Fastly API to create a Kafka logging endpoint.

func NewCreateCommand

func NewCreateCommand(parent cmd.Registerer, globals *config.Data) *CreateCommand

NewCreateCommand returns a usable command registered under the parent.

func (*CreateCommand) Exec

func (c *CreateCommand) Exec(in io.Reader, out io.Writer) error

Exec invokes the application logic for the command.

type DeleteCommand

type DeleteCommand struct {
	cmd.Base

	Input fastly.DeleteKafkaInput
	// contains filtered or unexported fields
}

DeleteCommand calls the Fastly API to delete a Kafka logging endpoint.

func NewDeleteCommand

func NewDeleteCommand(parent cmd.Registerer, globals *config.Data) *DeleteCommand

NewDeleteCommand returns a usable command registered under the parent.

func (*DeleteCommand) Exec

func (c *DeleteCommand) Exec(in io.Reader, out io.Writer) error

Exec invokes the application logic for the command.

type DescribeCommand

type DescribeCommand struct {
	cmd.Base

	Input fastly.GetKafkaInput
	// contains filtered or unexported fields
}

DescribeCommand calls the Fastly API to describe a Kafka logging endpoint.

func NewDescribeCommand

func NewDescribeCommand(parent cmd.Registerer, globals *config.Data) *DescribeCommand

NewDescribeCommand returns a usable command registered under the parent.

func (*DescribeCommand) Exec

func (c *DescribeCommand) Exec(in io.Reader, out io.Writer) error

Exec invokes the application logic for the command.

type ListCommand

type ListCommand struct {
	cmd.Base

	Input fastly.ListKafkasInput
	// contains filtered or unexported fields
}

ListCommand calls the Fastly API to list Kafka logging endpoints.

func NewListCommand

func NewListCommand(parent cmd.Registerer, globals *config.Data) *ListCommand

NewListCommand returns a usable command registered under the parent.

func (*ListCommand) Exec

func (c *ListCommand) Exec(in io.Reader, out io.Writer) error

Exec invokes the application logic for the command.

type RootCommand

type RootCommand struct {
	cmd.Base
}

RootCommand is the parent command for all subcommands in this package. It should be installed under the primary root command.

func NewRootCommand

func NewRootCommand(parent cmd.Registerer, globals *config.Data) *RootCommand

NewRootCommand returns a new command registered in the parent.

func (*RootCommand) Exec

func (c *RootCommand) Exec(in io.Reader, out io.Writer) error

Exec implements the command interface.

type UpdateCommand

type UpdateCommand struct {
	cmd.Base

	// required
	EndpointName string // Can't shadow cmd.Base method Name().

	NewName           cmd.OptionalString
	Index             cmd.OptionalString
	Topic             cmd.OptionalString
	Brokers           cmd.OptionalString
	UseTLS            cmd.OptionalBool
	CompressionCodec  cmd.OptionalString
	RequiredACKs      cmd.OptionalString
	TLSCACert         cmd.OptionalString
	TLSClientCert     cmd.OptionalString
	TLSClientKey      cmd.OptionalString
	TLSHostname       cmd.OptionalString
	Format            cmd.OptionalString
	FormatVersion     cmd.OptionalUint
	Placement         cmd.OptionalString
	ResponseCondition cmd.OptionalString
	ParseLogKeyvals   cmd.OptionalBool
	RequestMaxBytes   cmd.OptionalUint
	UseSASL           cmd.OptionalBool
	AuthMethod        cmd.OptionalString
	User              cmd.OptionalString
	Password          cmd.OptionalString
	// contains filtered or unexported fields
}

UpdateCommand calls the Fastly API to update a Kafka logging endpoint.

func NewUpdateCommand

func NewUpdateCommand(parent cmd.Registerer, globals *config.Data) *UpdateCommand

NewUpdateCommand returns a usable command registered under the parent.

func (*UpdateCommand) Exec

func (c *UpdateCommand) Exec(in io.Reader, out io.Writer) error

Exec invokes the application logic for the command.