metathings_component

type Endpoint struct {
	*url.URL
}

type FrameStream struct {
	// contains filtered or unexported fields
}

type GrpcModuleProxy struct {
	// contains filtered or unexported fields
}

type GrpcModuleProxyFactory struct{}

type GrpcModuleServer struct {
	// contains filtered or unexported fields
}

type GrpcModuleServiceClientFactory interface {
	NewModuleServiceClient(opts ...grpc.DialOption) (pb.ModuleServiceClient, client_helper.DoneFn, error)
}

type GrpcModuleServiceClientFactoryImpl struct {
	Address string
}

type GrpcModuleWrapper struct {
	// contains filtered or unexported fields
}

type HttpAuthContextParser func(*http.Request) (*SodaModuleAuthContext, error)

type Kernel struct {
	// contains filtered or unexported fields
}

type KernelConfig struct {
	*viper.Viper
}

type KernelInterface interface {
	Context() context.Context
	Show() (*deviced_pb.Module, error)
	ShowFirmwareDescriptor() (*deviced_pb.FirmwareDescriptor, error)
	PutObject(name string, content io.Reader) error
	PutObjectStreaming(name string, content io.ReadSeeker, opt *PutObjectStreamingOption) error
	PutObjectStreamingWithCancel(name string, content io.ReadSeeker, opt *PutObjectStreamingOption) (context.CancelFunc, chan error, error)
	PutObjects(objects map[string]io.Reader) error
	GetObject(name string) (*deviced_pb.Object, error)
	GetObjectContent(name string) ([]byte, error)
	RemoveObjct(name string) error
	RemoveObjets(names []string) error
	RenameObject(src, dst string) error
	PushFrameToFlowOnce(name string, data interface{}, opt *PushFrameToFlowOnceOption) error
	Heartbeat() error
}

type ListObjectsOption struct {
	Recursive bool
	Depth     int32
}

type Module struct {
	version_helper.Versioner
	// contains filtered or unexported fields
}

type ModuleOption struct {
	Config              string
	CredentialId        string
	CredentialSecret    string
	ServiceEndpoints    map[string]ServiceEndpoint
	TransportCredential TransportCredential
}

type ModuleProxy interface {
	UnaryCall(ctx context.Context, method string, req *any.Any) (*any.Any, error)
	StreamCall(ctx context.Context, method string, stm ModuleProxyStream) error
	Close() error
}

type ModuleProxyFactory interface {
	NewModuleProxy(args ...interface{}) (ModuleProxy, error)
}

type ModuleProxyStream interface {
	Send(*any.Any) error
	Recv() (*any.Any, error)
	grpc.ClientStream
}

type ModuleServer interface {
	Stop()
	Serve() error
}

type ModuleServerFactory func(*Module) (ModuleServer, error)

type ModuleServiceInitializer interface {
	InitModuleService(*Module) error
}

type ModuleServiceLookuper interface {
	LookupUnaryCall()
	LookupStreamCall()
}

type MqttModuleProxy struct {
	// contains filtered or unexported fields
}

type MqttModuleProxyFactory struct{}

type MqttModuleProxyOption struct {
	Module struct {
		Id string
	}
	Session struct {
		Id int64
	}
	Config struct {
		UnaryCallTimeout           time.Duration
		StreamCallConfigAckTimeout time.Duration
		MQTTConnectTimeout         time.Duration
		MQTTDisconnectTimeout      time.Duration
	}
	MQTT struct {
		Address  string
		Username string
		Password string
		ClientId string
		QoS      byte
	}
}

type NewKernelOption struct {
	Credential struct {
		Id     string
		Secret string
	}
	TransportCredential TransportCredential
	ServiceEndpoints    map[string]ServiceEndpoint
	ConfigText          string
}

type NewModuleOption func(objx.Map)

type PushFrameToFlowOnceOption struct {
	Id *string
	Ts *time.Time
}

type PutObjectStreamingOption struct {
	Sha1   string
	Length int64
}

type ServiceEndpoint struct {
	TransportCredential `mapstructure:",squash"`
	Address             string
}

type SodaModuleAuthContext struct {
	objx.Map
}

type SodaModuleAuthorizer interface {
	Sign(*SodaModuleAuthContext) (*SodaModuleAuthContext, error)
	Verify(*SodaModuleAuthContext) error
}

type SodaModuleAuthorizerFactory func(*Module) (SodaModuleAuthorizer, error)

type SodaModuleBackend interface {
	Start() error
	Stop() error
	Done() <-chan struct{}
	Health() error
}

type SodaModuleBackendFactory func(*Module) (SodaModuleBackend, error)

type SodaModuleBasicAuthorizer struct {
	// contains filtered or unexported fields
}

type SodaModuleDummyAuthorizer struct{}

type SodaModuleHttpBackend struct {
	// contains filtered or unexported fields
}

type SodaModuleHttpWrapper struct {
	// contains filtered or unexported fields
}

type SodaModuleHttpWrapperFactory struct{}

type SodaModuleSecretAuthorizer struct {
	// contains filtered or unexported fields
}

type SodaModuleServer struct {
	// contains filtered or unexported fields
}

type SodaModuleWrapper interface {
	pb.ModuleServiceServer
}

type SodaModuleWrapperFactory interface {
	NewModuleWrapper(*Module) (SodaModuleWrapper, error)
}

type TransportCredential struct {
	Insecure  bool
	PlainText bool   `mapstructure:"plain_text"`
	KeyFile   string `mapstructure:"key_file"`
	CertFile  string `mapstructure:"cert_file"`
}