cloud

Documentation

Index

• func CurrentRouter() string
• func RoutersCount() int
• func SetNextRouter()
• type Channel
  • func NewChannel(iDataStorage common_interfaces.IDataStorage, channelId string, password string, ...) *Channel
  • func (c *Channel) AddItems(items []string) error
  • func (c *Channel) GazerReg()
  • func (c *Channel) GazerWrite(host string, channelId string, psw string, items []common_interfaces.Item, ...) error
  • func (c *Channel) GetRemovedValues() ([]common_interfaces.Item, error)
  • func (c *Channel) GetValues() ([]common_interfaces.Item, error)
  • func (c *Channel) RemoveAllItems() error
  • func (c *Channel) RemoveItems(items []string) error
  • func (c *Channel) RenameItems(oldPrefix string, newPrefix string)
  • func (c *Channel) Start()
  • func (c *Channel) Stat() *utilities.Statistics
  • func (c *Channel) Stop()
  • func (c *Channel) Write(items []common_interfaces.Item, removed bool) error
• type ChannelFullInfo
• type ChannelInfo
• type Cloud
  • func NewCloud(iDataStorage common_interfaces.IDataStorage) *Cloud
  • func (c *Cloud) AddChannel(channelId string, password string, name string) error
  • func (c *Cloud) AddItems(channels []string, items []string) error
  • func (c *Cloud) ChannelsFullInfo() []ChannelFullInfo
  • func (c *Cloud) EditChannel(channelId string, name string) error
  • func (c *Cloud) GetChannelValues(channelId string) ([]common_interfaces.Item, error)
  • func (c *Cloud) GetChannels() ([]ChannelInfo, error)
  • func (c *Cloud) GetChannelsNamesWithItem(name string) []string
  • func (c *Cloud) GetChannelsWithItem(name string) []string
  • func (c *Cloud) ReceivedBytes() int
  • func (c *Cloud) RemoveAllItems(channelsId string) error
  • func (c *Cloud) RemoveChannel(channelId string) error
  • func (c *Cloud) RemoveItems(channels []string, items []string) error
  • func (c *Cloud) RenameItems(oldPrefix string, newPrefix string)
  • func (c *Cloud) SentBytes() int
  • func (c *Cloud) Start()
  • func (c *Cloud) Stop()
• type Item
• type Routers

Functions

func CurrentRouter

func CurrentRouter() string

func RoutersCount

func RoutersCount() int

func SetNextRouter

func SetNextRouter()

Types

type Channel

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

func NewChannel

func NewChannel(iDataStorage common_interfaces.IDataStorage, channelId string, password string, name string) *Channel

func (*Channel) AddItems

func (c *Channel) AddItems(items []string) error

func (*Channel) GazerReg

func (c *Channel) GazerReg()

func (*Channel) GazerWrite

func (c *Channel) GazerWrite(host string, channelId string, psw string, items []common_interfaces.Item, removed bool, fullData bool) error

func (*Channel) GetRemovedValues

func (c *Channel) GetRemovedValues() ([]common_interfaces.Item, error)

func (*Channel) GetValues

func (c *Channel) GetValues() ([]common_interfaces.Item, error)

func (*Channel) RemoveAllItems

func (c *Channel) RemoveAllItems() error

func (*Channel) RemoveItems

func (c *Channel) RemoveItems(items []string) error

func (*Channel) RenameItems

func (c *Channel) RenameItems(oldPrefix string, newPrefix string)

func (*Channel) Start

func (c *Channel) Start()

func (*Channel) Stat

func (c *Channel) Stat() *utilities.Statistics

func (*Channel) Stop

func (c *Channel) Stop()

func (*Channel) Write

func (c *Channel) Write(items []common_interfaces.Item, removed bool) error

type ChannelFullInfo

type ChannelFullInfo struct {
	Id       string   `json:"id"`
	Password string   `json:"password"`
	Name     string   `json:"name"`
	Items    []string `json:"items"`
}

type ChannelInfo

type ChannelInfo struct {
	Id   string
	Name string
}

type Cloud

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

func NewCloud

func NewCloud(iDataStorage common_interfaces.IDataStorage) *Cloud

func (*Cloud) AddChannel

func (c *Cloud) AddChannel(channelId string, password string, name string) error

func (*Cloud) AddItems

func (c *Cloud) AddItems(channels []string, items []string) error

func (*Cloud) ChannelsFullInfo

func (c *Cloud) ChannelsFullInfo() []ChannelFullInfo

func (*Cloud) EditChannel

func (c *Cloud) EditChannel(channelId string, name string) error

func (*Cloud) GetChannelValues

func (c *Cloud) GetChannelValues(channelId string) ([]common_interfaces.Item, error)

func (*Cloud) GetChannels

func (c *Cloud) GetChannels() ([]ChannelInfo, error)

func (*Cloud) GetChannelsNamesWithItem

func (c *Cloud) GetChannelsNamesWithItem(name string) []string

func (*Cloud) GetChannelsWithItem

func (c *Cloud) GetChannelsWithItem(name string) []string

func (*Cloud) ReceivedBytes

func (c *Cloud) ReceivedBytes() int

func (*Cloud) RemoveAllItems

func (c *Cloud) RemoveAllItems(channelsId string) error

func (*Cloud) RemoveChannel

func (c *Cloud) RemoveChannel(channelId string) error

func (*Cloud) RemoveItems

func (c *Cloud) RemoveItems(channels []string, items []string) error

func (*Cloud) RenameItems

func (c *Cloud) RenameItems(oldPrefix string, newPrefix string)

func (*Cloud) SentBytes

func (c *Cloud) SentBytes() int

func (*Cloud) Start

func (c *Cloud) Start()

func (*Cloud) Stop

func (c *Cloud) Stop()

type Item

type Item struct {
	Name  string
	Value string
}

type Routers

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