firehose

Documentation

Index

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

Constants

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

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,
		},
		{
			Name:        UpgradeAction,
			Description: "Upgrade firehose to current stable version",
		},
	},
	DriverFactory: func(conf json.RawMessage) (module.Driver, error) {
		fm := firehoseModuleWithDefaultConfigs()
		err := json.Unmarshal(conf, fm)
		if err != nil {
			return nil, err
		}
		return fm, nil
	},
}

Types

type Output

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

func (Output) JSON

func (out Output) JSON() []byte