clients

Documentation

Index

• func CreateHTTPClient(timeout int, invokeProtocol string) *http.Client
• func DeserializeDandelionResponse(function *common.Function, body []byte, record *metric.ExecutionRecord) error
• func DeserializeDirigentResponse(body []byte, record *mc.ExecutionRecord) error
• func HandleBodyClosing(response *http.Response)
• type ActivationMetadata
• type DandelionDeserializeResponse
• type DandelionRequest
• type FunctionResponse
• type HTTPResBody
• type InputItem
• type InputSet
• type Invoker
  • func CreateInvoker(cfg *config.LoaderConfiguration, announceDoneExe *sync.WaitGroup, ...) Invoker

Functions

func CreateHTTPClient

func CreateHTTPClient(timeout int, invokeProtocol string) *http.Client

func DeserializeDandelionResponse

func DeserializeDandelionResponse(function *common.Function, body []byte, record *metric.ExecutionRecord) error

func DeserializeDirigentResponse

func DeserializeDirigentResponse(body []byte, record *mc.ExecutionRecord) error

func HandleBodyClosing

func HandleBodyClosing(response *http.Response)

Types

type ActivationMetadata

type ActivationMetadata struct {
	Duration  uint32 //ms
	StartType mc.StartType
	WaitTime  int64 //ms
	InitTime  int64 //ms
}

type DandelionDeserializeResponse

type DandelionDeserializeResponse struct {
	Sets []InputSet `bson:"sets"`
}

type DandelionRequest

type DandelionRequest struct {
	Name string     `bson:"name"`
	Sets []InputSet `bson:"sets"`
}

type FunctionResponse

type FunctionResponse struct {
	Status        string `json:"Status"`
	Function      string `json:"Function"`
	MachineName   string `json:"MachineName"`
	ExecutionTime int64  `json:"ExecutionTime"`
}

type HTTPResBody

type HTTPResBody struct {
	DurationInMicroSec uint32 `json:"DurationInMicroSec"`
	MemoryUsageInKb    uint32 `json:"MemoryUsageInKb"`
}

type InputItem

type InputItem struct {
	Identifier string `bson:"identifier"`
	Key        int64  `bson:"key"`
	Data       []byte `bson:"data"`
}

type InputSet

type InputSet struct {
	Identifier string      `bson:"identifier"`
	Items      []InputItem `bson:"items"`
}

type Invoker

type Invoker interface {
	Invoke(*common.Function, *common.RuntimeSpecification) (bool, *metric.ExecutionRecord)
}

func CreateInvoker

func CreateInvoker(cfg *config.LoaderConfiguration, announceDoneExe *sync.WaitGroup, readOpenWhiskMetadata *sync.Mutex) Invoker