shoset

Documentation

Overview

Package shoset :

Package shoset :

Package shoset :

Package shoset :

Package shoset :

Package shoset :

Package shoset :

Index

• func GetConfiguration(c *net.ShosetConn) (msg.Message, error)
• func GetConfigurationDatabase(c *net.ShosetConn) (msg.Message, error)
• func GetHeartbeat(c *net.ShosetConn) (msg.Message, error)
• func GetLogicalConfiguration(c *net.ShosetConn) (msg.Message, error)
• func GetSecret(c *net.ShosetConn) (msg.Message, error)
• func HandleCommand(c *net.ShosetConn, message msg.Message) (err error)
• func HandleConfigJoin(c *net.ShosetConn, message msg.Message) error
• func HandleConfiguration(c *net.ShosetConn, message msg.Message) (err error)
• func HandleConfigurationDatabase(c *net.ShosetConn, message msg.Message) (err error)
• func HandleEvent(c *net.ShosetConn, message msg.Message) (err error)
• func HandleHeartbeat(c *net.ShosetConn, message msg.Message) (err error)
• func HandleLogicalConfiguration(c *net.ShosetConn, message msg.Message) (err error)
• func HandleSecret(c *net.ShosetConn, message msg.Message) (err error)
• func SendClusterPivotConfiguration(shoset *net.Shoset) (err error)
• func SendHeartbeat(shoset *net.Shoset) (err error)
• func SendLogicalConfiguration(shoset *net.Shoset) (err error)
• func SendSecret(shoset *net.Shoset) (err error)
• func WaitConfiguration(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message
• func WaitConfigurationDatabase(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message
• func WaitHeartbeat(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message
• func WaitLogicalConfiguration(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message
• func WaitSecret(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message

Functions

func GetConfiguration

func GetConfiguration(c *net.ShosetConn) (msg.Message, error)

func GetConfigurationDatabase

func GetConfigurationDatabase(c *net.ShosetConn) (msg.Message, error)

func GetHeartbeat

func GetHeartbeat(c *net.ShosetConn) (msg.Message, error)

GetHeartbeat :

func GetLogicalConfiguration

func GetLogicalConfiguration(c *net.ShosetConn) (msg.Message, error)

func GetSecret

func GetSecret(c *net.ShosetConn) (msg.Message, error)

func HandleCommand

func HandleCommand(c *net.ShosetConn, message msg.Message) (err error)

HandleCommand : Cluster handle command function.

func HandleConfigJoin

func HandleConfigJoin(c *net.ShosetConn, message msg.Message) error

HandleConfigJoin : Cluster handle config function.

func HandleConfiguration

func HandleConfiguration(c *net.ShosetConn, message msg.Message) (err error)

HandleConnectorConfig : Cluster handle connector config function.

func HandleConfigurationDatabase

func HandleConfigurationDatabase(c *net.ShosetConn, message msg.Message) (err error)

HandleSecret :

func HandleEvent

func HandleEvent(c *net.ShosetConn, message msg.Message) (err error)

HandleEvent : Cluster handle event function.

func HandleHeartbeat

func HandleHeartbeat(c *net.ShosetConn, message msg.Message) (err error)

HandleEvent : Cluster handle event function.

func HandleLogicalConfiguration

func HandleLogicalConfiguration(c *net.ShosetConn, message msg.Message) (err error)

HandleSecret :

func HandleSecret

func HandleSecret(c *net.ShosetConn, message msg.Message) (err error)

HandleSecret :

func SendClusterPivotConfiguration

func SendClusterPivotConfiguration(shoset *net.Shoset) (err error)

SendPivotConfiguration :

func SendHeartbeat

func SendHeartbeat(shoset *net.Shoset) (err error)

SendSecret :

func SendLogicalConfiguration

func SendLogicalConfiguration(shoset *net.Shoset) (err error)

SendSecret :

func SendSecret

func SendSecret(shoset *net.Shoset) (err error)

SendSecret :

func WaitConfiguration

func WaitConfiguration(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message

WaitConfig :

func WaitConfigurationDatabase

func WaitConfigurationDatabase(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message

WaitConfig :

func WaitHeartbeat

func WaitHeartbeat(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message

WaitHeartbeat :

func WaitLogicalConfiguration

func WaitLogicalConfiguration(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message

WaitConfig :

func WaitSecret

func WaitSecret(c *net.Shoset, replies *msg.Iterator, args map[string]string, timeout int) *msg.Message

WaitConfig :