module

Documentation

Index

• Constants
• func Preload(m *ModuleLoader) error
• type Module
• type ModuleCache
  • func NewModuleCache(redisClient *redis.Client) *ModuleCache
  • func (c *ModuleCache) CacheModule(moduleName string, moduleBytes []byte) error
  • func (c *ModuleCache) GetModule(moduleName string) ([]byte, error)
• type ModuleInvoker
  • func NewModuleInvoker(runtime *runtime.Runtime) *ModuleInvoker
  • func (m *ModuleInvoker) InvokeModuleWaZero(module []byte, data string) ([]byte, error)
• type ModuleLoader
  • func NewModuleLoader(cfg config.LoaderConfig, cache *ModuleCache, runtime *runtime.Runtime) (*ModuleLoader, error)
  • func (m *ModuleLoader) LoadModule(moduleName string) (*Module, error)

Constants

const (
	OBJECTSTORE_LOADER = "objectstore"
	FILESYSTEM_LOADER  = "fs"
)

Functions

func Preload

func Preload(m *ModuleLoader) error

Types

type Module

type Module struct {
	Name  string
	Bytes []byte
}

type ModuleCache

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

func NewModuleCache

func NewModuleCache(redisClient *redis.Client) *ModuleCache

func (*ModuleCache) CacheModule

func (c *ModuleCache) CacheModule(moduleName string, moduleBytes []byte) error

func (*ModuleCache) GetModule

func (c *ModuleCache) GetModule(moduleName string) ([]byte, error)

type ModuleInvoker

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

func NewModuleInvoker

func NewModuleInvoker(runtime *runtime.Runtime) *ModuleInvoker

func (*ModuleInvoker) InvokeModuleWaZero

func (m *ModuleInvoker) InvokeModuleWaZero(module []byte, data string) ([]byte, error)

type ModuleLoader

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

func NewModuleLoader

func NewModuleLoader(cfg config.LoaderConfig, cache *ModuleCache, runtime *runtime.Runtime) (*ModuleLoader, error)

func (*ModuleLoader) LoadModule

func (m *ModuleLoader) LoadModule(moduleName string) (*Module, error)