payloads

Documentation

Index

• func ToCamelCase(m map[string]string) map[string]string
• func ToSnakeCase(m map[string]string) map[string]string
• type ClientConfigRequestPayload
• type ClientConfigResponsePayload
• type ClusterUpdateRequestPayload
• type ClusterUpdateResponsePayload
• type ComponentsDeleteRequestPayload
• type ComponentsDeleteResponsePayload
• type ComponentsInstallRequestPayload
• type ComponentsUpdateRequestPayload
• type ComponentsUpdateResponsePayload
• type KsqlRequestPayload
• type KsqlResponsePayload
• type Service
• type SourceDescription
• type StreamsCreateRequestPayload
• type StreamsCreateResponsePayload
• type StreamsDeleteRequestPayload
• type StreamsDeleteResponsePayload
• type StreamsInfoRequestPayload

Functions

func ToCamelCase

func ToCamelCase(m map[string]string) map[string]string

func ToSnakeCase

func ToSnakeCase(m map[string]string) map[string]string

Types

type ClientConfigRequestPayload

type ClientConfigRequestPayload struct {
}

type ClientConfigResponsePayload

type ClientConfigResponsePayload struct {
	Services    map[string]Service `json:"services"`
	UserProfile map[string]string  `json:"user_profile"`
}

type ClusterUpdateRequestPayload

type ClusterUpdateRequestPayload struct {
	ClusterConfig config.ClusterConfig `json:"cluster_config"`
}

type ClusterUpdateResponsePayload

type ClusterUpdateResponsePayload struct {
	ClusterConfig map[string]bool `json:"cluster_config"`
}

type ComponentsDeleteRequestPayload

type ComponentsDeleteRequestPayload struct {
	Components []string `json:"components,omitempty"`
}

type ComponentsDeleteResponsePayload

type ComponentsDeleteResponsePayload struct {
	Components map[string]bool `json:"components,omitempty"`
}

type ComponentsInstallRequestPayload

type ComponentsInstallRequestPayload struct {
	Name string `json:"name,omitempty"`
}

type ComponentsUpdateRequestPayload

type ComponentsUpdateRequestPayload struct {
	Components []config.Component `json:"components,omitempty"`
}

type ComponentsUpdateResponsePayload

type ComponentsUpdateResponsePayload struct {
	Components map[string]bool `json:"components,omitempty"`
}

type KsqlRequestPayload

type KsqlRequestPayload struct {
	Ksql                string            `json:"ksql"`
	StreamingProperties map[string]string `json:"streamingProperties"`
}

type KsqlResponsePayload

type KsqlResponsePayload []struct {
	Type              string            `json:"@type"`
	StatementText     string            `json:"statementText"`
	SourceDescription SourceDescription `json:"sourceDescription,omitempty"`
	Streams           []struct {
		Type        string `json:"type"`
		Name        string `json:"name"`
		Topic       string `json:"topic"`
		KeyFormat   string `json:"keyFormat"`
		ValueFormat string `json:"valueFormat"`
		IsWindowed  bool   `json:"isWindowed"`
	} `json:"streams"`
	Warnings []struct {
		Message string `json:"message"`
	} `json:"warnings"`
}

type Service

type Service struct {
	Enabled   bool   `json:"enabled"`
	Healthy   bool   `json:"healthy"`
	Component string `json:"component"`
}

type SourceDescription

type SourceDescription struct {
	Name         string `json:"name,omitempty"`
	WindowType   any    `json:"windowType,omitempty"`
	ReadQueries  []any  `json:"readQueries,omitempty"`
	WriteQueries []struct {
		QueryString     string   `json:"queryString,omitempty"`
		Sinks           []string `json:"sinks,omitempty"`
		SinkKafkaTopics []string `json:"sinkKafkaTopics,omitempty"`
		ID              string   `json:"id,omitempty"`
		StatusCount     struct {
			Running int `json:"RUNNING,omitempty"`
		} `json:"statusCount,omitempty"`
		QueryType string `json:"queryType,omitempty"`
		State     string `json:"state,omitempty"`
	} `json:"writeQueries,omitempty"`
	Fields []struct {
		Name   string `json:"name,omitempty"`
		Schema struct {
			Type         string `json:"type,omitempty"`
			Fields       any    `json:"fields,omitempty"`
			MemberSchema any    `json:"memberSchema,omitempty"`
		} `json:"schema,omitempty"`
		Type string `json:"type,omitempty"`
	} `json:"fields,omitempty"`
	Type                 string `json:"type,omitempty"`
	Timestamp            string `json:"timestamp,omitempty"`
	Statistics           string `json:"statistics,omitempty"`
	ErrorStats           string `json:"errorStats,omitempty"`
	Extended             bool   `json:"extended,omitempty"`
	KeyFormat            string `json:"keyFormat,omitempty"`
	ValueFormat          string `json:"valueFormat,omitempty"`
	Topic                string `json:"topic,omitempty"`
	Partitions           int    `json:"partitions,omitempty"`
	Replication          int    `json:"replication,omitempty"`
	Statement            string `json:"statement,omitempty"`
	QueryOffsetSummaries []any  `json:"queryOffsetSummaries,omitempty"`
	SourceConstraints    []any  `json:"sourceConstraints,omitempty"`
	ClusterStatistics    []any  `json:"clusterStatistics,omitempty"`
	ClusterErrorStats    []any  `json:"clusterErrorStats,omitempty"`
}

type StreamsCreateRequestPayload

type StreamsCreateRequestPayload struct {
	Name   string `json:"name"`
	Topics []struct {
		Name   string `json:"name"`
		Fields []struct {
			Name    string `json:"name"`
			Type    string `json:"type",omitempty`
			NewName string `json:"newName,omitempty"`
		} `json:"fields"`
	} `json:"topics"`
	Joins []struct {
		Name   string `json:"name"`
		Field1 string `json:"field1"`
		Field2 string `json:"field2"`
	} `json:"joins"`
	Aggregations []any  `json:"aggregations"`
	Key          string `json:"key"`
}

type StreamsCreateResponsePayload

type StreamsCreateResponsePayload struct {
	Name        string `json:"name"`
	OutputTopic string `json:"outputTopic"`
}

type StreamsDeleteRequestPayload

type StreamsDeleteRequestPayload struct {
	Name string `json:"name"`
}

type StreamsDeleteResponsePayload

type StreamsDeleteResponsePayload struct {
	Name string `json:"name"`
}

type StreamsInfoRequestPayload

type StreamsInfoRequestPayload struct {
	Name string `json:"name"`
}