metathings_deviced_connection

Documentation

Index

• Variables
• type Bridge
• type BridgeFactory
  • func NewBridgeFactory(name string, args ...interface{}) (BridgeFactory, error)
• type Channel
• type Connection
  • func NewConnection(cleanup_cb func()) Connection
• type ConnectionCenter
  • func NewConnectionCenter(brfty BridgeFactory, stor Storage, sess_stor session_storage.SessionStorage, ...) (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")
	ErrTimeout                  = errors.New("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")
)

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 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(*storage.Device, pb.DevicedService_ConnectServer) (Connection, error)
	UnaryCall(*storage.Device, *pb.OpUnaryCallValue) (*pb.UnaryCallValue, error)
	StreamCall(*storage.Device, *pb.OpStreamCallConfig, pb.DevicedService_StreamCallServer) error
}

func NewConnectionCenter

func NewConnectionCenter(brfty BridgeFactory, stor Storage, sess_stor session_storage.SessionStorage, logger log.FieldLogger) (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
}