http

Documentation

Index

• type ErrorBody
• type FlowCreateReq
• type FlowCreateResp
• type FlowDeleteResp
• type FlowGetReq
• type FlowGetResp
• type FlowListResp
• type FlowRunReq
• type FlowRunResp
• type NamespaceCreateReq
• type NamespaceCreateResp
• type NamespaceDeleteResp
• type NamespaceGetReq
• type NamespaceGetResp
• type NamespaceListResp
• type ResponseError
  • func NewResponseError(e error, c int) *ResponseError
  • func (e *ResponseError) Error() string
  • func (e *ResponseError) StatusCode() int
  • func (e *ResponseError) String() string
• type RunCancelResp
• type RunDeleteResp
• type RunGetResp
• type RunListResp
• type RunsLogsReq
• type RunsLogsResp
• type Server
  • func NewServer(req *ServerReq) (*Server, error)
  • func (s *Server) Start()
  • func (s *Server) Stop()
• type ServerReq
• type TriggerCreateReq
• type TriggerCreateResp
• type TriggerDeleteResp
• type TriggerGetReq
• type TriggerGetResp
• type TriggerListResp

Types

type ErrorBody

type ErrorBody struct {
	Msg  string `json:"message"`
	Code int    `json:"code"`
}

type FlowCreateReq

type FlowCreateReq struct {
	Flow *sharedstate.Flow `json:"flow"`
}

type FlowCreateResp

type FlowCreateResp struct {
	Flow *sharedstate.Flow `json:"flow"`
	// contains filtered or unexported fields
}

type FlowDeleteResp

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

type FlowGetReq

type FlowGetReq struct {
	ID string `json:"id"`
}

type FlowGetResp

type FlowGetResp struct {
	Flow *sharedstate.Flow `json:"flow"`
	// contains filtered or unexported fields
}

type FlowListResp

type FlowListResp struct {
	Flows []*sharedstate.FlowStub `json:"flows"`
	// contains filtered or unexported fields
}

type FlowRunReq

type FlowRunReq struct {
	Variables map[string]any `json:"variables"`
}

type FlowRunResp

type FlowRunResp struct {
	RunID ulid.ULID `json:"run_id"`
	// contains filtered or unexported fields
}

type NamespaceCreateReq

type NamespaceCreateReq struct {
	Namespace *sharedstate.Namespace `json:"namespace"`
}

type NamespaceCreateResp

type NamespaceCreateResp struct {
	Namespace *sharedstate.Namespace `json:"namespace"`
	// contains filtered or unexported fields
}

type NamespaceDeleteResp

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

type NamespaceGetReq

type NamespaceGetReq struct {
	ID string `json:"id"`
}

type NamespaceGetResp

type NamespaceGetResp struct {
	Namesapce *sharedstate.Namespace `json:"namespace"`
	// contains filtered or unexported fields
}

type NamespaceListResp

type NamespaceListResp struct {
	Namespaces []*sharedstate.NamespaceStub `json:"namespaces"`
	// contains filtered or unexported fields
}

type ResponseError

type ResponseError struct {
	ErrorBody `json:"error"`
}

func NewResponseError

func NewResponseError(e error, c int) *ResponseError

func (*ResponseError) Error

func (e *ResponseError) Error() string

func (*ResponseError) StatusCode

func (e *ResponseError) StatusCode() int

func (*ResponseError) String

func (e *ResponseError) String() string

type RunCancelResp

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

type RunDeleteResp

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

type RunGetResp

type RunGetResp struct {
	Run *sharedstate.Run `json:"run"`
	// contains filtered or unexported fields
}

type RunListResp

type RunListResp struct {
	Runs []*sharedstate.RunStub `json:"runs"`
	// contains filtered or unexported fields
}

type RunsLogsReq

type RunsLogsReq struct {
	StepID string `json:"step_id"`
	Tail   bool   `json:"tail"`
}

type RunsLogsResp

type RunsLogsResp struct {
	Logs []string `json:"logs"`
	// contains filtered or unexported fields
}

type Server

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

func NewServer

func NewServer(req *ServerReq) (*Server, error)

func (*Server) Start

func (s *Server) Start()

func (*Server) Stop

func (s *Server) Stop()

type ServerReq

type ServerReq struct {
	Coordinator        *coordinator.Coordinator
	Logger             *zap.Logger
	HTTPAddr           string
	HTPPAccessLogLevel string
	State              state.State
}

type TriggerCreateReq

type TriggerCreateReq struct {
	Trigger *sharedstate.Trigger `json:"trigger"`
}

type TriggerCreateResp

type TriggerCreateResp struct {
	Trigger *sharedstate.Trigger `json:"trigger"`
	// contains filtered or unexported fields
}

type TriggerDeleteResp

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

type TriggerGetReq

type TriggerGetReq struct {
	ID string `json:"id"`
}

type TriggerGetResp

type TriggerGetResp struct {
	Trigger *sharedstate.Trigger `json:"trigger"`
	// contains filtered or unexported fields
}

type TriggerListResp

type TriggerListResp struct {
	Triggers []*sharedstate.TriggerStub `json:"triggers"`
	// contains filtered or unexported fields
}