v1alpha2

type ActivationData struct {
	Campaign             string                            `json:"campaign"`
	Namespace            string                            `json:"namespace,omitempty"`
	Activation           string                            `json:"activation"`
	ActivationGeneration string                            `json:"activationGeneration"`
	Stage                string                            `json:"stage"`
	Inputs               map[string]interface{}            `json:"inputs,omitempty"`
	Outputs              map[string]map[string]interface{} `json:"outputs,omitempty"`
	Provider             string                            `json:"provider,omitempty"`
	Config               interface{}                       `json:"config,omitempty"`
	TriggeringStage      string                            `json:"triggeringStage,omitempty"`
	Schedule             *ScheduleSpec                     `json:"schedule,omitempty"`
	NeedsReport          bool                              `json:"needsReport,omitempty"`
}

type COAError struct {
	InnerError error
	Message    string
	State      State
}

type COAHandler func(COARequest) COAResponse

type COARequest struct {
	Context     context.Context   `json:"-"`
	Method      string            `json:"method"`
	Route       string            `json:"route"`
	ContentType string            `json:"contentType"`
	Body        []byte            `json:"body"`
	Metadata    map[string]string `json:"metadata,omitempty"`
	Parameters  map[string]string `json:"parameters,omitempty"`
}

type COAResponse struct {
	ContentType string            `json:"contentType"`
	Body        []byte            `json:"body"`
	State       State             `json:"state"`
	Metadata    map[string]string `json:"metadata,omitempty"`
	RedirectUri string            `json:"redirectUri,omitempty"`
}

type Endpoint struct {
	Methods    []string
	Version    string
	Route      string
	Handler    COAHandler
	Parameters []string
}

type Event struct {
	Metadata map[string]string `json:"metadata"`
	Body     interface{}       `json:"body"`
}

type EventHandler func(topic string, message Event) error

type HeartBeatAction string

type HeartBeatData struct {
	JobId  string          `json:"id"`
	Scope  string          `json:"scope,omitempty"`
	Action HeartBeatAction `json:"action"`
	Time   time.Time       `json:"time"`
}

type IEdge interface {
	GetFrom() string
	GetTo() string
	GetProperties() map[string]interface{}
}

type INode interface {
	GetId() string
	GetParent() string
	GetType() string
	GetProperties() map[string]interface{}
}

type InputOutputData struct {
	Inputs  map[string]interface{}            `json:"inputs,omitempty"`
	Outputs map[string]map[string]interface{} `json:"outputs,omitempty"`
}

type JobAction string

type JobData struct {
	Id     string      `json:"id"`
	Scope  string      `json:"scope,omitempty"`
	Action JobAction   `json:"action"`
	Body   interface{} `json:"body,omitempty"`
	Data   []byte      `json:"data"`
}

type SafeBuffer struct {
	// contains filtered or unexported fields
}

type ScheduleSpec struct {
	Date string `json:"date"`
	Time string `json:"time"`
	Zone string `json:"zone"`
}

type SiteConnection struct {
	BaseUrl  string `json:"baseUrl"`
	Username string `json:"username"`
	Password string `json:"password"`
}

type SiteInfo struct {
	SiteId      string            `json:"siteId"`
	Properties  map[string]string `json:"properties,omitempty"`
	ParentSite  SiteConnection    `json:"parentSite,omitempty"`
	CurrentSite SiteConnection    `json:"currentSite"`
}

type State uint16

type Terminable interface {
	Shutdown(ctx context.Context) error
}

type Trail struct {
	Origin     string                 `json:"origin"`
	Catalog    string                 `json:"catalog"`
	Type       string                 `json:"type"`
	Properties map[string]interface{} `json:"properties"`
}