api

Documentation

Index

• Constants
• Variables
• type API
  • func NewAPI(cfg *config.Config, db *db.DB, dispatcher *dispatcher.Dispatcher, ...) *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 ErrorResponse
• type Pagination
  • func NewPagination[T any](total int64, data []T) *Pagination[T]

Constants

const (
	ApplicationJsonType = "application/json"
)

Variables

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

Types

type API

type API struct {
	DB *db.DB
	// contains filtered or unexported fields
}

func NewAPI

func NewAPI(cfg *config.Config, db *db.DB, dispatcher *dispatcher.Dispatcher, tracer *tracing.Tracer) *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 ErrorResponse

type ErrorResponse struct {
	Message string      `json:"message"`
	Error   interface{} `json:"error,omitempty"`
}

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]