controllers

Documentation

Index

• Constants
• func CreateDataSet(env *env.Env) func(http.ResponseWriter, *http.Request)
• func CreateSource(env *env.Env) func(http.ResponseWriter, *http.Request)
• func CreateSourceType(env *env.Env) func(http.ResponseWriter, *http.Request)
• func DeleteDataSet(env *env.Env) func(http.ResponseWriter, *http.Request)
• func DeleteSource(env *env.Env) func(http.ResponseWriter, *http.Request)
• func DeleteSourceType(env *env.Env) func(http.ResponseWriter, *http.Request)
• func GetData(env *env.Env) func(http.ResponseWriter, *http.Request)
• func GetDataSet(env *env.Env) func(http.ResponseWriter, *http.Request)
• func GetDataSets(env *env.Env) func(http.ResponseWriter, *http.Request)
• func GetHomePage(w http.ResponseWriter, r *http.Request)
• func GetSource(env *env.Env) func(http.ResponseWriter, *http.Request)
• func GetSourceType(env *env.Env) func(http.ResponseWriter, *http.Request)
• func GetSourceTypes(env *env.Env) func(http.ResponseWriter, *http.Request)
• func GetSources(env *env.Env) func(http.ResponseWriter, *http.Request)
• func UpdateDataSet(env *env.Env) func(http.ResponseWriter, *http.Request)
• func UpdateSource(env *env.Env) func(http.ResponseWriter, *http.Request)
• func UpdateSourceType(env *env.Env) func(http.ResponseWriter, *http.Request)
• type Message

Constants

const RABBITMQ_CONNECTION = "amqp://guest:guest@localhost:5672/"

const RABBITMQ_QUEUE_NAME = "sd_orchestrator"

Functions

func CreateDataSet

func CreateDataSet(env *env.Env) func(http.ResponseWriter, *http.Request)

func CreateSource

func CreateSource(env *env.Env) func(http.ResponseWriter, *http.Request)

func CreateSourceType

func CreateSourceType(env *env.Env) func(http.ResponseWriter, *http.Request)

func DeleteDataSet

func DeleteDataSet(env *env.Env) func(http.ResponseWriter, *http.Request)

func DeleteSource

func DeleteSource(env *env.Env) func(http.ResponseWriter, *http.Request)

func DeleteSourceType

func DeleteSourceType(env *env.Env) func(http.ResponseWriter, *http.Request)

func GetData

func GetData(env *env.Env) func(http.ResponseWriter, *http.Request)

func GetDataSet

func GetDataSet(env *env.Env) func(http.ResponseWriter, *http.Request)

func GetDataSets

func GetDataSets(env *env.Env) func(http.ResponseWriter, *http.Request)

func GetHomePage

func GetHomePage(w http.ResponseWriter, r *http.Request)

func GetSource

func GetSource(env *env.Env) func(http.ResponseWriter, *http.Request)

func GetSourceType

func GetSourceType(env *env.Env) func(http.ResponseWriter, *http.Request)

func GetSourceTypes

func GetSourceTypes(env *env.Env) func(http.ResponseWriter, *http.Request)

func GetSources

func GetSources(env *env.Env) func(http.ResponseWriter, *http.Request)

func UpdateDataSet

func UpdateDataSet(env *env.Env) func(http.ResponseWriter, *http.Request)

func UpdateSource

func UpdateSource(env *env.Env) func(http.ResponseWriter, *http.Request)

func UpdateSourceType

func UpdateSourceType(env *env.Env) func(http.ResponseWriter, *http.Request)

Types

type Message

type Message struct {
	Name   string
	UUID   string
	Params []string
}