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 EventMessage
• type FuncModeInfo
• type JobUserUpdate

Constants

const (
	CHILD_JOB_INFO    = "childJobInfo"
	GO_MESSAGE_TYPE   = "go"
	CHILD_USER_UPDATE = "childUserUpdate"
)

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 EventMessage

type EventMessage struct {
	Variant string `json:"variant"`
	// JSON encoded string
	Data string `json:"data"`
}

type FuncModeInfo

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

type JobUserUpdate

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