cmd

package
v1.2.15 Latest Latest
Warning

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

Go to latest
Published: Aug 8, 2022 License: MIT Imports: 54 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var (
	ErrInvalidArgument = errors.New("invalid argument")
)
View Source
var (
	RootCmd = &cobra.Command{
		Use:   "metathingsd",
		Short: "MetaThingsd Command Line Toolkits",
	}
)

Functions

func NewDescriptorStorage added in v1.1.27

func NewDescriptorStorage(opt *DevicedOption, logger log.FieldLogger) (descriptor_storage.DescriptorStorage, error)

func NewDeviceCloudRouting added in v1.1.18

func NewDeviceCloudRouting(p NewDeviceCloudRoutingParams) error

func NewDeviceCloudStorage added in v1.0.0

func NewDeviceCloudStorage(opt *DeviceCloudOption, logger log.FieldLogger) (storage.Storage, error)

func NewDevicedDataLaunchers added in v1.2.15

func NewDevicedDataLaunchers(p NewDevicedDataLaunchersParams) ([]evaluatord_sdk.DataLauncher, error)

func NewDevicedStorage

func NewDevicedStorage(p NewDevicedStorageParams) (storage.Storage, error)

func NewEvaluatordDataStorage added in v1.2.5

func NewEvaluatordDataStorage(p NewEvaluatordDataStorageParams) (dssdk.DataStorage, error)

func NewEvaluatordStorage added in v1.1.24

func NewEvaluatordStorage(p NewEvaluatordStorageParams) (storage.Storage, error)

func NewEvaluatordTaskStorage added in v1.1.28

func NewEvaluatordTaskStorage(p NewEvaluatordTaskStorageParams) (storage.TaskStorage, error)

func NewEvaluatordTimerBackend added in v1.1.28

func NewEvaluatordTimerBackend(p NewEvaluatordTimerBackendParams) (timer_backend.TimerBackend, error)

func NewEvaluatordTimerStorage added in v1.1.28

func NewEvaluatordTimerStorage(p NewEvaluatordTimerStorageParams) (storage.TimerStorage, error)

func NewFlowFactory added in v1.1.23

func NewFlowFactory(opt *DevicedOption, logger log.FieldLogger) (flow.FlowFactory, error)

func NewFlowSetFactory added in v1.1.23

func NewFlowSetFactory(opt *DevicedOption, logger log.FieldLogger) (flow.FlowSetFactory, error)

func NewIdentityd2Backend

func NewIdentityd2Backend(cli_fty *client_helper.ClientFactory, logger log.FieldLogger) (policy.Backend, error)

func NewMetathingsDeviceCloudServiceOption added in v1.0.0

func NewMetathingsDeviceCloudServiceOption(opt *DeviceCloudOption) *service.MetathingsDeviceCloudServiceOption

func NewMetathingsDevicedServiceOption

func NewMetathingsDevicedServiceOption(opt *DevicedOption) *service.MetathingsDevicedServiceOption

func NewMetathingsEvaulatordServiceOption added in v1.1.24

func NewMetathingsEvaulatordServiceOption(opt *EvaluatordOption) *service.MetathingsEvaluatordServiceOption

func NewMetathingsPolicydServiceOption

func NewMetathingsPolicydServiceOption(opt *PolicydOption) (*service.MetathingsPolicydServiceOption, error)

func NewMosquittoPluginRouting added in v1.1.18

func NewMosquittoPluginRouting(p NewMosquittoPluginRoutingParams) error

func NewMosquittoPluginServiceOption added in v1.0.0

func NewMosquittoPluginServiceOption(opt *MosquittoPluginOption) *service.MosquittoPluginServiceOption

func NewMosquittoPluginStorage added in v1.0.0

func NewMosquittoPluginStorage(
	opt *MosquittoPluginOption,
	logger log.FieldLogger,
) (storage.Storage, error)

func NewSessionStorage

func NewSessionStorage(opt *DevicedOption, logger log.FieldLogger) (session_storage.SessionStorage, error)

func NewSimpleStorage

func NewSimpleStorage(opt *DevicedOption, logger log.FieldLogger) (simple_storage.SimpleStorage, error)

func NewTagdStorage

func NewTagdStorage(opt *TagdOption, logger log.FieldLogger) (storage.Storage, error)

Types

type DeviceCloudOption added in v1.0.0

type DeviceCloudOption struct {
	cmd_contrib.ServiceBaseOption `mapstructure:",squash"`
	Storage                       map[string]interface{}
	Connection                    map[string]interface{}
}

func NewDeviceCloudOption added in v1.0.0

func NewDeviceCloudOption() *DeviceCloudOption

type DevicedOption

type DevicedOption struct {
	cmd_contrib.ServiceBaseOption `mapstructure:",squash"`
	SessionStorage                map[string]interface{}
	SimpleStorage                 map[string]interface{}
	DescriptorStorage             map[string]interface{}
	ConnectionCenter              struct {
		Storage map[string]interface{}
		Bridge  map[string]interface{}
	}
	Flow          map[string]interface{}
	FlowSet       map[string]interface{}
	DataLaunchers map[string]interface{}
}

func NewDevicedOption

func NewDevicedOption() *DevicedOption

type EvaluatordOption added in v1.1.24

type EvaluatordOption struct {
	cmd_contrib.ServiceBaseOption `mapstructure:",squash"`
	TaskStorage                   map[string]interface{}
	DataStorage                   map[string]interface{}
	TimerStorage                  map[string]interface{}
	TimerBackend                  map[string]interface{}
}

func NewEvaluatordOption added in v1.1.24

func NewEvaluatordOption() *EvaluatordOption

type MosquittoPluginOption added in v1.0.0

type MosquittoPluginOption struct {
	cmd_contrib.ServiceBaseOption `mapstructure:",squash"`
	MosquittoStorage              map[string]interface{}
	Webhook                       cmd_contrib.WebhookOption
}

func NewMosquittoPluginOption added in v1.0.0

func NewMosquittoPluginOption() *MosquittoPluginOption

type NewConnectionCenterParams added in v1.1.28

type NewConnectionCenterParams struct {
	fx.In

	Option         *DevicedOption
	SessionStorage session_storage.SessionStorage
	Logger         log.FieldLogger
	Tracer         opentracing.Tracer `name:"opentracing_tracer" optional:"true"`
}

type NewDeviceCloudRoutingParams added in v1.1.18

type NewDeviceCloudRoutingParams struct {
	fx.In

	Router  *mux.Router
	Service *service.MetathingsDeviceCloudService
}

type NewDevicedDataLaunchersParams added in v1.2.15

type NewDevicedDataLaunchersParams struct {
	fx.In

	Option *DevicedOption
	Logger log.FieldLogger
	Tracer opentracing.Tracer `name:"opentracing_tracer" optional:"true"`
}

type NewDevicedStorageParams added in v1.1.18

type NewDevicedStorageParams struct {
	fx.In

	Option cmd_contrib.StorageOptioner
	Logger log.FieldLogger
	Tracer opentracing.Tracer `name:"opentracing_tracer" optional:"true"`
}

type NewEvaluatordDataStorageParams added in v1.2.5

type NewEvaluatordDataStorageParams struct {
	fx.In

	Option *EvaluatordOption
	Logger logrus.FieldLogger
}

type NewEvaluatordStorageParams added in v1.1.24

type NewEvaluatordStorageParams struct {
	fx.In

	Option cmd_contrib.StorageOptioner
	Logger logrus.FieldLogger
	Tracer opentracing.Tracer `name:"opentracing_tracer" optional:"true"`
}

type NewEvaluatordTaskStorageParams added in v1.1.28

type NewEvaluatordTaskStorageParams struct {
	fx.In

	Option *EvaluatordOption
	Logger logrus.FieldLogger
	Tracer opentracing.Tracer `name:"opentracing_tracer" optional:"true"`
}

type NewEvaluatordTimerBackendParams added in v1.1.28

type NewEvaluatordTimerBackendParams struct {
	fx.In

	Option *EvaluatordOption
	Logger logrus.FieldLogger
}

type NewEvaluatordTimerStorageParams added in v1.1.28

type NewEvaluatordTimerStorageParams struct {
	fx.In

	Option *EvaluatordOption
	Logger logrus.FieldLogger
	Tracer opentracing.Tracer `name:"opentracing_tracer" optional:"true"`
}

type NewIdentityd2StorageParams added in v1.1.18

type NewIdentityd2StorageParams struct {
	fx.In

	Option cmd_contrib.StorageOptioner
	Logger log.FieldLogger
	Tracer opentracing.Tracer `name:"opentracing_tracer" optional:"true"`
}

type NewMosquittoPluginRoutingParams added in v1.1.18

type NewMosquittoPluginRoutingParams struct {
	fx.In

	Router  *mux.Router
	Service *service.MosquittoPluginService
	Tracer  opentracing.Tracer `name:"opentracing_tracer" optional:"true"`
}

type PolicydOption

type PolicydOption struct {
	cmd_contrib.ServiceBaseOption `mapstructure:",squash"`
	ModelFile                     string `mapstructure:"model_file"`
	PolicyFile                    string `mapstructure:"policy_file"`
}

func NewPolicydOption

func NewPolicydOption() *PolicydOption

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL