cmd

package
v1.2.14-alpha.1 Latest Latest
Warning

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

 Go to latest Published: Apr 26, 2022 License: MIT Imports: 53 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 NewConnectionCenter 

func NewConnectionCenter(p NewConnectionCenterParams) (connection.ConnectionCenter, error)

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 NewDevicedDataLauncher added in v1.1.24 

func NewDevicedDataLauncher(p NewDevicedDataLauncherParams) (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 NewIdentityd2Storage 

func NewIdentityd2Storage(p NewIdentityd2StorageParams) (storage.Storage, 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 NewMetathingsIdentitydServiceOption 

func NewMetathingsIdentitydServiceOption(opt *Identityd2Option) *service.MetathingsIdentitydServiceOption

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

func GetDeviceCloudOptions() (
	*DeviceCloudOption,
	cmd_contrib.ServiceOptioner,
	cmd_contrib.ListenOptioner,
	cmd_contrib.LoggerOptioner,
	cmd_contrib.ServiceEndpointsOptioner,
	cmd_contrib.CredentialOptioner,
	cmd_contrib.TransportCredentialOptioner,
	cmd_contrib.OpentracingOptioner,
)

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{}
	DataLauncher map[string]interface{}
}

func GetDevicedOptions 

func GetDevicedOptions() (
	*DevicedOption,
	cmd_contrib.ServiceOptioner,
	cmd_contrib.ListenOptioner,
	cmd_contrib.TransportCredentialOptioner,
	cmd_contrib.StorageOptioner,
	cmd_contrib.LoggerOptioner,
	cmd_contrib.ServiceEndpointsOptioner,
	cmd_contrib.CredentialOptioner,
	cmd_contrib.OpentracingOptioner,
)

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 GetEvaluatordOptions added in v1.1.24 

func GetEvaluatordOptions() (
	*EvaluatordOption,
	cmd_contrib.ServiceOptioner,
	cmd_contrib.ListenOptioner,
	cmd_contrib.TransportCredentialOptioner,
	cmd_contrib.StorageOptioner,
	cmd_contrib.LoggerOptioner,
	cmd_contrib.ServiceEndpointsOptioner,
	cmd_contrib.CredentialOptioner,
	cmd_contrib.OpentracingOptioner,
)

func NewEvaluatordOption added in v1.1.24 

func NewEvaluatordOption() *EvaluatordOption

type Identityd2Option 

type Identityd2Option struct {
	// expose detail for viper to unmarshal config file.
	cmd_contrib.ServiceBaseOption `mapstructure:",squash"`
	Init                          int
}

func GetIdentityd2Options 

func GetIdentityd2Options() (
	*Identityd2Option,
	cmd_contrib.ServiceOptioner,
	cmd_contrib.ListenOptioner,
	cmd_contrib.TransportCredentialOptioner,
	cmd_contrib.StorageOptioner,
	cmd_contrib.LoggerOptioner,
	cmd_contrib.ServiceEndpointsOptioner,
	cmd_contrib.WebhookServiceOptioner,
	cmd_contrib.OpentracingOptioner,
)

func NewIdentityd2Option 

func NewIdentityd2Option() *Identityd2Option

type MosquittoPluginOption added in v1.0.0 

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

func GetMosquittoPluginOptions added in v1.0.0 

func GetMosquittoPluginOptions() (
	*MosquittoPluginOption,
	cmd_contrib.ServiceOptioner,
	cmd_contrib.ListenOptioner,
	cmd_contrib.LoggerOptioner,
	cmd_contrib.ServiceEndpointsOptioner,
	cmd_contrib.OpentracingOptioner,
)

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 NewDevicedDataLauncherParams added in v1.1.24 

type NewDevicedDataLauncherParams 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 GetPolicydOptions 

func GetPolicydOptions() (
	*PolicydOption,
	cmd_contrib.ServiceOptioner,
	cmd_contrib.ListenOptioner,
	cmd_contrib.TransportCredentialOptioner,
	cmd_contrib.StorageOptioner,
	cmd_contrib.LoggerOptioner,
	cmd_contrib.OpentracingOptioner,
)

func NewPolicydOption 

func NewPolicydOption() *PolicydOption

type TagdOption 

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

func GetTagdOptions 

func GetTagdOptions() (
	*TagdOption,
	cmd_contrib.ServiceOptioner,
	cmd_contrib.ListenOptioner,
	cmd_contrib.TransportCredentialOptioner,
	cmd_contrib.LoggerOptioner,
	cmd_contrib.ServiceEndpointsOptioner,
	cmd_contrib.CredentialOptioner,
	cmd_contrib.OpentracingOptioner,
)

func NewTagdOption 

func NewTagdOption() *TagdOption

Source Files

View all Source files

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.