types

package
v1.0.0 Latest Latest
Warning

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

 Go to latest Published: Feb 9, 2023 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func AppletFromContext 

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

func InstanceFromContext 

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

func LoggerFromContext 

func LoggerFromContext(ctx context.Context) (log.Logger, 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 MustAppletFromContext 

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

func MustInstanceFromContext 

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

func MustLoggerFromContext 

func MustLoggerFromContext(ctx context.Context) log.Logger

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 MustPgEndpointFromContext 

func MustPgEndpointFromContext(ctx context.Context) *postgres.Endpoint

func MustProjectFromContext 

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

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 MustTaskBoardFromContext 

func MustTaskBoardFromContext(ctx context.Context) *mq.TaskBoard

func MustTaskWorkerFromContext 

func MustTaskWorkerFromContext(ctx context.Context) *mq.TaskWorker

func MustWasmDBExecutorFromContext added in v1.0.0 

func MustWasmDBExecutorFromContext(ctx context.Context) *postgres.Endpoint

func PgEndpointFromContext 

func PgEndpointFromContext(ctx context.Context) (*postgres.Endpoint, bool)

func ProjectFromContext 

func ProjectFromContext(ctx context.Context) (*models.Project, 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 TaskBoardFromContext 

func TaskBoardFromContext(ctx context.Context) (*mq.TaskBoard, bool)

func TaskWorkerFromContext 

func TaskWorkerFromContext(ctx context.Context) (*mq.TaskWorker, bool)

func WasmDBExecutorFromContext added in v1.0.0 

func WasmDBExecutorFromContext(ctx context.Context) (*postgres.Endpoint, bool)

func WithApplet 

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

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 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 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 WithPgEndpoint 

func WithPgEndpoint(ctx context.Context, v postgres.Endpoint) context.Context

func WithPgEndpointContext 

func WithPgEndpointContext(v *postgres.Endpoint) contextx.WithContext

func WithProject 

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

func WithProjectContext 

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

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 WithTaskBoard 

func WithTaskBoard(ctx context.Context, tb *mq.TaskBoard) context.Context

func WithTaskBoardContext 

func WithTaskBoardContext(tb *mq.TaskBoard) contextx.WithContext

func WithTaskWorker 

func WithTaskWorker(ctx context.Context, tw *mq.TaskWorker) context.Context

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 WithWasmDBExecutor(ctx context.Context, v postgres.Endpoint) context.Context

func WithWasmDBExecutorContext added in v1.0.0 

func WithWasmDBExecutorContext(v *postgres.Endpoint) contextx.WithContext

Types

type CtxApplet 

type CtxApplet struct{}

type CtxEthClient 

type CtxEthClient struct{} // CtxEthClient ETHClientConfig

type CtxInstance 

type CtxInstance struct{}

type CtxLogger 

type CtxLogger struct{} // CtxLogger log.Logger

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 CtxRedisEndpoint added in v1.0.0 

type CtxRedisEndpoint struct{} // CtxRedisEndpoint redis.Redis

type CtxResource added in v1.0.0 

type CtxResource 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 ETHClientConfig 

type ETHClientConfig struct {
	PrivateKey string `env:""`
	Endpoints  string `env:""`
}

func ETHClientConfigFromContext 

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

func MustETHClientConfigFromContext 

func MustETHClientConfigFromContext(ctx context.Context) *ETHClientConfig

type SFID 

type SFID = types.SFID

type SFIDs 

type SFIDs = types.SFIDs

type UploadConfig 

type UploadConfig struct {
	Root          string `env:""`
	FileSizeLimit 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()

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.