kafka

package
v0.21.1 Latest Latest
Warning

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

 Go to latest Published: Dec 18, 2020 License: Apache-2.0 Imports: 8 Imported by: 0

Documentation

Overview

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

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type CreateCommand 

type CreateCommand struct {
	common.Base

	// required
	EndpointName string // Can't shaddow common.Base method Name().
	Version      int
	Topic        string
	Brokers      string

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

CreateCommand calls the Fastly API to create Kafka logging endpoints.

func NewCreateCommand 

func NewCreateCommand(parent common.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 {
	common.Base

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

DeleteCommand calls the Fastly API to delete Kafka logging endpoints.

func NewDeleteCommand 

func NewDeleteCommand(parent common.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 {
	common.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 common.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 {
	common.Base

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

ListCommand calls the Fastly API to list Kafka logging endpoints.

func NewListCommand 

func NewListCommand(parent common.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 {
	common.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 common.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 {
	common.Base

	// required
	EndpointName string // Can't shaddow common.Base method Name().
	Version      int

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

UpdateCommand calls the Fastly API to update Kafka logging endpoints.

func NewUpdateCommand 

func NewUpdateCommand(parent common.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.

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.