container

package

v0.0.0-...-6f0d270 Latest Latest Go to latest Published: Apr 28, 2020 License: MIT Imports: 8 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

This section is empty.

This section is empty.

This section is empty.

type ExceedConcurrencyLimit struct {
}

ExceedConcurrencyLimit means the number of waitting task beyonds the concurrencyLimit

func (e *ExceedConcurrencyLimit) Error() string

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

Meta is an abstract handler of a specified env container

func NewMeta(containerHost string, funcName string, runtime string) (*Meta, error)

NewMeta returns a container handler which maintains a rpc connection with the container

func (m *Meta) GetFuncName() string

GetFuncName

func (m *Meta) GetRuntime() string

func (m *Meta) InvokeFunc(ctx context.Context, funcName string, payload []byte) ([]byte, error)

InvokeFunc exec the func in container

func (m *Meta) LoadFunc(ctx context.Context, funcName string, url string) error

LoadFunc reset the function settings in container

func (m *Meta) SetConcurrencyLimit(limit int64)

SetConcurrencyLimit this limit influence the invoke, pls refer to invoke

func (m *Meta) SetEnvVariable(ctx context.Context, envs []string) error

SetEnvVariable overwrite some envs in container

func (m *Meta) SetTimeout(timeout int64)

SetTimeout timeout is used to limit the invokecation exec time