metathings_deviced_connection

Documentation

Index

• Variables
• func ErrUnexpectedResponse(res []byte) error
• func ToBridgeFactory(y *BridgeFactory) func(string, interface{}) error
• func ToStorage(y *Storage) func(string, interface{}) error
• type Bridge
• type BridgeFactory
  • func NewBridgeFactory(name string, args ...interface{}) (BridgeFactory, error)
• type Channel
• type ConnectResponseInterceptor
• type ConnectResponseInterceptorChain
  • func NewConnectResponseInterceptorChain(args ...interface{}) ConnectResponseInterceptorChain
• type ConnectResponseMatcher
  • func NewConnectResponseUnaryCallMatcher(kind pb.ConnectMessageKind, component, name, method string) ConnectResponseMatcher
• type Connection
  • func NewConnection(cleanup_cb func()) Connection
• type ConnectionCenter
  • func NewConnectionCenter(args ...interface{}) (ConnectionCenter, error)
• type Side
• type Storage
  • func NewStorage(name string, args ...interface{}) (Storage, error)
• type StorageFactory
• type StreamConnection

Variables

var (
	ErrInvalidArgument = errors.New("invalid argument")
	ErrChannelClosed   = errors.New("channel closed")
	// ErrUnexpectedResponse       = errors.New("unexpected response")
	ErrBridgeClosed             = errors.New("bridge closed")
	ErrReceiveTimeout           = errors.New("receive timeout")
	ErrDuplicatedDeviceInstance = errors.New("duplicated device instance")
	ErrDeviceOffline            = errors.New("device offline")
)

var (
	ErrUnknownBridgeDriver = errors.New("unknown bridge driver")
)

var (
	ErrUnknownStorageDriver = errors.New("unknown storage driver")
)

var (
	InterceptorStop = errors.New("interceptor stop")
)

Functions

func ErrUnexpectedResponse

func ErrUnexpectedResponse(res []byte) error

func ToBridgeFactory

func ToBridgeFactory(y *BridgeFactory) func(string, interface{}) error

func ToStorage

func ToStorage(y *Storage) func(string, interface{}) error

Types

type Bridge

type Bridge interface {
	Id() string
	North() Channel
	South() Channel
	Close() error
}

type BridgeFactory

type BridgeFactory interface {
	BuildBridge(device_id string, sess int64) (Bridge, error)
	GetBridge(br_id string) (Bridge, error)
}

func NewBridgeFactory

func NewBridgeFactory(name string, args ...interface{}) (BridgeFactory, error)

type Channel

type Channel interface {
	Send([]byte) error
	Recv() ([]byte, error)
	AsyncSend() chan<- []byte
	AsyncRecv() <-chan []byte
	Close() error
}

type ConnectResponseInterceptor

type ConnectResponseInterceptor func(*pb.ConnectResponse) error

type ConnectResponseInterceptorChain

type ConnectResponseInterceptorChain func(*pb.ConnectResponse) error

func NewConnectResponseInterceptorChain

func NewConnectResponseInterceptorChain(args ...interface{}) ConnectResponseInterceptorChain

type ConnectResponseMatcher

type ConnectResponseMatcher func(*pb.ConnectResponse) bool

func NewConnectResponseUnaryCallMatcher

func NewConnectResponseUnaryCallMatcher(kind pb.ConnectMessageKind, component, name, method string) ConnectResponseMatcher

type Connection

type Connection interface {
	Err(err ...error) error
	Wait() chan bool
	Done()
	Cleanup()
}

func NewConnection

func NewConnection(cleanup_cb func()) Connection

type ConnectionCenter

type ConnectionCenter interface {
	BuildConnection(context.Context, *storage.Device, pb.DevicedService_ConnectServer) (Connection, error)
	UnaryCall(context.Context, *storage.Device, *pb.OpUnaryCallValue) (*pb.UnaryCallValue, error)
	StreamCall(context.Context, *storage.Device, *pb.OpStreamCallConfig, pb.DevicedService_StreamCallServer) error
	SyncFirmware(context.Context, *storage.Device) error
}

func NewConnectionCenter

func NewConnectionCenter(args ...interface{}) (ConnectionCenter, error)

type Side

type Side string

const (
	NORTH_SIDE Side = "north"
	SOUTH_SIDE Side = "south"
)

type Storage

type Storage interface {
	AddBridgeToDevice(dev_id string, sess int32, br_id string) error
	RemoveBridgeFromDevice(dev_id string, sess int32, br_id string) error
	ListBridgesFromDevice(dev_id string, sess int32) ([]string, error)
}

func NewStorage

func NewStorage(name string, args ...interface{}) (Storage, error)

type StorageFactory

type StorageFactory func(...interface{}) (Storage, error)

type StreamConnection

type StreamConnection interface {
	Connection
}