rtctrl

type CASOpType int

type Control interface {
	InvokeFunction(input *InvocationInput) *InvocationOutput
}

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

type DispatcherV2Options struct {
	RuntimeServerAddress string
	RunnerServerAddress  string
	UserLogFileDir       string
	UserLogType          string
}

type InvocationInput struct {
	// runtime
	Runtime *RuntimeInfo

	// ExternalRequestID: external request ID
	ExternalRequestID string

	// RequestID: internal request ID
	RequestID string

	// User xxx
	User *api.User

	// The object for the Lambda function location.
	Code *api.FunctionCodeLocation

	// A complex type that describes function metadata.
	Configuration *api.FunctionConfiguration

	// log configuration
	LogConfig *api.LogConfiguration

	// define whether transfer request body as a stream
	WithStreamMode bool

	Request  *api.InvokeProxyRequest
	Response *api.InvokeProxyResponse

	// Enable Metric
	EnableMetrics bool

	// IsLogTail
	IsLogTail bool

	Logger      *logs.Logger
	InvokeType  string
	TriggerType string
}

type InvocationOutput struct {
	Output    *InvocationResponse
	Statistic *InvocationStatistic
}

type InvocationResponse struct {
	FuncResult string   `json:"result,omitempty"`
	LogMessage []string `json:"log"`
	FuncError  string   `json:"errtype,omitempty"`
	ErrorInfo  string   `json:"errinfo,omitempty"`
	Response   *api.InvokeProxyResponse
}

type InvocationStatistic struct {
	Statistic *StatisticInfo
	Metric    *RtCtrlInvokeMetric
}

type InvokeHTTPRequest struct {
	RequestID       string
	Request         *http.Request
	FunctionTimeout int64
	Logger          *logs.Logger
	CtxCancel       func()
}

type InvokeHTTPResponse struct {
	RequestID string
	Response  *http.Response
}

type InvokeRequest struct {
	RequestID       string `json:"requestid"`
	Version         string `json:"version"`
	AccessKeyID     string `json:"accessKey"`
	AccessKeySecret string `json:"secretKey"`
	SecurityToken   string `json:"securityToken"`
	ClientContext   string `json:"clientContext,omitempty"`
	EventObject     string `json:"eventObject,omitempty"`
}

type InvokeResponse struct {
	RequestID  string `json:"requestid"`
	Success    bool   `json:"success"`
	FuncResult string `json:"result,omitempty"`
	FuncError  string `json:"error,omitempty"`
}

type LogStatStore interface {
	Receiver() string
	String() string
	WriteStdLog(from int, buf []byte, eof bool) (int, error)
	WriteFunctionLog(log string) error
	WriteFunctionReportLog(log string, params *reportParameters) error
	SetMemUsed(used int64)
	LogFile() string
	MemUsed() int64
	LogDone(set bool) bool
	Close() (string, error)
	Wait()
}

type LogStatStoreParameter struct {
	RequestID       string
	TriggerType     string
	RuntimeID       string
	UserID          string
	FunctionName    string
	FunctionBrn     string
	FunctionVersion string
	FilePath        string
	LogType         string
}

type MarkInput struct {
	CommitID        string
	ConcurrentQuota uint64
}

type MergedInput struct {
	CommitID string
}

type NewRuntimeParameters struct {
	RuntimeID               string
	ConcurrentMode          bool
	StreamMode              bool
	WaitRuntimeAliveTimeout int
	IsFrozen                bool
	Resource                *api.Resource
}

type OccupyInput struct {
	CommitID       string
	WithStreamMode bool
	MemorySize     uint64
	MilliCPUs      int64
}

type ReportedRunnerInfo struct {
	Hostname    string
	ContainerID string
	Status      string
}

type RequestInfo struct {
	RequestID         string
	Runtime           *RuntimeInfo
	InvokeStartTimeNS int64
	InvokeStartTimeMS int64
	InitStartTimeMS   int64
	InitDoneTimeMS    int64
	InvokeDoneTimeMS  int64
	InvokeDurationMS  time.Duration
	BilledDurationMS  time.Duration
	MaxMemUsedBytes   int64
	MemorySpecSize    int64
	TriggerType       string

	Status RequestStatus
	Input  *InvocationInput
	Output *InvocationOutput

	SyncChannel    chan struct{}
	TimeoutChannel chan struct{} // timeout notification
	// contains filtered or unexported fields
}

type RequestStatus int

type ResetInput struct {
	Deadline time.Time
}

type RetrieveInput struct {
	Deadline time.Time
}

type RollbackInput struct {
	CommitID string
}

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

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

type RuntimeConfigOptions struct {
	// Time to wait for runtime to connect (Cold Start)
	// Units: seconds
	WaitRuntimeAliveTimeout int
}

type RuntimeDispatcher interface {
	// runtime
	RuntimeList() []*RuntimeInfo
	GetRuntime(string) (*RuntimeInfo, error)
	NewRuntime(*NewRuntimeParameters) *RuntimeInfo
	OccupyColdRuntime(*InvocationInput) (*RuntimeInfo, *api.ScaleUpRecommendation)
	FindWarmRuntime(*InvocationInput) *RuntimeInfo
	CoolDownRuntime(*RuntimeInfo) (*api.ScaleDownRecommendation, error)
	ResetRuntime(*RuntimeInfo) (*api.ScaleDownRecommendation, error)

	// resource
	IncreaseUsedResource(*api.Resource) bool
	ReleaseUsedResource(*api.Resource) bool
	ReleaseMarkedResource(rs *api.Resource) bool
	SyncResource(*api.FuncletResource) bool
	SyncRuntimeResource(string, *api.Resource) (bool, error)

	// statistic
	RuntimeStatistics() (cold, inUse, all int)
	ResourceStatistics() *api.ServiceResource
}

type RuntimeInfo struct {
	RuntimeID string `json:"RuntimeID"`

	// runtime state machine
	State         RuntimeStateType `json:"State"`
	Used          bool             `json:"used"`
	Marked        bool             `json:"marked"`
	Abnormal      bool             `json:"abnormal"`
	AbnormalTimes uint             `json:"abnormalTimes"`

	// runtime resource
	Resource *api.Resource `json:"Resource"`

	// Function meta
	UserID                  string `json:"UserID"` // CFC User ID
	CommitID                string `json:"CommitID"`
	MemorySize              uint64 `json:"MemorySize"`
	ConcurrentMode          bool   `json:"ConcurrentMode"`
	DefaultConcurrentMode   bool   `json:"DefaultConcurrentMode"`
	Concurrency             uint64 `json:"Concurrency"`
	WithStreamMode          bool   `json:"WithStreamMode"` // is http stream mode
	WaitRuntimeAliveTimeout int    `json:"WaitRuntimeAliveTimeout"`

	// Statistics
	PreLoadTimeMS  int64 `json:"PreLoadTimeMS"`
	PostLoadTimeMS int64 `json:"PostLoadTimeMS"`
	PreInitTimeMS  int64 `json:"PreInitTimeMS"`
	PostInitTimeMS int64 `json:"PostInitTimeMS"`
	AcceptReqCnt   int64 `json:"AcceptReqCnt"`
	RejectReqCnt   int64 `json:"RejectReqCnt"`

	LastLivenessTime time.Time `json:"LastLivenessTime"`
	LastAccessTime   time.Time `json:"LastAccessTime"`
	LastResetTime    time.Time `json:"LastResetTime"`
	// contains filtered or unexported fields
}

type RuntimeInfoError struct {
	RuntimeID string
}

type RuntimeManager struct {
	MaxRuntimeIdle        int
	MaxRunnerDefunct      int
	MaxRunnerResetTimeout int
	// contains filtered or unexported fields
}

type RuntimeManagerParameters struct {
	// Runtime maximum idle time
	// Units: seconds
	MaxRuntimeIdle int

	// The longest expire time after runner disconnect
	// Units: seconds
	MaxRunnerDefunct int

	// The longest expire time after runner last reset
	// Units: seconds
	MaxRunnerResetTimeout int
}

type RuntimeMatchError struct {
	Reason string
}

type RuntimeNoNeedToReset struct {
	RuntimeID string
}

type RuntimeNotExist struct {
	RuntimeID string
}

type RuntimeReleaseError struct {
	RuntimeID string
	Reason    string
}

type RuntimeStateType = string

type RuntimeStateUnmatched struct {
	RuntimeID     string
	CurrentState  RuntimeStateType
	ExpectedState []RuntimeStateType
}

type RuntimeSyncError struct {
	RuntimeID string
	Reason    string
}

type StatisticInfo struct {
	UserID     string  `json:"userid"`
	RequestID  string  `json:"reqid,omitempty"`
	Function   string  `json:"function"`
	Version    string  `json:"version"`
	StartTime  int64   `json:"startms"`
	Duration   float64 `json:"duration"`
	MemoryUsed int64   `json:"memused"`
	StatusCode int     `json:"status"`
}

type StopInput struct {
	Deadline time.Time
}

type UserLogType string