metathings_component

Mar 25, 2021

Changes in this version

+ var ErrRequireSodaModuleAuthorizerPassword = errors.New("require soda module authorizer password")

+ var ErrRequireSodaModuleAuthorizerSecret = errors.New("require soda module authorizer secret")

+ var ErrRequireSodaModuleAuthorizerUsername = errors.New("require soda module authorizer username")

+ func WrapHttpAuthContext(r *http.Request, ctx *SodaModuleAuthContext) error

type SodaModuleAuthorizer

+ func NewSodaModuleBasicAuthorizer(m *Module) (SodaModuleAuthorizer, error)

+ Sign func(*SodaModuleAuthContext) (*SodaModuleAuthContext, error)

+ Verify func(*SodaModuleAuthContext) error

+ type SodaModuleBasicAuthorizer struct

+ func (a *SodaModuleBasicAuthorizer) Sign(ctx *SodaModuleAuthContext) (*SodaModuleAuthContext, error)

+ func (a *SodaModuleBasicAuthorizer) Verify(ctx *SodaModuleAuthContext) error

type SodaModuleDummyAuthorizer

+ func (*SodaModuleDummyAuthorizer) Sign(*SodaModuleAuthContext) (*SodaModuleAuthContext, error)

+ func (*SodaModuleDummyAuthorizer) Verify(*SodaModuleAuthContext) error

type SodaModuleSecretAuthorizer

+ func (a *SodaModuleSecretAuthorizer) Sign(ctx *SodaModuleAuthContext) (*SodaModuleAuthContext, error)

+ func (a *SodaModuleSecretAuthorizer) Verify(ctx *SodaModuleAuthContext) error

Jan 23, 2021

Changes in this version

+ const METATHINGS_SODA_MODULE_CLIENT_USERAGENT

+ var ErrDownstreamNotFound = errors.New("downstream not found")

+ var ErrRequireSodaModuleAuthorizeSecret = errors.New("require soda module authorizer secret")

+ var ErrUnauthorized = errors.New("unauthorized")

+ var ErrUnexpectedTokenFormat = errors.New("unexpected token format")

+ var ErrUnknownSodaModuleAuthorizerDriver = errors.New("unknown soda module authorizer driver")

+ var ErrUnknownSodaModuleBackendDriver = errors.New("unknown soda module backend driver")

+ var ErrUnknownSodaModuleWrapperDriver = errors.New("unknown soda module wrapper driver")

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

type Kernel

+ func (k *Kernel) ListObjects(name string, opt *ListObjectsOption) ([]*deviced_pb.Object, error)

+ func (k *Kernel) PushFrameToFlowOnce(name string, data interface{}, opt *PushFrameToFlowOnceOption) error

+ type KernelInterface interface

+ Context func() context.Context

+ GetObject func(name string) (*deviced_pb.Object, error)

+ GetObjectContent func(name string) ([]byte, error)

+ Heartbeat func() error

+ PushFrameToFlowOnce func(name string, data interface{}, opt *PushFrameToFlowOnceOption) error

+ PutObject func(name string, content io.Reader) error

+ PutObjectStreaming func(name string, content io.ReadSeeker, opt *PutObjectStreamingOption) error

+ PutObjectStreamingWithCancel func(name string, content io.ReadSeeker, opt *PutObjectStreamingOption) (context.CancelFunc, chan error, error)

+ PutObjects func(objects map[string]io.Reader) error

+ RemoveObjct func(name string) error

+ RemoveObjets func(names []string) error

+ RenameObject func(src, dst string) error

+ Show func() (*deviced_pb.Module, error)

+ ShowFirmwareDescriptor func() (*deviced_pb.FirmwareDescriptor, error)

+ type ListObjectsOption struct

+ Depth int32

+ Recursive bool

type Module

+ func (m *Module) IsRunning() bool

type ModuleServer

+ func NewSodaModuleServer(m *Module) (ModuleServer, error)

type NewModuleOption

+ func SetArgs(vs []string) NewModuleOption

+ func SetTarget(v interface{}) NewModuleOption

+ type PushFrameToFlowOnceOption struct

+ Id *string

+ Ts *time.Time

+ type SodaModuleAuthContext struct

+ func ParseHttpAuthContext(name string, r *http.Request) (*SodaModuleAuthContext, error)

+ type SodaModuleAuthorizer interface

+ Authorize func(*SodaModuleAuthContext) error

+ func NewSodaModuleAuthorizer(name string, m *Module) (SodaModuleAuthorizer, error)

+ func NewSodaModuleDummyAuthorizer(m *Module) (SodaModuleAuthorizer, error)

+ func NewSodaModuleSecretAuthorizer(m *Module) (SodaModuleAuthorizer, error)

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

+ type SodaModuleBackend interface

+ Done func() <-chan struct{}

+ Health func() error

+ Start func() error

+ Stop func() error

+ func NewSodaModuleBackend(name string, mdl *Module) (SodaModuleBackend, error)

+ func NewSodaModuleHttpBackend(m *Module) (SodaModuleBackend, error)

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

+ type SodaModuleDummyAuthorizer struct

+ func (a *SodaModuleDummyAuthorizer) Authorize(ctx *SodaModuleAuthContext) error

+ type SodaModuleHttpBackend struct

+ func (b *SodaModuleHttpBackend) Done() <-chan struct{}

+ func (b *SodaModuleHttpBackend) Health() error

+ func (b *SodaModuleHttpBackend) Start() error

+ func (b *SodaModuleHttpBackend) Stop() error

+ type SodaModuleHttpWrapper struct

+ func (w *SodaModuleHttpWrapper) StreamCall(pb.ModuleService_StreamCallServer) error

+ func (w *SodaModuleHttpWrapper) UnaryCall(ctx context.Context, req *pb.UnaryCallRequest) (*pb.UnaryCallResponse, error)

+ type SodaModuleHttpWrapperFactory struct

+ func (f *SodaModuleHttpWrapperFactory) NewModuleWrapper(m *Module) (SodaModuleWrapper, error)

+ type SodaModuleSecretAuthorizer struct

+ func (a *SodaModuleSecretAuthorizer) Authorize(ctx *SodaModuleAuthContext) error

+ type SodaModuleServer struct

+ func (s *SodaModuleServer) Serve() error

+ func (s *SodaModuleServer) Start() error

+ func (s *SodaModuleServer) Stop()

+ func (s *SodaModuleServer) Wait()

+ type SodaModuleWrapper interface

+ func NewSodaModuleWrapper(m *Module) (SodaModuleWrapper, error)

+ type SodaModuleWrapperFactory interface

+ NewModuleWrapper func(*Module) (SodaModuleWrapper, error)

Jul 24, 2020

Changes in this version

+ func NewDefaultModuleOption() objx.Map

type Kernel

+ func (k *Kernel) ShowFirmwareDescriptor() (*deviced_pb.FirmwareDescriptor, error)

+ type NewModuleOption func(objx.Map)

+ func SetVersion(v string) NewModuleOption

Dec 30, 2019

Changes in this version

type Kernel

+ func (k *Kernel) PutObjectStreaming(name string, content io.ReadSeeker, opt *PutObjectStreamingOption) error

+ func (k *Kernel) PutObjectStreamingWithCancel(name string, content io.ReadSeeker, opt *PutObjectStreamingOption) (cancel context.CancelFunc, errs chan error, err error)

type Module

+ func (m *Module) PutObjectStreaming(name string, content io.ReadSeeker, opt *PutObjectStreamingOption) error

+ func (m *Module) PutObjectStreamingWithCancel(name string, content io.ReadSeeker, opt *PutObjectStreamingOption) (context.CancelFunc, chan error, error)

+ type PutObjectStreamingOption struct

+ Length int64

+ Sha1 string

+ func NewPutObjectStreamingOptionFromPath(path string) (*PutObjectStreamingOption, error)

Nov 25, 2019

Changes in this version

type ModuleOption

+ ServiceEndpoints map[string]ServiceEndpoint

+ type ServiceEndpoint struct

+ Address string

+ type TransportCredential struct

+ CertFile string

+ Insecure bool

+ KeyFile string

+ PlainText bool

Oct 23, 2019

Changes in this version

type ModuleOption

+ TransportCredential struct{ ... }

type NewKernelOption

+ TransportCredential struct{ ... }

Sep 27, 2019

Changes in this version

+ type FrameStream struct

+ func (fs *FrameStream) Close() error

+ func (fs *FrameStream) Push(dat interface{}) error

+ func (fs *FrameStream) PushFrame(frm *deviced_pb.OpFrame) error

type Kernel

+ func (k *Kernel) NewFrameStream(flow string) (*FrameStream, error)

Jul 30, 2019

Changes in this version

+ var ErrStartTimeout = errors.New("start timeout")

+ var ErrStreamCallConfig = errors.New("stream call config error")

+ var ErrStreamCallConfigAckTimeout = errors.New("stream call config ack timeout")

+ var ErrSubscribedSession = errors.New("subscribed session")

+ var ErrUnaryCallTimeout = errors.New("unary call timeout")

+ var ErrUnexceptedResponse = errors.New("unexpected response")

+ var ErrUnsubscribedSession = errors.New("unsubscribed session")

+ var MQTT_DOWNSTREAM = "downstream"

+ var MQTT_UPSTREAM = "upstream"

+ type Endpoint struct

+ func ParseEndpoint(ep string) (*Endpoint, error)

+ func (ep *Endpoint) GetTransportProtocol(defaults ...string) string

+ func (ep *Endpoint) IsMetathingsProtocol() bool

type GrpcModuleProxy

+ func (self *GrpcModuleProxy) Close() error

type ModuleProxy

+ Close func() error

+ type MqttModuleProxy struct

+ func (p *MqttModuleProxy) Close() error

+ func (p *MqttModuleProxy) StreamCall(ctx context.Context, method string, upstm ModuleProxyStream) error

+ func (p *MqttModuleProxy) UnaryCall(ctx context.Context, method string, value *any.Any) (*any.Any, error)

+ type MqttModuleProxyFactory struct

+ func (f *MqttModuleProxyFactory) NewModuleProxy(args ...interface{}) (ModuleProxy, error)

+ type MqttModuleProxyOption struct

+ Config struct{ ... }

+ MQTT struct{ ... }

+ Module struct{ ... }

+ Session struct{ ... }

Jun 12, 2019

Changes in this version

+ const METATHINGS_COMPONENT_PREFIX

+ var ErrBadScheme = errors.New("bad scheme")

+ var ErrBadServiceEndpoint = errors.New("bad service endpoint")

+ var ErrDefaultAddressRequired = errors.New("default address required")

+ var ErrDeviceAddressRequired = errors.New("device address required")

+ var ErrHandleUnimplemented = errors.New("handle unimplemented")

+ var ErrInvalidArguments = errors.New("invalid arguments")

+ var ErrUnknownModuleProxyDriver = errors.New("unknown module proxy driver")

+ var ErrUnknownModuleServerAdapter = errors.New("unknown module server adapter")

+ func ToModule(v **Module) func(string, interface{}) error

+ type GrpcModuleProxy struct

+ func (self *GrpcModuleProxy) StreamCall(ctx context.Context, method string, upstm ModuleProxyStream) error

+ func (self *GrpcModuleProxy) UnaryCall(ctx context.Context, method string, value *any.Any) (*any.Any, error)

+ type GrpcModuleProxyFactory struct

+ func (self *GrpcModuleProxyFactory) NewModuleProxy(args ...interface{}) (ModuleProxy, error)

+ type GrpcModuleServer struct

+ func (s *GrpcModuleServer) Serve() error

+ func (s *GrpcModuleServer) Stop()

+ type GrpcModuleServiceClientFactory interface

+ NewModuleServiceClient func(opts ...grpc.DialOption) (pb.ModuleServiceClient, client_helper.CloseFn, error)

+ func NewGrpcModuleServiceClientFactory(addr string) GrpcModuleServiceClientFactory

+ type GrpcModuleServiceClientFactoryImpl struct

+ Address string

+ func (self *GrpcModuleServiceClientFactoryImpl) NewModuleServiceClient(opts ...grpc.DialOption) (pb.ModuleServiceClient, client_helper.CloseFn, error)

+ type GrpcModuleWrapper struct

+ func NewGrpcModuleWrapper(target interface{}, logger log.FieldLogger) *GrpcModuleWrapper

+ func (self *GrpcModuleWrapper) StreamCall(upstm pb.ModuleService_StreamCallServer) error

+ func (self *GrpcModuleWrapper) UnaryCall(ctx context.Context, req *pb.UnaryCallRequest) (*pb.UnaryCallResponse, error)

+ type Kernel struct

+ func NewKernel(opt *NewKernelOption) (*Kernel, error)

+ func (k *Kernel) Config() *KernelConfig

+ func (k *Kernel) Context() context.Context

+ func (k *Kernel) GetObject(name string) (*deviced_pb.Object, error)

+ func (k *Kernel) GetObjectContent(name string) ([]byte, error)

+ func (k *Kernel) Heartbeat() error

+ func (k *Kernel) PutObject(name string, content io.Reader) error

+ func (k *Kernel) PutObjects(objects map[string]io.Reader) error

+ func (k *Kernel) RemoveObject(name string) error

+ func (k *Kernel) RemoveObjects(names []string) error

+ func (k *Kernel) RenameObject(src, dst string) error

+ func (k *Kernel) Show() (*deviced_pb.Module, error)

+ type KernelConfig struct

+ func NewKernelConfigFromText(text string) (*KernelConfig, error)

+ func (kc *KernelConfig) Raw() *viper.Viper

+ func (kc *KernelConfig) Sub(key string) *KernelConfig

+ type Module struct

+ func NewModule(name string, target interface{}) (*Module, error)

+ func (m *Module) GetObject(name string) (*deviced_pb.Object, error)

+ func (m *Module) GetObjectContent(name string) ([]byte, error)

+ func (m *Module) HeartbeatLoop()

+ func (m *Module) Init() error

+ func (m *Module) Kernel() *Kernel

+ func (m *Module) Launch() error

+ func (m *Module) Logger() log.FieldLogger

+ func (m *Module) Name() string

+ func (m *Module) PutObject(name string, content io.Reader) error

+ func (m *Module) PutObjects(objects map[string]io.Reader) error

+ func (m *Module) RemoveObject(name string) error

+ func (m *Module) RemoveObjects(names []string) error

+ func (m *Module) RenameObject(src, dst string) error

+ func (m *Module) Serve() error

+ func (m *Module) Stop()

+ func (m *Module) Target() interface{}

+ func (m *Module) WithNamespace(name string) string

+ type ModuleOption struct

+ Addresses []string

+ Config string

+ CredentialId string

+ CredentialSecret string

+ type ModuleProxy interface

+ StreamCall func(ctx context.Context, method string, stm ModuleProxyStream) error

+ UnaryCall func(ctx context.Context, method string, req *any.Any) (*any.Any, error)

+ func NewModuleProxy(name string, args ...interface{}) (ModuleProxy, error)

+ type ModuleProxyFactory interface

+ NewModuleProxy func(args ...interface{}) (ModuleProxy, error)

+ type ModuleProxyStream interface

+ Recv func() (*any.Any, error)

+ Send func(*any.Any) error

+ func NewModuleProxyStream(stm deviced_pb.DevicedService_ConnectClient, session int64) ModuleProxyStream

+ type ModuleServer interface

+ Serve func() error

+ Stop func()

+ func NewGrpcModuleServer(m *Module) (ModuleServer, error)

+ func NewModuleServer(name string, mdl *Module) (ModuleServer, error)

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

+ type ModuleServiceInitializer interface

+ InitModuleService func(*Module) error

+ type ModuleServiceLookuper interface

+ LookupStreamCall func()

+ LookupUnaryCall func()

+ type NewKernelOption struct

+ ConfigText string

+ Credential struct{ ... }

+ ServiceEndpoints map[string]string