api

Nov 16, 2023

Changes in this version

+ const FmtPluginContainer

+ var ErrCreateLocal = errors.New("could not create local directory for files")

+ var ErrFSKind = errors.New("storage kind not supported")

+ var ErrNoFSConfig = errors.New("no filestore configuration found")

+ func GetFileStore() (stow.Location, error)

+ func LoadPlugin(funcName, dir, fName string) (func(*coprocess.Object) (*coprocess.Object, error), error)

+ type API struct

+ func NewAPI(store storage.MservStore) *API

+ func (a *API) FetchAndServeBundleFile(mw *storage.MW) (string, error)

+ func (a *API) GetAllActiveMW(ctx context.Context) ([]*storage.MW, error)

+ func (a *API) GetMWByID(ctx context.Context, id string) (*storage.MW, error)

+ func (a *API) HandleDeleteBundle(ctx context.Context, bundleName string) error

+ func (a *API) HandleNewBundle(ctx context.Context, filePath, apiID, bundleName string) (*storage.MW, error)

+ func (a *API) HandleUpdateBundle(ctx context.Context, filePath, bundleName string) (*storage.MW, error)

+ func (a *API) LoadMWIntoDispatcher(mw *storage.MW, pluginPath string) (*storage.MW, error)

+ func (a *API) StoreBundleOnly(ctx context.Context, filePath, apiID, bundleName string) (*storage.MW, error)

+ type Dispatcher struct

+ func (d *Dispatcher) Dispatch(ctx context.Context, object *coprocess.Object) (*coprocess.Object, error)

+ func (d *Dispatcher) DispatchEvent(ctx context.Context, event *coprocess.Event) (*coprocess.EventReply, error)