Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

corwhisk

package

Go to main page

Versions in this module

v0

v0.2.2

Jul 7, 2022

Changes in this version

type WhiskClientConfig

+ Polling api.PollingStrategy

v0.2.1

Mar 31, 2022

Changes in this version

type ConcurrentRateLimiter

+ func (c *ConcurrentRateLimiter) TryAllow() bool

+ func (c *ConcurrentRateLimiter) WaitN(ctx context.Context, n int) error

type Limiter

+ WaitN func(ctx context.Context, n int) error

type WhiskClient

+ func (l *WhiskClient) Hint(fname string, payload interface{}, hint *int) (io.ReadCloser, error)

+ func (l *WhiskClient) PollActivation(activationID string) (io.ReadCloser, error)

+ func (l *WhiskClient) Reset() error

type WhiskClientApi

+ Hint func(fname string, payload interface{}, hint *int) (io.ReadCloser, error)

+ PollActivation func(activationID string) (io.ReadCloser, error)

+ Reset func() error

type WhiskClientConfig

+ HintingFeature bool

v0.2.0

Jan 23, 2022

v0.1.7

Jan 23, 2022

Changes in this version

+ const MaxPullRetries

+ const MaxRetries

+ func GetQualifiedName(functioname string) (string, string)

+ type BatchRequest struct

+ Payloads []WhiskPayload

+ type ConcurrentRateLimiter struct

+ ConcurrentToken int

+ TokenPerMinute int64

+ func NewConcurrentRateLimiter(tokenPerMinute int64, concurrentToken int) (*ConcurrentRateLimiter, error)

+ func (c *ConcurrentRateLimiter) Allow()

+ func (c *ConcurrentRateLimiter) Wait(ctx context.Context) error

+ type Limiter interface

+ Allow func()

+ Wait func(ctx context.Context) error

+ type OWInfoResponse struct

+ Features struct{ ... }

+ Limits struct{ ... }

+ type WhiskCacheConfigInjector interface

+ ConfigureWhisk func(action *whisk.Action) error

+ type WhiskClient struct

+ Client *whisk.Client

+ ConcurrencyLimit *int

+ func (l *WhiskClient) Close() error

+ func (l *WhiskClient) DeleteFunction(name string) error

+ func (l *WhiskClient) DeployFunction(conf WhiskFunctionConfig) error

+ func (l *WhiskClient) Invoke(name string, payload interface{}) (io.ReadCloser, error)

+ func (l *WhiskClient) InvokeAsBatch(name string, payloads []interface{}) ([]interface{}, error)

+ func (l *WhiskClient) InvokeAsync(name string, payload interface{}) (interface{}, error)

+ func (l *WhiskClient) ReceiveUntil(when func() bool) chan io.ReadCloser

+ type WhiskClientApi interface

+ DeleteFunction func(name string) error

+ DeployFunction func(conf WhiskFunctionConfig) error

+ Invoke func(name string, payload interface{}) (io.ReadCloser, error)

+ InvokeAsBatch func(name string, payload []interface{}) ([]interface{}, error)

+ InvokeAsync func(name string, payload interface{}) (interface{}, error)

+ ReceiveUntil func(when func() bool) chan io.ReadCloser

+ func NewWhiskClient(conf WhiskClientConfig) WhiskClientApi

+ type WhiskClientConfig struct

+ Address *string

+ BatchRequestFeature bool

+ ConcurrencyLimit int

+ Context context.Context

+ DataPreloadingFeature bool

+ Host string

+ MultiDeploymentFeature bool

+ Namespace string

+ RemoteLoggingHost string

+ RequestPerMinute int64

+ Token string

+ WriteMetrics bool

+ type WhiskFunctionConfig struct

+ CacheConfigInjector api.CacheConfigInjector

+ FunctionName string

+ Memory int

+ Timeout int

+ type WhiskPayload struct

+ Env map[string]*string

+ Value interface{}