openfaas

Feb 1, 2020

Changes in this version

+ type Client struct

+ func NewClient(client *http.Client, creds *auth.BasicAuthCredentials, gatewayURL string) *Client

+ func (c *Client) GetFunctions(ctx context.Context, namespace string) ([]types.FunctionStatus, error)

+ func (c *Client) GetNamespaces(ctx context.Context) ([]string, error)

+ func (c *Client) HasNamespaceSupport(ctx context.Context) (bool, error)

+ func (c *Client) InvokeAsync(ctx context.Context, name string, payload []byte) (bool, error)

+ func (c *Client) InvokeSync(ctx context.Context, name string, payload []byte) ([]byte, error)

+ type Controller struct

+ func NewController(conf *config.Controller, client FunctionCrawler) *Controller

+ func (c *Controller) Invoke(topic string, message []byte)

+ func (c *Controller) Start(ctx context.Context)

+ type FunctionCrawler interface

+ type FunctionFetcher interface

+ GetFunctions func(ctx context.Context, namespace string) ([]types.FunctionStatus, error)

+ type FunctionMapBuilder struct

+ func NewFunctionMapBuilder() *FunctionMapBuilder

+ func (b *FunctionMapBuilder) Append(topic string, function string)

+ func (b *FunctionMapBuilder) Build() map[string][]string

+ type Invoker interface

+ InvokeAsync func(ctx context.Context, name string, payload []byte) (bool, error)

+ InvokeSync func(ctx context.Context, name string, payload []byte) ([]byte, error)

+ type NamespaceFetcher interface

+ GetNamespaces func(ctx context.Context) ([]string, error)

+ HasNamespaceSupport func(ctx context.Context) (bool, error)

+ type TopicFunctionCache struct

+ func NewTopicFunctionCache() *TopicFunctionCache

+ func (m *TopicFunctionCache) GetCachedValues(name string) []string

+ func (m *TopicFunctionCache) Refresh(update map[string][]string)

+ type TopicMap interface

+ GetCachedValues func(name string) []string

+ Refresh func(update map[string][]string)

+ type TopicMapBuilder interface

+ Append func(topic string, function string)

+ Build func() map[string][]string