types

package
v1.6.5-rc54 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 26, 2024 License: Apache-2.0 Imports: 30 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AccountFromContext added in v1.1.0 

func AccountFromContext(ctx context.Context) (*models.Account, bool)

func AppletFromContext 

func AppletFromContext(ctx context.Context) (*models.Applet, bool)

func ChainHeightFromContext added in v1.1.0 

func ChainHeightFromContext(ctx context.Context) (*models.ChainHeight, bool)

func ChainTxFromContext added in v1.1.0 

func ChainTxFromContext(ctx context.Context) (*models.ChainTx, bool)

func ContractLogFromContext added in v1.1.0 

func ContractLogFromContext(ctx context.Context) (*models.ContractLog, bool)

func CronJobFromContext added in v1.1.0 

func CronJobFromContext(ctx context.Context) (*models.CronJob, bool)

func EnableTrafficLimitFromContext 

func EnableTrafficLimitFromContext(ctx context.Context) bool

func EventIDFromContext added in v1.2.2 

func EventIDFromContext(ctx context.Context) (string, bool)

func FileSystemOpFromContext added in v1.1.0 

func FileSystemOpFromContext(ctx context.Context) (filesystem.FileSystemOp, bool)

func InstanceFromContext 

func InstanceFromContext(ctx context.Context) (*models.Instance, bool)

func LoggerFromContext 

func LoggerFromContext(ctx context.Context) (log.Logger, bool)

func MaxWasmConsumeFuelFromContext 

func MaxWasmConsumeFuelFromContext(ctx context.Context) (uint64, bool)

func MgrDBExecutorFromContext added in v1.0.0 

func MgrDBExecutorFromContext(ctx context.Context) (sqlx.DBExecutor, bool)

func MonitorDBExecutorFromContext 

func MonitorDBExecutorFromContext(ctx context.Context) (sqlx.DBExecutor, bool)

func MqttBrokerFromContext 

func MqttBrokerFromContext(ctx context.Context) (*mqtt.Broker, bool)

func MustAccountFromContext added in v1.1.0 

func MustAccountFromContext(ctx context.Context) *models.Account

func MustAppletFromContext 

func MustAppletFromContext(ctx context.Context) *models.Applet

func MustChainHeightFromContext added in v1.1.0 

func MustChainHeightFromContext(ctx context.Context) *models.ChainHeight

func MustChainTxFromContext added in v1.1.0 

func MustChainTxFromContext(ctx context.Context) *models.ChainTx

func MustContractLogFromContext added in v1.1.0 

func MustContractLogFromContext(ctx context.Context) *models.ContractLog

func MustCronJobFromContext added in v1.1.0 

func MustCronJobFromContext(ctx context.Context) *models.CronJob

func MustEventIDFromContext added in v1.2.2 

func MustEventIDFromContext(ctx context.Context) string

func MustFileSystemOpFromContext added in v1.1.0 

func MustFileSystemOpFromContext(ctx context.Context) filesystem.FileSystemOp

func MustInstanceFromContext 

func MustInstanceFromContext(ctx context.Context) *models.Instance

func MustLoggerFromContext 

func MustLoggerFromContext(ctx context.Context) log.Logger

func MustMaxWasmConsumeFuelFromContext 

func MustMaxWasmConsumeFuelFromContext(ctx context.Context) uint64

func MustMgrDBExecutorFromContext added in v1.0.0 

func MustMgrDBExecutorFromContext(ctx context.Context) sqlx.DBExecutor

func MustMonitorDBExecutorFromContext 

func MustMonitorDBExecutorFromContext(ctx context.Context) sqlx.DBExecutor

func MustMqttBrokerFromContext 

func MustMqttBrokerFromContext(ctx context.Context) *mqtt.Broker

func MustOperatorFromContext added in v1.1.0 

func MustOperatorFromContext(ctx context.Context) *models.Operator

func MustOperatorPoolFromContext added in v1.5.9 

func MustOperatorPoolFromContext(ctx context.Context) optypes.Pool

func MustOperatorsFromContext added in v1.4.6 

func MustOperatorsFromContext(ctx context.Context) []models.Operator

func MustProjectFromContext 

func MustProjectFromContext(ctx context.Context) *models.Project

func MustProjectOperatorFromContext added in v1.4.6 

func MustProjectOperatorFromContext(ctx context.Context) *models.ProjectOperator

func MustProxyClientFromContext added in v1.1.0 

func MustProxyClientFromContext(ctx context.Context) *client.Client

func MustPublisherFromContext added in v1.1.0 

func MustPublisherFromContext(ctx context.Context) *models.Publisher

func MustRedisEndpointFromContext added in v1.0.0 

func MustRedisEndpointFromContext(ctx context.Context) *redis.Redis

func MustResourceFromContext added in v1.0.0 

func MustResourceFromContext(ctx context.Context) *models.Resource

func MustResourceOwnershipFromContext added in v1.1.0 

func MustResourceOwnershipFromContext(ctx context.Context) *models.ResourceOwnership

func MustStrategyFromContext added in v1.1.0 

func MustStrategyFromContext(ctx context.Context) *models.Strategy

func MustTrafficLimitFromContext added in v1.2.5 

func MustTrafficLimitFromContext(ctx context.Context) *models.TrafficLimit

func MustWasmApiServerFromContext added in v1.4.2 

func MustWasmApiServerFromContext(ctx context.Context) wasmapi.Server

func OperatorFromContext added in v1.1.0 

func OperatorFromContext(ctx context.Context) (*models.Operator, bool)

func OperatorPoolFromContext added in v1.5.9 

func OperatorPoolFromContext(ctx context.Context) (optypes.Pool, bool)

func OperatorsFromContext added in v1.4.6 

func OperatorsFromContext(ctx context.Context) ([]models.Operator, bool)

func ProjectFromContext 

func ProjectFromContext(ctx context.Context) (*models.Project, bool)

func ProjectOperatorFromContext added in v1.4.6 

func ProjectOperatorFromContext(ctx context.Context) (*models.ProjectOperator, bool)

func ProxyClientFromContext added in v1.1.0 

func ProxyClientFromContext(ctx context.Context) (*client.Client, bool)

func PublisherFromContext added in v1.1.0 

func PublisherFromContext(ctx context.Context) (*models.Publisher, bool)

func RedisEndpointFromContext added in v1.0.0 

func RedisEndpointFromContext(ctx context.Context) (*redis.Redis, bool)

func ResourceFromContext added in v1.0.0 

func ResourceFromContext(ctx context.Context) (*models.Resource, bool)

func ResourceOwnershipFromContext added in v1.1.0 

func ResourceOwnershipFromContext(ctx context.Context) (*models.ResourceOwnership, bool)

func StrategyFromContext added in v1.1.0 

func StrategyFromContext(ctx context.Context) (*models.Strategy, bool)

func TrafficLimitFromContext added in v1.2.5 

func TrafficLimitFromContext(ctx context.Context) (*models.TrafficLimit, bool)

func WasmApiServerFromContext added in v1.4.2 

func WasmApiServerFromContext(ctx context.Context) (wasmapi.Server, bool)

func WithAccount added in v1.1.0 

func WithAccount(ctx context.Context, v *models.Account) context.Context

func WithAccountContext added in v1.1.0 

func WithAccountContext(v *models.Account) contextx.WithContext

func WithApplet 

func WithApplet(ctx context.Context, a *models.Applet) context.Context

func WithAppletContext 

func WithAppletContext(a *models.Applet) contextx.WithContext

func WithChainConfig added in v1.5.3 

func WithChainConfig(ctx context.Context, v *ChainConfig) context.Context

func WithChainConfigContext added in v1.5.3 

func WithChainConfigContext(v *ChainConfig) contextx.WithContext

func WithChainHeight added in v1.1.0 

func WithChainHeight(ctx context.Context, v *models.ChainHeight) context.Context

func WithChainHeightContext added in v1.1.0 

func WithChainHeightContext(v *models.ChainHeight) contextx.WithContext

func WithChainTx added in v1.1.0 

func WithChainTx(ctx context.Context, v *models.ChainTx) context.Context

func WithChainTxContext added in v1.1.0 

func WithChainTxContext(v *models.ChainTx) contextx.WithContext

func WithContractLog added in v1.1.0 

func WithContractLog(ctx context.Context, v *models.ContractLog) context.Context

func WithContractLogContext added in v1.1.0 

func WithContractLogContext(v *models.ContractLog) contextx.WithContext

func WithCronJob added in v1.1.0 

func WithCronJob(ctx context.Context, v *models.CronJob) context.Context

func WithCronJobContext added in v1.1.0 

func WithCronJobContext(v *models.CronJob) contextx.WithContext

func WithETHClientConfig 

func WithETHClientConfig(ctx context.Context, v *ETHClientConfig) context.Context

func WithETHClientConfigContext 

func WithETHClientConfigContext(v *ETHClientConfig) contextx.WithContext

func WithEnableTrafficLimit 

func WithEnableTrafficLimit(ctx context.Context, v bool) context.Context

func WithEnableTrafficLimitContext 

func WithEnableTrafficLimitContext(v bool) contextx.WithContext

func WithEthAddressWhiteList added in v1.4.6 

func WithEthAddressWhiteList(ctx context.Context, v *EthAddressWhiteList) context.Context

func WithEthAddressWhiteListContext added in v1.4.6 

func WithEthAddressWhiteListContext(v *EthAddressWhiteList) contextx.WithContext

func WithEventID added in v1.2.2 

func WithEventID(ctx context.Context, v string) context.Context

func WithEventIDContext added in v1.2.2 

func WithEventIDContext(v string) contextx.WithContext

func WithFileSystemOp added in v1.1.0 

func WithFileSystemOp(ctx context.Context, v filesystem.FileSystemOp) context.Context

func WithFileSystemOpContext added in v1.1.0 

func WithFileSystemOpContext(v filesystem.FileSystemOp) contextx.WithContext

func WithInstance 

func WithInstance(ctx context.Context, i *models.Instance) context.Context

func WithInstanceContext 

func WithInstanceContext(i *models.Instance) contextx.WithContext

func WithLogger 

func WithLogger(ctx context.Context, v log.Logger) context.Context

func WithLoggerContext 

func WithLoggerContext(v log.Logger) contextx.WithContext

func WithMaxWasmConsumeFuel 

func WithMaxWasmConsumeFuel(ctx context.Context, v uint64) context.Context

func WithMaxWasmConsumeFuelContext 

func WithMaxWasmConsumeFuelContext(v uint64) contextx.WithContext

func WithMetricsCenterConfig added in v1.2.2 

func WithMetricsCenterConfig(ctx context.Context, v *MetricsCenterConfig) context.Context

func WithMetricsCenterConfigContext added in v1.2.2 

func WithMetricsCenterConfigContext(v *MetricsCenterConfig) contextx.WithContext

func WithMgrDBExecutor added in v1.0.0 

func WithMgrDBExecutor(ctx context.Context, v sqlx.DBExecutor) context.Context

func WithMgrDBExecutorContext added in v1.0.0 

func WithMgrDBExecutorContext(v sqlx.DBExecutor) contextx.WithContext

func WithMonitorDBExecutor 

func WithMonitorDBExecutor(ctx context.Context, v sqlx.DBExecutor) context.Context

func WithMonitorDBExecutorContext 

func WithMonitorDBExecutorContext(v sqlx.DBExecutor) contextx.WithContext

func WithMqttBroker 

func WithMqttBroker(ctx context.Context, v *mqtt.Broker) context.Context

func WithMqttBrokerContext 

func WithMqttBrokerContext(v *mqtt.Broker) contextx.WithContext

func WithOperator added in v1.1.0 

func WithOperator(ctx context.Context, v *models.Operator) context.Context

func WithOperatorContext added in v1.1.0 

func WithOperatorContext(v *models.Operator) contextx.WithContext

func WithOperatorPool added in v1.5.9 

func WithOperatorPool(ctx context.Context, v optypes.Pool) context.Context

func WithOperatorPoolContext added in v1.5.9 

func WithOperatorPoolContext(v optypes.Pool) contextx.WithContext

func WithOperators added in v1.4.6 

func WithOperators(ctx context.Context, v []models.Operator) context.Context

func WithOperatorsContext added in v1.4.6 

func WithOperatorsContext(v []models.Operator) contextx.WithContext

func WithProject 

func WithProject(ctx context.Context, p *models.Project) context.Context

func WithProjectContext 

func WithProjectContext(p *models.Project) contextx.WithContext

func WithProjectFilter 

func WithProjectFilter(ctx context.Context, f *ProjectFilter) context.Context

func WithProjectFilterContext 

func WithProjectFilterContext(f *ProjectFilter) contextx.WithContext

func WithProjectOperator added in v1.4.6 

func WithProjectOperator(ctx context.Context, v *models.ProjectOperator) context.Context

func WithProjectOperatorContext added in v1.4.6 

func WithProjectOperatorContext(v *models.ProjectOperator) contextx.WithContext

func WithProxyClient added in v1.1.0 

func WithProxyClient(ctx context.Context, v *client.Client) context.Context

func WithProxyClientContext added in v1.1.0 

func WithProxyClientContext(v *client.Client) contextx.WithContext

func WithPublisher added in v1.1.0 

func WithPublisher(ctx context.Context, v *models.Publisher) context.Context

func WithPublisherContext added in v1.1.0 

func WithPublisherContext(v *models.Publisher) contextx.WithContext

func WithRedis added in v1.1.0 

func WithRedis(ctx context.Context, v *redis.Redis) context.Context

func WithRedisEndpointContext added in v1.0.0 

func WithRedisEndpointContext(v *redis.Redis) contextx.WithContext

func WithResource added in v1.0.0 

func WithResource(ctx context.Context, r *models.Resource) context.Context

func WithResourceContext added in v1.0.0 

func WithResourceContext(r *models.Resource) contextx.WithContext

func WithResourceOwnership added in v1.1.0 

func WithResourceOwnership(ctx context.Context, o *models.ResourceOwnership) context.Context

func WithResourceOwnershipContext added in v1.1.0 

func WithResourceOwnershipContext(o *models.ResourceOwnership) contextx.WithContext

func WithRobotNotifierConfig added in v1.2.3 

func WithRobotNotifierConfig(ctx context.Context, v *RobotNotifierConfig) context.Context

func WithRobotNotifierConfigContext added in v1.2.3 

func WithRobotNotifierConfigContext(v *RobotNotifierConfig) contextx.WithContext

func WithStrategy added in v1.1.0 

func WithStrategy(ctx context.Context, v *models.Strategy) context.Context

func WithStrategyContext added in v1.1.0 

func WithStrategyContext(v *models.Strategy) contextx.WithContext

func WithStrategyResults added in v1.1.0 

func WithStrategyResults(ctx context.Context, v []*StrategyResult) context.Context

func WithStrategyResultsContext added in v1.1.0 

func WithStrategyResultsContext(v []*StrategyResult) contextx.WithContext

func WithTrafficLimit added in v1.2.5 

func WithTrafficLimit(ctx context.Context, r *models.TrafficLimit) context.Context

func WithTrafficLimitContext added in v1.2.5 

func WithTrafficLimitContext(r *models.TrafficLimit) contextx.WithContext

func WithUploadConfig 

func WithUploadConfig(ctx context.Context, v *UploadConfig) context.Context

func WithUploadConfigContext 

func WithUploadConfigContext(v *UploadConfig) contextx.WithContext

func WithWasmApiServer added in v1.4.2 

func WithWasmApiServer(ctx context.Context, v wasmapi.Server) context.Context

func WithWasmApiServerContext added in v1.4.2 

func WithWasmApiServerContext(v wasmapi.Server) contextx.WithContext

func WithWasmDBConfig added in v1.2.2 

func WithWasmDBConfig(ctx context.Context, v *WasmDBConfig) context.Context

func WithWasmDBConfigContext added in v1.2.2 

func WithWasmDBConfigContext(v *WasmDBConfig) contextx.WithContext

Types

type Chain added in v1.5.3 

type Chain struct {
	ChainID                         uint64          `json:"chainID,omitempty"`
	Name                            enums.ChainName `json:"name"`
	Endpoint                        string          `json:"endpoint"`
	AABundlerEndpoint               string          `json:"aaBundlerEndpoint"`
	AAPaymasterEndpoint             string          `json:"aaPaymasterEndpoint"`
	AAEntryPointContractAddress     string          `json:"aaEntryPointContractAddress"`
	AAAccountFactoryContractAddress string          `json:"aaAccountFactoryContractAddress"`
}

func (*Chain) IsAASupported added in v1.5.9 

func (c *Chain) IsAASupported() bool

func (*Chain) IsEth added in v1.5.3 

func (c *Chain) IsEth() bool

func (*Chain) IsSolana added in v1.5.3 

func (c *Chain) IsSolana() bool

func (*Chain) IsZKSync added in v1.6.1 

func (c *Chain) IsZKSync() bool

type ChainConfig added in v1.5.3 

type ChainConfig struct {
	Configs          string                     `env:""     json:"-"`
	Chains           map[enums.ChainName]*Chain `env:"-"    json:"-"`
	ChainIDs         map[uint64]*Chain          `env:"-"    json:"-"`
	AAUserOpEndpoint string                     `env:""     json:"-"`
}

func ChainConfigFromContext added in v1.5.3 

func ChainConfigFromContext(ctx context.Context) (*ChainConfig, bool)

func MustChainConfigFromContext added in v1.5.3 

func MustChainConfigFromContext(ctx context.Context) *ChainConfig

func (*ChainConfig) GetChain added in v1.5.3 

func (c *ChainConfig) GetChain(chainID uint64, chainName enums.ChainName) (*Chain, bool)

func (*ChainConfig) Init added in v1.5.3 

func (c *ChainConfig) Init()

func (*ChainConfig) LivenessCheck added in v1.5.6 

func (cc *ChainConfig) LivenessCheck() map[string]string

type CtxAccount added in v1.1.0 

type CtxAccount struct{}

CtxAccount type *models.Account

type CtxApplet 

type CtxApplet struct{}

CtxApplet type *models.Applet

type CtxChainConfig added in v1.5.3 

type CtxChainConfig struct{}

CtxChainConfig type *ChainConfig global chain endpoints

type CtxChainHeight added in v1.4.6 

type CtxChainHeight struct{}

CtxChainHeight type *models.ChainHeight

type CtxChainTx added in v1.4.6 

type CtxChainTx struct{}

CtxChainTx type *models.ChainTx

type CtxContractLog added in v1.4.6 

type CtxContractLog struct{}

CtxContractLog type *models.ContractLog

type CtxCronJob added in v1.1.0 

type CtxCronJob struct{}

CtxCronJob type *models.CronJob

type CtxEnableTrafficLimit 

type CtxEnableTrafficLimit struct{}

CtxEnableTrafficLimit if enable traffic limit

type CtxEthAddressWhiteList added in v1.4.6 

type CtxEthAddressWhiteList struct{}

CtxWhiteList type *EthAddressWhiteList global eth address white list

type CtxEthClient 

type CtxEthClient struct{}

CtxEthClient type *ETHClientConfig global eth chain endpoints

type CtxEventID added in v1.2.2 

type CtxEventID struct{}

CtxEventID type string. current event id

type CtxFileSystemOp added in v1.1.0 

type CtxFileSystemOp struct{}

CtxFileSystemOp type filesystem.FileSystemOp describe resource storing operation type

type CtxInstance 

type CtxInstance struct{}

CtxInstance type *models.Instance

type CtxLogger 

type CtxLogger struct{}

CtxLogger type log.Logger. service logger

type CtxMaxWasmConsumeFuel 

type CtxMaxWasmConsumeFuel struct{}

CtxMaxWasmConsumeFuel global wasm consume fuel per invoking

type CtxMetricsCenterConfig added in v1.2.2 

type CtxMetricsCenterConfig struct{}

CtxMetricsCenterConfig *MetricsCenterConfig for metrics

type CtxMgrDBExecutor added in v1.0.0 

type CtxMgrDBExecutor struct{}

CtxMgrDBExecutor type sqlx.DBExecutor for global manager server database

type CtxMonitorDBExecutor 

type CtxMonitorDBExecutor struct{}

CtxMonitorDBExecutor type sqlx.DBExecutor for global monitor server database

type CtxMqttBroker 

type CtxMqttBroker struct{}

CtxMqttBroker *mqtt.Broker. mqtt broker

type CtxOperator added in v1.1.0 

type CtxOperator struct{}

CtxOperator type *models.Operator

type CtxOperatorPool added in v1.5.9 

type CtxOperatorPool struct{}

CtxOperatorPool type *operator.Pool global operator memory pool

type CtxOperators added in v1.4.6 

type CtxOperators struct{}

CtxOperators type []models.Operator filtered operators

type CtxProject 

type CtxProject struct{}

CtxProject type *models.Project

type CtxProjectFilter 

type CtxProjectFilter struct{}

CtxProjectFilter global project filter

type CtxProjectOperator added in v1.4.6 

type CtxProjectOperator struct{}

CtxProjectOperator type *models.ProjectOperator

type CtxProxyClient added in v1.1.0 

type CtxProxyClient struct{}

CtxProxyClient type *client.Client http client for forwarding mqtt event

type CtxPublisher added in v1.1.0 

type CtxPublisher struct{}

CtxPublisher type *models.Publisher

type CtxRedisEndpoint added in v1.0.0 

type CtxRedisEndpoint struct{}

CtxRedisEndpoint type *redis.Redis. redis endpoint

type CtxResource added in v1.0.0 

type CtxResource struct{}

CtxResource type *models.Resource

type CtxResourceOwnership added in v1.1.0 

type CtxResourceOwnership struct{}

CtxResourceOwnership type *models.ResourceOwnership

type CtxRobotNotifierConfig added in v1.2.3 

type CtxRobotNotifierConfig struct{}

CtxRobotNotifierConfig type *RobotNotifierConfig for notify service level message to maintainers.

type CtxStrategy added in v1.1.0 

type CtxStrategy struct{}

CtxStrategy type *models.Strategy

type CtxStrategyResults added in v1.1.0 

type CtxStrategyResults struct{} // CtxStrategyResults

CtxStrategyResults type []*StrategyResult event strategies

type CtxTrafficLimit added in v1.2.5 

type CtxTrafficLimit struct{}

CtxTrafficLimit type *models.TrafficLimit

type CtxUploadConfig 

type CtxUploadConfig struct{}

CtxUploadConfig type *UploadConfig. resource upload configuration

type CtxWasmApiServer added in v1.4.2 

type CtxWasmApiServer struct{}

CtxWasmApiServer type wasmapi/types.Server wasm global async server TODO move to wasm context package

type CtxWasmDBConfig added in v1.2.2 

type CtxWasmDBConfig struct{}

CtxWasmDBConfig type *WasmDBConfig wasm database config

type ETHClientConfig 

type ETHClientConfig struct {
	Endpoints string            `env:""`
	Clients   map[uint32]string `env:"-"`
}

func ETHClientConfigFromContext 

func ETHClientConfigFromContext(ctx context.Context) (*ETHClientConfig, bool)

func MustETHClientConfigFromContext 

func MustETHClientConfigFromContext(ctx context.Context) *ETHClientConfig

func (*ETHClientConfig) Init added in v1.2.4 

func (c *ETHClientConfig) Init()

type EthAddress added in v1.1.0 

type EthAddress = types.EthAddress

aliases from base/types

type EthAddressWhiteList added in v1.4.6 

type EthAddressWhiteList []string

func EthAddressWhiteListFromContext added in v1.4.6 

func EthAddressWhiteListFromContext(ctx context.Context) (*EthAddressWhiteList, bool)

func MustEthAddressWhiteListFromContext added in v1.4.6 

func MustEthAddressWhiteListFromContext(ctx context.Context) *EthAddressWhiteList

func (*EthAddressWhiteList) Init added in v1.4.6 

func (v *EthAddressWhiteList) Init()

func (*EthAddressWhiteList) Validate added in v1.4.6 

func (v *EthAddressWhiteList) Validate(address string) bool

type FileSystem added in v1.1.0 

type FileSystem struct {
	Type enums.FileSystemMode `env:""`
}

func (*FileSystem) SetDefault added in v1.1.0 

func (f *FileSystem) SetDefault()

type Initializer added in v1.1.0 

type Initializer = types.Initializer

aliases from base/types

type InitializerWith added in v1.1.0 

type InitializerWith = types.InitializerWith

aliases from base/types

type MetricsCenterConfig added in v1.2.2 

type MetricsCenterConfig struct {
	Endpoint      string `env:""`
	ClickHouseDSN string `env:""`
}

func MetricsCenterConfigFromContext added in v1.2.2 

func MetricsCenterConfigFromContext(ctx context.Context) (*MetricsCenterConfig, bool)

func MustMetricsCenterConfigFromContext added in v1.2.2 

func MustMetricsCenterConfigFromContext(ctx context.Context) *MetricsCenterConfig

type ProjectFilter 

type ProjectFilter struct {
	WhiteList []SFID
	BlackList []SFID
}

func MustProjectFilterFromContext 

func MustProjectFilterFromContext(ctx context.Context) *ProjectFilter

func ProjectFilterFromContext 

func ProjectFilterFromContext(ctx context.Context) (*ProjectFilter, bool)

func (*ProjectFilter) Filter 

func (f *ProjectFilter) Filter(id types.SFID) bool

type Risc0Config added in v1.5.9 

type Risc0Config struct {
	Endpoint        string
	Websocket       string
	CreateProofPath string
}

func (*Risc0Config) LivenessCheck added in v1.5.9 

func (r *Risc0Config) LivenessCheck() map[string]string

type RobotNotifierConfig added in v1.2.3 

type RobotNotifierConfig struct {
	Vendor string   `env:""` // Vendor robot vendor eg: `Lark` `Wechat Work` `DingTalk`
	Env    string   `env:""` // Env Service env, eg: dev-staging, prod
	URL    string   `env:""` // URL webhook url
	Secret string   `env:""` // Secret message secret
	PINs   []string `env:""` // PINs pin someone

	SignFn func(int64) (string, error) `env:"-"`
}

func MustRobotNotifierConfigFromContext added in v1.2.3 

func MustRobotNotifierConfigFromContext(ctx context.Context) *RobotNotifierConfig

func RobotNotifierConfigFromContext added in v1.2.3 

func RobotNotifierConfigFromContext(ctx context.Context) (*RobotNotifierConfig, bool)

func (*RobotNotifierConfig) Init added in v1.2.3 

func (c *RobotNotifierConfig) Init()

func (*RobotNotifierConfig) IsZero added in v1.2.3 

func (c *RobotNotifierConfig) IsZero() bool

type SFID 

type SFID = types.SFID

aliases from base/types

type SFIDs 

type SFIDs = types.SFIDs

aliases from base/types

type StrategyResult added in v1.1.0 

type StrategyResult struct {
	ProjectName string         `json:"projectName" db:"f_prj_name"`
	AppletID    types.SFID     `json:"appletID"    db:"f_app_id"`
	AppletName  string         `json:"appletName"  db:"f_app_name"`
	InstanceID  types.SFID     `json:"instanceID"  db:"f_ins_id"`
	Handler     string         `json:"handler"     db:"f_hdl"`
	EventType   string         `json:"eventType"   db:"f_evt"`
	AutoCollect datatypes.Bool `json:"autoCollect" db:"f_auto_collect"`
}

func MustStrategyResultsFromContext added in v1.1.0 

func MustStrategyResultsFromContext(ctx context.Context) []*StrategyResult

func StrategyResultsFromContext added in v1.1.0 

func StrategyResultsFromContext(ctx context.Context) ([]*StrategyResult, bool)

type Timestamp added in v1.1.0 

type Timestamp = types.Timestamp

aliases from base/types

type UploadConfig 

type UploadConfig struct {
	FilesizeLimitBytes int64 `env:""`
	DiskReserveBytes   int64 `env:""`
}

func MustUploadConfigFromContext 

func MustUploadConfigFromContext(ctx context.Context) *UploadConfig

func UploadConfigFromContext 

func UploadConfigFromContext(ctx context.Context) (*UploadConfig, bool)

func (*UploadConfig) SetDefault 

func (c *UploadConfig) SetDefault()

type ValidatedInitializer added in v1.1.0 

type ValidatedInitializer = types.ValidatedInitializer

aliases from base/types

type ValidatedInitializerWith added in v1.1.0 

type ValidatedInitializerWith = types.ValidatedInitializerWith

aliases from base/types

type WasmDBConfig added in v1.2.2 

type WasmDBConfig struct {
	Endpoint        types.Endpoint
	MaxConnection   int
	PoolSize        int
	ConnMaxLifetime types.Duration
	LazyInit        bool
}

func MustWasmDBConfigFromContext added in v1.2.2 

func MustWasmDBConfigFromContext(ctx context.Context) *WasmDBConfig

func WasmDBConfigFromContext added in v1.2.2 

func WasmDBConfigFromContext(ctx context.Context) (*WasmDBConfig, bool)

func (*WasmDBConfig) SetDefault added in v1.2.2 

func (c *WasmDBConfig) SetDefault()

Source Files

View all Source files

Directories

Path Synopsis
kvdb
sql_util

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.