corwhisk

type BatchRequest struct {
	Payloads []WhiskPayload `json:"payloads"`
}

type ConcurrentRateLimiter struct {
	TokenPerMinute  int64
	ConcurrentToken int
	// contains filtered or unexported fields
}

type Limiter interface {
	//Wait acquires a single token from the limiter, blocks until token is availibe or context is canceled.
	Wait(ctx context.Context) error

	//Allow releases a single token to the limiter
	Allow()
}

type OWInfoResponse struct {
	Features struct {
		BatchRequestFeature bool `json:"batch"`
		CallbackFeature     bool `json:"feedback"`
		LCHFeature          bool `json:"lch"`
	} `json:"features,omitempty"`
	Limits struct {
		ActionsPerMinute  int64 `json:"actions_per_minute"`
		ConcurrentActions int   `json:"concurrent_actions"`
		MaxActionDuration int64 `json:"max_action_duration"`
		MaxActionMemory   int64 `json:"max_action_memory"`
		MinActionDuration int64 `json:"min_action_duration"`
		MinActionMemory   int64 `json:"min_action_memory"`
	} `json:"limits,omitempty"`
}

type WhiskCacheConfigInjector interface {
	api.CacheConfigInjector
	ConfigureWhisk(action *whisk.Action) error
}

type WhiskClient struct {
	Client *whisk.Client

	ConcurrencyLimit *int
	// contains filtered or unexported fields
}

type WhiskClientApi interface {
	Invoke(name string, payload interface{}) (io.ReadCloser, error)

	InvokeAsBatch(name string, payload []interface{}) ([]interface{}, error)
	InvokeAsync(name string, payload interface{}) (interface{}, error)
	ReceiveUntil(when func() bool) chan io.ReadCloser

	DeployFunction(conf WhiskFunctionConfig) error
	DeleteFunction(name string) error
}

type WhiskClientConfig struct {
	RequestPerMinute int64
	ConcurrencyLimit int

	Host      string
	Token     string
	Namespace string

	Context           context.Context
	RemoteLoggingHost string

	BatchRequestFeature    bool
	MultiDeploymentFeature bool
	DataPreloadingFeature  bool

	WriteMetrics bool

	Address *string
}

type WhiskFunctionConfig struct {
	Memory              int
	Timeout             int
	FunctionName        string
	CacheConfigInjector api.CacheConfigInjector
}

type WhiskPayload struct {
	Value interface{}        `json:"value"`
	Env   map[string]*string `json:"env"`
}