api

Documentation

Index

• Variables
• func ValidateRequest(r *http.Request, defaults map[string]interface{}, target entities.Schema) error
• type API
  • func NewAPI(opts Options) *API
  • func (api *API) CreateEndpoint(w http.ResponseWriter, r *http.Request)
  • func (api *API) CreateEvent(w http.ResponseWriter, r *http.Request)
  • func (api *API) CreatePlugin(w http.ResponseWriter, r *http.Request)
  • func (api *API) CreateSource(w http.ResponseWriter, r *http.Request)
  • func (api *API) CreateWorkspace(w http.ResponseWriter, r *http.Request)
  • func (api *API) DeleteEndpoint(w http.ResponseWriter, r *http.Request)
  • func (api *API) DeletePlugin(w http.ResponseWriter, r *http.Request)
  • func (api *API) DeleteSource(w http.ResponseWriter, r *http.Request)
  • func (api *API) DeleteWorkspace(w http.ResponseWriter, r *http.Request)
  • func (api *API) Dump(w http.ResponseWriter, r *http.Request)
  • func (api *API) GetAttempt(w http.ResponseWriter, r *http.Request)
  • func (api *API) GetEndpoint(w http.ResponseWriter, r *http.Request)
  • func (api *API) GetEvent(w http.ResponseWriter, r *http.Request)
  • func (api *API) GetPlugin(w http.ResponseWriter, r *http.Request)
  • func (api *API) GetSource(w http.ResponseWriter, r *http.Request)
  • func (api *API) GetWorkspace(w http.ResponseWriter, r *http.Request)
  • func (api *API) Handler() http.Handler
  • func (api *API) Index(w http.ResponseWriter, r *http.Request)
  • func (api *API) PageAttempt(w http.ResponseWriter, r *http.Request)
  • func (api *API) PageEndpoint(w http.ResponseWriter, r *http.Request)
  • func (api *API) PageEvent(w http.ResponseWriter, r *http.Request)
  • func (api *API) PagePlugin(w http.ResponseWriter, r *http.Request)
  • func (api *API) PageSource(w http.ResponseWriter, r *http.Request)
  • func (api *API) PageWorkspace(w http.ResponseWriter, r *http.Request)
  • func (api *API) RetryEvent(w http.ResponseWriter, r *http.Request)
  • func (api *API) Sync(w http.ResponseWriter, r *http.Request)
  • func (api *API) UpdateEndpoint(w http.ResponseWriter, r *http.Request)
  • func (api *API) UpdatePlugin(w http.ResponseWriter, r *http.Request)
  • func (api *API) UpdateSource(w http.ResponseWriter, r *http.Request)
  • func (api *API) UpdateWorkspace(w http.ResponseWriter, r *http.Request)
• type IndexResponse
• type Options
• type Pagination
  • func NewPagination[T any](total int64, data []T) *Pagination[T]

Variables

var (
	MsgNotFound    = "Not found"
	MsgInavlidUUID = "Invalid uuid"
)

Functions

func ValidateRequest

func ValidateRequest(r *http.Request, defaults map[string]interface{}, target entities.Schema) error

Types

type API

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

func NewAPI

func NewAPI(opts Options) *API

func (*API) CreateEndpoint

func (api *API) CreateEndpoint(w http.ResponseWriter, r *http.Request)

func (*API) CreateEvent

func (api *API) CreateEvent(w http.ResponseWriter, r *http.Request)

func (*API) CreatePlugin

func (api *API) CreatePlugin(w http.ResponseWriter, r *http.Request)

func (*API) CreateSource

func (api *API) CreateSource(w http.ResponseWriter, r *http.Request)

func (*API) CreateWorkspace

func (api *API) CreateWorkspace(w http.ResponseWriter, r *http.Request)

func (*API) DeleteEndpoint

func (api *API) DeleteEndpoint(w http.ResponseWriter, r *http.Request)

func (*API) DeletePlugin

func (api *API) DeletePlugin(w http.ResponseWriter, r *http.Request)

func (*API) DeleteSource

func (api *API) DeleteSource(w http.ResponseWriter, r *http.Request)

func (*API) DeleteWorkspace

func (api *API) DeleteWorkspace(w http.ResponseWriter, r *http.Request)

func (*API) Dump

func (api *API) Dump(w http.ResponseWriter, r *http.Request)

func (*API) GetAttempt

func (api *API) GetAttempt(w http.ResponseWriter, r *http.Request)

func (*API) GetEndpoint

func (api *API) GetEndpoint(w http.ResponseWriter, r *http.Request)

func (*API) GetEvent

func (api *API) GetEvent(w http.ResponseWriter, r *http.Request)

func (*API) GetPlugin

func (api *API) GetPlugin(w http.ResponseWriter, r *http.Request)

func (*API) GetSource

func (api *API) GetSource(w http.ResponseWriter, r *http.Request)

func (*API) GetWorkspace

func (api *API) GetWorkspace(w http.ResponseWriter, r *http.Request)

func (*API) Handler

func (api *API) Handler() http.Handler

Handler returns a http.Handler

func (*API) Index

func (api *API) Index(w http.ResponseWriter, r *http.Request)

func (*API) PageAttempt

func (api *API) PageAttempt(w http.ResponseWriter, r *http.Request)

func (*API) PageEndpoint

func (api *API) PageEndpoint(w http.ResponseWriter, r *http.Request)

func (*API) PageEvent

func (api *API) PageEvent(w http.ResponseWriter, r *http.Request)

func (*API) PagePlugin

func (api *API) PagePlugin(w http.ResponseWriter, r *http.Request)

func (*API) PageSource

func (api *API) PageSource(w http.ResponseWriter, r *http.Request)

func (*API) PageWorkspace

func (api *API) PageWorkspace(w http.ResponseWriter, r *http.Request)

func (*API) RetryEvent

func (api *API) RetryEvent(w http.ResponseWriter, r *http.Request)

func (*API) Sync

func (api *API) Sync(w http.ResponseWriter, r *http.Request)

func (*API) UpdateEndpoint

func (api *API) UpdateEndpoint(w http.ResponseWriter, r *http.Request)

func (*API) UpdatePlugin

func (api *API) UpdatePlugin(w http.ResponseWriter, r *http.Request)

func (*API) UpdateSource

func (api *API) UpdateSource(w http.ResponseWriter, r *http.Request)

func (*API) UpdateWorkspace

func (api *API) UpdateWorkspace(w http.ResponseWriter, r *http.Request)

type IndexResponse

type IndexResponse struct {
	Version       string         `json:"version"`
	Message       string         `json:"message"`
	Configuration *config.Config `json:"configuration"`
}

type Options

type Options struct {
	Config      *config.Config
	DB          *db.DB
	Dispatcher  *dispatcher.Dispatcher
	Middlewares []mux.MiddlewareFunc
	EventBus    eventbus.Bus
}

type Pagination

type Pagination[T any] struct {
	Total int64 `json:"total"`
	Data  []T   `json:"data"`
}

func NewPagination

func NewPagination[T any](total int64, data []T) *Pagination[T]