Documentation ¶
Index ¶
- func AccountFromContext(ctx context.Context) (*models.Account, bool)
- func AppletFromContext(ctx context.Context) (*models.Applet, bool)
- func InstanceFromContext(ctx context.Context) (*models.Instance, bool)
- func LoggerFromContext(ctx context.Context) (log.Logger, bool)
- func MgrDBExecutorFromContext(ctx context.Context) (sqlx.DBExecutor, bool)
- func MonitorDBExecutorFromContext(ctx context.Context) (sqlx.DBExecutor, bool)
- func MqttBrokerFromContext(ctx context.Context) (*mqtt.Broker, bool)
- func MustAccountFromContext(ctx context.Context) *models.Account
- func MustAppletFromContext(ctx context.Context) *models.Applet
- func MustInstanceFromContext(ctx context.Context) *models.Instance
- func MustLoggerFromContext(ctx context.Context) log.Logger
- func MustMgrDBExecutorFromContext(ctx context.Context) sqlx.DBExecutor
- func MustMonitorDBExecutorFromContext(ctx context.Context) sqlx.DBExecutor
- func MustMqttBrokerFromContext(ctx context.Context) *mqtt.Broker
- func MustPgEndpointFromContext(ctx context.Context) *postgres.Endpoint
- func MustProjectFromContext(ctx context.Context) *models.Project
- func MustPublisherFromContext(ctx context.Context) *models.Publisher
- func MustRedisEndpointFromContext(ctx context.Context) *redis.Redis
- func MustResourceFromContext(ctx context.Context) *models.Resource
- func MustStrategyFromContext(ctx context.Context) *models.Strategy
- func MustTaskBoardFromContext(ctx context.Context) *mq.TaskBoard
- func MustTaskWorkerFromContext(ctx context.Context) *mq.TaskWorker
- func MustWasmDBExecutorFromContext(ctx context.Context) sqlx.DBExecutor
- func PgEndpointFromContext(ctx context.Context) (*postgres.Endpoint, bool)
- func ProjectFromContext(ctx context.Context) (*models.Project, bool)
- func PublisherFromContext(ctx context.Context) (*models.Publisher, bool)
- func RedisEndpointFromContext(ctx context.Context) (*redis.Redis, bool)
- func ResourceFromContext(ctx context.Context) (*models.Resource, bool)
- func StrategyFromContext(ctx context.Context) (*models.Strategy, bool)
- func TaskBoardFromContext(ctx context.Context) (*mq.TaskBoard, bool)
- func TaskWorkerFromContext(ctx context.Context) (*mq.TaskWorker, bool)
- func WasmDBExecutorFromContext(ctx context.Context) (sqlx.DBExecutor, bool)
- func WithAccount(ctx context.Context, v *models.Account) context.Context
- func WithAccountContext(v *models.Account) contextx.WithContext
- func WithApplet(ctx context.Context, a *models.Applet) context.Context
- func WithAppletContext(a *models.Applet) contextx.WithContext
- func WithETHClientConfig(ctx context.Context, v *ETHClientConfig) context.Context
- func WithETHClientConfigContext(v *ETHClientConfig) contextx.WithContext
- func WithInstance(ctx context.Context, i *models.Instance) context.Context
- func WithInstanceContext(i *models.Instance) contextx.WithContext
- func WithLogger(ctx context.Context, v log.Logger) context.Context
- func WithLoggerContext(v log.Logger) contextx.WithContext
- func WithMgrDBExecutor(ctx context.Context, v sqlx.DBExecutor) context.Context
- func WithMgrDBExecutorContext(v sqlx.DBExecutor) contextx.WithContext
- func WithMonitorDBExecutor(ctx context.Context, v sqlx.DBExecutor) context.Context
- func WithMonitorDBExecutorContext(v sqlx.DBExecutor) contextx.WithContext
- func WithMqttBroker(ctx context.Context, v *mqtt.Broker) context.Context
- func WithMqttBrokerContext(v *mqtt.Broker) contextx.WithContext
- func WithPgEndpoint(ctx context.Context, v postgres.Endpoint) context.Context
- func WithPgEndpointContext(v *postgres.Endpoint) contextx.WithContext
- func WithProject(ctx context.Context, p *models.Project) context.Context
- func WithProjectContext(p *models.Project) contextx.WithContext
- func WithPublisher(ctx context.Context, v *models.Publisher) context.Context
- func WithPublisherContext(v *models.Publisher) contextx.WithContext
- func WithRedis(ctx context.Context, v *redis.Redis) context.Context
- func WithRedisEndpointContext(v *redis.Redis) contextx.WithContext
- func WithResource(ctx context.Context, r *models.Resource) context.Context
- func WithResourceContext(r *models.Resource) contextx.WithContext
- func WithStrategy(ctx context.Context, v *models.Strategy) context.Context
- func WithStrategyContext(v *models.Strategy) contextx.WithContext
- func WithTaskBoard(ctx context.Context, tb *mq.TaskBoard) context.Context
- func WithTaskBoardContext(tb *mq.TaskBoard) contextx.WithContext
- func WithTaskWorker(ctx context.Context, tw *mq.TaskWorker) context.Context
- func WithTaskWorkerContext(tw *mq.TaskWorker) contextx.WithContext
- func WithUploadConfig(ctx context.Context, v *UploadConfig) context.Context
- func WithUploadConfigContext(v *UploadConfig) contextx.WithContext
- func WithWasmDBExecutor(ctx context.Context, v sqlx.DBExecutor) context.Context
- func WithWasmDBExecutorContext(v sqlx.DBExecutor) contextx.WithContext
- func WithWhiteList(ctx context.Context, v *WhiteList) context.Context
- func WithWhiteListContext(v *WhiteList) contextx.WithContext
- type CtxAccount
- type CtxApplet
- type CtxEthClient
- type CtxInstance
- type CtxLogger
- type CtxMgrDBExecutor
- type CtxMonitorDBExecutor
- type CtxMqttBroker
- type CtxPgEndpoint
- type CtxProject
- type CtxPublisher
- type CtxRedisEndpoint
- type CtxResource
- type CtxStrategy
- type CtxTaskBoard
- type CtxTaskWorker
- type CtxUploadConfig
- type CtxWasmDBExecutor
- type CtxWhiteList
- type ETHClientConfig
- type EthAddress
- type Initializer
- type InitializerWith
- type SFID
- type SFIDs
- type Timestamp
- type UploadConfig
- type ValidatedInitializer
- type ValidatedInitializerWith
- type WhiteList
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func AccountFromContext ¶ added in v1.1.0
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 MustAccountFromContext ¶ added in v1.1.0
func MustMgrDBExecutorFromContext ¶ added in v1.0.0
func MustMgrDBExecutorFromContext(ctx context.Context) sqlx.DBExecutor
func MustMonitorDBExecutorFromContext ¶
func MustMonitorDBExecutorFromContext(ctx context.Context) sqlx.DBExecutor
func MustPublisherFromContext ¶ added in v1.1.0
func MustRedisEndpointFromContext ¶ added in v1.0.0
func MustResourceFromContext ¶ added in v1.0.0
func MustStrategyFromContext ¶ added in v1.1.0
func MustTaskWorkerFromContext ¶
func MustTaskWorkerFromContext(ctx context.Context) *mq.TaskWorker
func MustWasmDBExecutorFromContext ¶ added in v1.0.0
func MustWasmDBExecutorFromContext(ctx context.Context) sqlx.DBExecutor
func PgEndpointFromContext ¶
func PublisherFromContext ¶ added in v1.1.0
func RedisEndpointFromContext ¶ added in v1.0.0
func ResourceFromContext ¶ added in v1.0.0
func StrategyFromContext ¶ added in v1.1.0
func TaskWorkerFromContext ¶
func TaskWorkerFromContext(ctx context.Context) (*mq.TaskWorker, bool)
func WasmDBExecutorFromContext ¶ added in v1.0.0
func WasmDBExecutorFromContext(ctx context.Context) (sqlx.DBExecutor, bool)
func WithAccount ¶ added in v1.1.0
func WithAccountContext ¶ added in v1.1.0
func WithAccountContext(v *models.Account) contextx.WithContext
func WithAppletContext ¶
func WithAppletContext(a *models.Applet) contextx.WithContext
func WithETHClientConfig ¶
func WithETHClientConfig(ctx context.Context, v *ETHClientConfig) context.Context
func WithETHClientConfigContext ¶
func WithETHClientConfigContext(v *ETHClientConfig) contextx.WithContext
func WithInstanceContext ¶
func WithInstanceContext(i *models.Instance) contextx.WithContext
func WithLoggerContext ¶
func WithLoggerContext(v log.Logger) contextx.WithContext
func WithMgrDBExecutor ¶ added in v1.0.0
func WithMgrDBExecutorContext ¶ added in v1.0.0
func WithMgrDBExecutorContext(v sqlx.DBExecutor) contextx.WithContext
func WithMonitorDBExecutor ¶
func WithMonitorDBExecutorContext ¶
func WithMonitorDBExecutorContext(v sqlx.DBExecutor) contextx.WithContext
func WithMqttBrokerContext ¶
func WithMqttBrokerContext(v *mqtt.Broker) contextx.WithContext
func WithPgEndpointContext ¶
func WithPgEndpointContext(v *postgres.Endpoint) contextx.WithContext
func WithProjectContext ¶
func WithProjectContext(p *models.Project) contextx.WithContext
func WithPublisher ¶ added in v1.1.0
func WithPublisherContext ¶ added in v1.1.0
func WithPublisherContext(v *models.Publisher) contextx.WithContext
func WithRedisEndpointContext ¶ added in v1.0.0
func WithRedisEndpointContext(v *redis.Redis) contextx.WithContext
func WithResource ¶ added in v1.0.0
func WithResourceContext ¶ added in v1.0.0
func WithResourceContext(r *models.Resource) contextx.WithContext
func WithStrategy ¶ added in v1.1.0
func WithStrategyContext ¶ added in v1.1.0
func WithStrategyContext(v *models.Strategy) contextx.WithContext
func WithTaskBoardContext ¶
func WithTaskBoardContext(tb *mq.TaskBoard) contextx.WithContext
func WithTaskWorker ¶
func WithTaskWorkerContext ¶
func WithTaskWorkerContext(tw *mq.TaskWorker) contextx.WithContext
func WithUploadConfig ¶
func WithUploadConfig(ctx context.Context, v *UploadConfig) context.Context
func WithUploadConfigContext ¶
func WithUploadConfigContext(v *UploadConfig) contextx.WithContext
func WithWasmDBExecutor ¶ added in v1.0.0
func WithWasmDBExecutorContext ¶ added in v1.0.0
func WithWasmDBExecutorContext(v sqlx.DBExecutor) contextx.WithContext
func WithWhiteList ¶ added in v1.1.0
func WithWhiteListContext ¶ added in v1.1.0
func WithWhiteListContext(v *WhiteList) contextx.WithContext
Types ¶
type CtxAccount ¶ added in v1.1.0
type CtxAccount struct{}
type CtxEthClient ¶
type CtxEthClient struct{} // CtxEthClient ETHClientConfig
type CtxInstance ¶
type CtxInstance struct{}
type CtxMgrDBExecutor ¶ added in v1.0.0
type CtxMgrDBExecutor struct{} // CtxMgrDBExecutor sqlx.DBExecutor
type CtxMonitorDBExecutor ¶
type CtxMonitorDBExecutor struct{} // CtxMonitorDBExecutor sqlx.DBExecutor
type CtxMqttBroker ¶
type CtxMqttBroker struct{} // CtxMqttBroker mqtt.Broker
type CtxPgEndpoint ¶
type CtxPgEndpoint struct{} // CtxPgEndpoint postgres.Endpoint
type CtxProject ¶
type CtxProject struct{}
type CtxPublisher ¶ added in v1.1.0
type CtxPublisher struct{}
type CtxRedisEndpoint ¶ added in v1.0.0
type CtxRedisEndpoint struct{} // CtxRedisEndpoint redis.Redis
type CtxResource ¶ added in v1.0.0
type CtxResource struct{}
type CtxStrategy ¶ added in v1.1.0
type CtxStrategy struct{}
type CtxTaskBoard ¶
type CtxTaskBoard struct{}
type CtxTaskWorker ¶
type CtxTaskWorker struct{}
type CtxUploadConfig ¶
type CtxUploadConfig struct{} // CtxUploadConfig UploadConfig
type CtxWasmDBExecutor ¶ added in v1.0.0
type CtxWasmDBExecutor struct{} // CtxWasmDBExecutor sqlx.DBExecutor
type CtxWhiteList ¶ added in v1.1.0
type CtxWhiteList struct{}
type ETHClientConfig ¶
type ETHClientConfig struct {
Endpoints string `env:""`
}
func ETHClientConfigFromContext ¶
func ETHClientConfigFromContext(ctx context.Context) (*ETHClientConfig, bool)
func MustETHClientConfigFromContext ¶
func MustETHClientConfigFromContext(ctx context.Context) *ETHClientConfig
type InitializerWith ¶ added in v1.1.0
type InitializerWith = types.InitializerWith
aliases from base/types
type UploadConfig ¶
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 WhiteList ¶ added in v1.1.0
type WhiteList []string
func MustWhiteListFromContext ¶ added in v1.1.0
func WhiteListFromContext ¶ added in v1.1.0
Click to show internal directories.
Click to hide internal directories.