flink

Documentation

Index

• Variables
• type Config
• type Influx
• type Output

Variables

var Module = module.Descriptor{
	Kind: "flink",
	Actions: []module.ActionDesc{
		{
			Name: module.CreateAction,
		},
		{
			Name: module.UpdateAction,
		},
	},
	DriverFactory: func(conf json.RawMessage) (module.Driver, error) {
		fd := &flinkDriver{}
		err := json.Unmarshal(conf, &fd)
		if err != nil {
			return nil, errors.ErrInvalid.WithMsgf("failed to unmarshal module config: %v", err)
		}
		return fd, nil
	},
}

Types

type Config

type Config struct {
	KubeNamespace   string   `json:"kube_namespace,omitempty"`
	Influx          Influx   `json:"influx,omitempty"`
	SinkKafkaStream string   `json:"sink_kafka_stream,omitempty"`
	PrometheusURL   string   `json:"prometheus_url,omitempty"`
	FlinkName       string   `json:"flink_name,omitempty"`
	ExtraStreams    []string `json:"extra_streams,omitempty"`
}

type Influx

type Influx struct {
	URL      string `json:"url,omitempty"`
	Username string `json:"username,omitempty"`
	Password string `json:"password,omitempty"`
}

type Output

type Output struct {
	KubeCluster     kubernetes.Output `json:"kube_cluster,omitempty"`
	KubeNamespace   string            `json:"kube_namespace,omitempty"`
	Influx          Influx            `json:"influx,omitempty"`
	SinkKafkaStream string            `json:"sink_kafka_stream,omitempty"`
	PrometheusURL   string            `json:"prometheus_url,omitempty"`
	FlinkName       string            `json:"flink_name,omitempty"`
	ExtraStreams    []string          `json:"extra_streams,omitempty"`
}