public_channel

package

v1.0.6 Latest Latest Go to latest Published: Aug 16, 2021 License: MIT Imports: 14 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/gazercloud/gazernode

Links

Open Source Insights

Documentation ¶

Index ¶

func CurrentRouter() string
func RoutersCount() int
func SetNextRouter()
type Channel
- func NewChannel(iDataStorage common_interfaces.IDataStorage, channelId string, password string, ...) *Channel
type ChannelFullInfo
type ChannelInfo
type Cloud
- func NewCloud(iDataStorage common_interfaces.IDataStorage) *Cloud
type Item
type Routers

Constants ¶

This section is empty.

Variables ¶

This section is empty.

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, needToStart bool) *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) Status ¶

func (c *Channel) Status() string

func (*Channel) Stop ¶

func (c *Channel) Stop(saveAsBeginState bool)

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"`
	NeedToStartAfterLoad bool     `json:"need_to_start_after_load"`
}

type ChannelInfo ¶

type ChannelInfo struct {
	Id     string `json:"id"`
	Name   string `json:"name"`
	Status string `json:"status"`
}

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, needToStart bool) 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) StartChannels ¶

func (c *Cloud) StartChannels(ids []string) (err error)

func (*Cloud) Stop ¶

func (c *Cloud) Stop()

func (*Cloud) StopChannels ¶

func (c *Cloud) StopChannels(ids []string) (err error)

type Item ¶

type Item struct {
	Name  string
	Value string
}

type Routers ¶

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

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL