metathings_deviced_sdk

Documentation

Index

• Variables
• func SetBool(key string) func(bool) func(map[string]interface{})
• func SetInt(key string) func(int) func(map[string]interface{})
• func ToCaller(v *Caller) func(string, interface{}) error
• func ToProtobuf(x *Config) (*pb.OpConfig, error)
• func ToSimpleStorage(v *SimpleStorage) func(string, interface{}) error
• type Caller
  • func NewCaller(name string, args ...interface{}) (Caller, error)
  • func NewDevicedCaller(args ...interface{}) (Caller, error)
• type CallerFactory
• type Config
  • func FromConfig(x *pb.Config) (*Config, error)
  • func LookupConfig(cfgs []*pb.Config, alias string) (*Config, error)
  • func (c *Config) Get(selector string) *objx.Value
  • func (c *Config) Set(selector string, value interface{})
• type DevicedCaller
  • func (c *DevicedCaller) UnaryCall(ctx context.Context, device, module, method string, ...) (map[string]interface{}, error)
• type DevicedSimpleStorage
  • func (s *DevicedSimpleStorage) Get(ctx context.Context, obj *pb.Object) (*pb.Object, error)
  • func (s *DevicedSimpleStorage) GetContent(ctx context.Context, obj *pb.Object) ([]byte, error)
  • func (s *DevicedSimpleStorage) List(ctx context.Context, obj *pb.Object, opts ...SimpleStorageListOption) ([]*pb.Object, error)
  • func (s *DevicedSimpleStorage) Put(ctx context.Context, obj *pb.Object, rd io.Reader) error
  • func (s *DevicedSimpleStorage) Remove(ctx context.Context, obj *pb.Object) error
  • func (s *DevicedSimpleStorage) Rename(ctx context.Context, src, dst *pb.Object) error
• type MockCaller
  • func (m *MockCaller) UnaryCall(ctx context.Context, device, module, method string, ...) (map[string]interface{}, error)
• type MockSimpleStorage
  • func (m *MockSimpleStorage) Get(ctx context.Context, obj *pb.Object) (*pb.Object, error)
  • func (m *MockSimpleStorage) GetContent(ctx context.Context, obj *pb.Object) ([]byte, error)
  • func (m *MockSimpleStorage) List(ctx context.Context, obj *pb.Object, opts ...SimpleStorageListOption) ([]*pb.Object, error)
  • func (m *MockSimpleStorage) Put(ctx context.Context, obj *pb.Object, rd io.Reader) error
  • func (m *MockSimpleStorage) Remove(ctx context.Context, obj *pb.Object) error
  • func (m *MockSimpleStorage) Rename(ctx context.Context, src, dst *pb.Object) error
  • func (m *MockSimpleStorage) SetGetContentResult(buf []byte)
  • func (m *MockSimpleStorage) SetGetResult(obj *pb.Object)
  • func (m *MockSimpleStorage) SetListResult(objs []*pb.Object)
• type SimpleStorage
  • func NewDevicedSimpleStorage(args ...interface{}) (SimpleStorage, error)
  • func NewSimpleStorage(name string, args ...interface{}) (SimpleStorage, error)
• type SimpleStorageFactory
• type SimpleStorageListOption

Variables

var (
	ErrUnsupportedSimpleStorageFactory = errors.New("unsupported simple storage driver")
	ErrUnsupportedCallerFactory        = errors.New("unsupported caller driver")

	ErrMethodNotFound = errors.New("method not found")
	ErrModuleNotFound = errors.New("module not found")
	ErrConfigNotFound = errors.New("config not found")
)

var (
	SimpleStorageListOption_SetRecursive = SetBool("recursive")
	SimpleStorageListOption_SetDepth     = SetInt("depth")
)

Functions

func SetBool

func SetBool(key string) func(bool) func(map[string]interface{})

func SetInt

func SetInt(key string) func(int) func(map[string]interface{})

func ToCaller

func ToCaller(v *Caller) func(string, interface{}) error

func ToProtobuf

func ToProtobuf(x *Config) (*pb.OpConfig, error)

func ToSimpleStorage

func ToSimpleStorage(v *SimpleStorage) func(string, interface{}) error

Types

type Caller

type Caller interface {
	UnaryCall(ctx context.Context, device, module, method string, arguments map[string]interface{}) (map[string]interface{}, error)
}

func NewCaller

func NewCaller(name string, args ...interface{}) (Caller, error)

func NewDevicedCaller

func NewDevicedCaller(args ...interface{}) (Caller, error)

type CallerFactory

type CallerFactory func(...interface{}) (Caller, error)

type Config

type Config struct {
	*pb.Config
	// contains filtered or unexported fields
}

func FromConfig

func FromConfig(x *pb.Config) (*Config, error)

func LookupConfig

func LookupConfig(cfgs []*pb.Config, alias string) (*Config, error)

func (*Config) Get

func (c *Config) Get(selector string) *objx.Value

func (*Config) Set

func (c *Config) Set(selector string, value interface{})

type DevicedCaller

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

func (*DevicedCaller) UnaryCall

func (c *DevicedCaller) UnaryCall(ctx context.Context, device, module, method string, arguments map[string]interface{}) (map[string]interface{}, error)

type DevicedSimpleStorage

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

func (*DevicedSimpleStorage) Get

func (s *DevicedSimpleStorage) Get(ctx context.Context, obj *pb.Object) (*pb.Object, error)

func (*DevicedSimpleStorage) GetContent

func (s *DevicedSimpleStorage) GetContent(ctx context.Context, obj *pb.Object) ([]byte, error)

func (*DevicedSimpleStorage) List

func (s *DevicedSimpleStorage) List(ctx context.Context, obj *pb.Object, opts ...SimpleStorageListOption) ([]*pb.Object, error)

func (*DevicedSimpleStorage) Put

func (s *DevicedSimpleStorage) Put(ctx context.Context, obj *pb.Object, rd io.Reader) error

func (*DevicedSimpleStorage) Remove

func (s *DevicedSimpleStorage) Remove(ctx context.Context, obj *pb.Object) error

func (*DevicedSimpleStorage) Rename

func (s *DevicedSimpleStorage) Rename(ctx context.Context, src, dst *pb.Object) error

type MockCaller

type MockCaller struct {
	mock.Mock
	// contains filtered or unexported fields
}

func (*MockCaller) UnaryCall

func (m *MockCaller) UnaryCall(ctx context.Context, device, module, method string, arguments map[string]interface{}) (map[string]interface{}, error)

type MockSimpleStorage

type MockSimpleStorage struct {
	mock.Mock
	// contains filtered or unexported fields
}

func (*MockSimpleStorage) Get

func (m *MockSimpleStorage) Get(ctx context.Context, obj *pb.Object) (*pb.Object, error)

func (*MockSimpleStorage) GetContent

func (m *MockSimpleStorage) GetContent(ctx context.Context, obj *pb.Object) ([]byte, error)

func (*MockSimpleStorage) List

func (m *MockSimpleStorage) List(ctx context.Context, obj *pb.Object, opts ...SimpleStorageListOption) ([]*pb.Object, error)

func (*MockSimpleStorage) Put

func (m *MockSimpleStorage) Put(ctx context.Context, obj *pb.Object, rd io.Reader) error

func (*MockSimpleStorage) Remove

func (m *MockSimpleStorage) Remove(ctx context.Context, obj *pb.Object) error

func (*MockSimpleStorage) Rename

func (m *MockSimpleStorage) Rename(ctx context.Context, src, dst *pb.Object) error

func (*MockSimpleStorage) SetGetContentResult

func (m *MockSimpleStorage) SetGetContentResult(buf []byte)

func (*MockSimpleStorage) SetGetResult

func (m *MockSimpleStorage) SetGetResult(obj *pb.Object)

func (*MockSimpleStorage) SetListResult

func (m *MockSimpleStorage) SetListResult(objs []*pb.Object)

type SimpleStorage

type SimpleStorage interface {
	Put(context.Context, *pb.Object, io.Reader) error
	Remove(context.Context, *pb.Object) error
	Rename(ctx context.Context, src *pb.Object, dst *pb.Object) error
	Get(context.Context, *pb.Object) (*pb.Object, error)
	GetContent(context.Context, *pb.Object) ([]byte, error)
	List(context.Context, *pb.Object, ...SimpleStorageListOption) ([]*pb.Object, error)
}

func NewDevicedSimpleStorage

func NewDevicedSimpleStorage(args ...interface{}) (SimpleStorage, error)

func NewSimpleStorage

func NewSimpleStorage(name string, args ...interface{}) (SimpleStorage, error)

type SimpleStorageFactory

type SimpleStorageFactory func(...interface{}) (SimpleStorage, error)

type SimpleStorageListOption

type SimpleStorageListOption func(map[string]interface{})