lib

Documentation

Index

• Constants
• func GetCreditsClient(standalone bool) *redis.Client
• func GetEnvVariable(key, defaultValue string) string
• func GetEnvVariableBool(key string, defaultValue bool) bool
• func GetEnvVariableRaw(key, defaultValue string, hideError bool) string
• func GetHexEnvVariable(key, defaultValue string) []byte
• func IsPrivateIP(ip net.IP) bool
• func IsPrivateIPString(ip string) bool
• type CreditsManager
  • func CreateCreditsManager(ctx context.Context, variant string, variantTargetId string, ...) *CreditsManager
  • func (creditsManager *CreditsManager) BillFinalCredits()
  • func (creditsManager *CreditsManager) ForceDeductCredits(credits int64, setLastBillingTime bool)
  • func (creditsManager *CreditsManager) GetCredits() int64
  • func (creditsManager *CreditsManager) StartMonitoringCredits(outOfCreditsCallback func())
  • func (creditsManager *CreditsManager) StopCreditsCapturing()
• type FuncModeInfo
• type FunctionAuthClient
• type FunctionResult
• type JobUserUpdate
• type LiveFunction
• type WrappedJobUserUpdate

Constants

const OUT_OF_CREDITS_MESSAGE = "out of credits"

Functions

func GetCreditsClient

func GetCreditsClient(standalone bool) *redis.Client

func GetEnvVariable

func GetEnvVariable(key, defaultValue string) string

func GetEnvVariableBool

func GetEnvVariableBool(key string, defaultValue bool) bool

func GetEnvVariableRaw

func GetEnvVariableRaw(key, defaultValue string, hideError bool) string

func GetHexEnvVariable

func GetHexEnvVariable(key, defaultValue string) []byte

func IsPrivateIP

func IsPrivateIP(ip net.IP) bool

func IsPrivateIPString

func IsPrivateIPString(ip string) bool

Types

type CreditsManager

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

func CreateCreditsManager

func CreateCreditsManager(ctx context.Context, variant string, variantTargetId string,
	creditsClient *redis.Client, funcModeInfo FuncModeInfo) *CreditsManager

func (*CreditsManager) BillFinalCredits

func (creditsManager *CreditsManager) BillFinalCredits()

func (*CreditsManager) ForceDeductCredits

func (creditsManager *CreditsManager) ForceDeductCredits(credits int64, setLastBillingTime bool)

func (*CreditsManager) GetCredits

func (creditsManager *CreditsManager) GetCredits() int64

func (*CreditsManager) StartMonitoringCredits

func (creditsManager *CreditsManager) StartMonitoringCredits(outOfCreditsCallback func())

func (*CreditsManager) StopCreditsCapturing

func (creditsManager *CreditsManager) StopCreditsCapturing()

type FuncModeInfo

type FuncModeInfo struct {
	Instance100MSUnitRate int64 `json:"instance100msUnitRate"`
}

type FunctionAuthClient

type FunctionAuthClient interface {
	Functions() []LiveFunction
	ExecuteFunction(location string) (*(chan FunctionResult), error)
	CheckFunctionAvailability(location string) error
}

type FunctionResult

type FunctionResult struct {
	Response *http.Response
	Error    error
}

type JobUserUpdate

type JobUserUpdate struct {
	UpdateType string `json:"updateType"`
}

type LiveFunction

type LiveFunction struct {
	Location string
	Uri      string
	State    functionspb.Function_State
}

type WrappedJobUserUpdate

type WrappedJobUserUpdate struct {
	Update JobUserUpdate `json:"update"`
	JobId  string        `json:"jobId"`
}