cmd

package
v1.1.25-alpha Latest Latest
Warning

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

 Go to latest Published: Mar 19, 2020 License: MIT Imports: 50 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(opt *DevicedOption, sess_stor session_storage.SessionStorage, logger log.FieldLogger) (connection.ConnectionCenter, 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 NewEvaluatordStorage added in v1.1.24 

func NewEvaluatordStorage(p NewEvaluatordStorageParams) (storage.Storage, 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{}
	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"`
}

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

type NewEvaluatordStorageParams struct {
	fx.In

	Option cmd_contrib.StorageOptioner
	Logger log.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.