firehose

Documentation

Index

• Constants
• Variables
• type Output
  • func (out Output) JSON() []byte

Constants

const (
	StopAction  = "stop"
	StartAction = "start"
	ScaleAction = "scale"
	ResetAction = "reset"
)

const (
	ResetToDateTime = "DATETIME"
	ResetToEarliest = "EARLIEST"
	ResetToLatest   = "LATEST"
)

Variables

var (
	ErrNetwork = worker.RetryableError{RetryAfter: networkErrorRetryDuration}
	ErrKubeAPI = worker.RetryableError{RetryAfter: kubeAPIRetryBackoffDuration}
)

var Module = module.Descriptor{
	Kind: "firehose",
	Dependencies: map[string]string{
		// contains filtered or unexported fields
	},
	Actions: []module.ActionDesc{
		{
			Name:        module.CreateAction,
			Description: "Creates firehose instance.",
			ParamSchema: completeConfigSchema,
		},
		{
			Name:        module.UpdateAction,
			Description: "Updates an existing firehose instance.",
			ParamSchema: completeConfigSchema,
		},
		{
			Name:        ScaleAction,
			Description: "Scale-up or scale-down an existing firehose instance.",
			ParamSchema: scaleActionSchema,
		},
		{
			Name:        StopAction,
			Description: "Stop firehose and all its components.",
		},
		{
			Name:        StartAction,
			Description: "Start firehose and all its components.",
		},
		{
			Name:        ResetAction,
			Description: "Reset firehose kafka consumer group to given timestamp",
			ParamSchema: resetActionSchema,
		},
	},
	DriverFactory: func(conf json.RawMessage) (module.Driver, error) {
		return &firehoseModule{}, nil
	},
}

Types

type Output

type Output struct {
	Namespace   string     `json:"namespace"`
	ReleaseName string     `json:"release_name"`
	Pods        []kube.Pod `json:"pods"`
}

func (Output) JSON

func (out Output) JSON() []byte