zookeeper

Documentation

Index

• type Client
  • func New(zooKeeperServerPoolAddresses []string) (*Client, error)
  • func (obj *Client) ClientRequestExist(guid string) (bool, error)
  • func (obj *Client) DeletePendingRequest(guid string) error
  • func (obj *Client) GetAllPendingClientRequestGuid() ([]string, error)
  • func (obj *Client) GetClientRequestInformation(guid string) (uint8, []byte, error)
  • func (obj *Client) GetCurrentLeaderPublicInternetAddress() (string, error)
  • func (obj *Client) GetProcessMembershipTable() (map[int]map[int]string, error)
  • func (obj *Client) Initialize() error
  • func (obj *Client) KeepConnectionAlive()
  • func (obj *Client) RegisterClientRequest(guid string, initialStatus uint8) error
  • func (obj *Client) RegisterClientRequestAsComplete(guid string, outputGuid string) error
  • func (obj *Client) RegisterNewWorkerProcess(processId int, processGroupId int, processPublicInternetAddress string) error
  • func (obj *Client) UpdateClientRequestStatusBackup(guid string, status uint8, data []byte) error
  • func (obj *Client) WaitForClientRequestCompletion(guid string) (string, error)
  • func (obj *Client) WaitUntilLeader(myOwnPublicInternetAddress string) error
  • func (obj *Client) WaitUntilProcessMembershipChanges() error
• type ElectionResponse

Types

type Client

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

func New

func New(zooKeeperServerPoolAddresses []string) (*Client, error)

func (*Client) ClientRequestExist

func (obj *Client) ClientRequestExist(guid string) (bool, error)

func (*Client) DeletePendingRequest

func (obj *Client) DeletePendingRequest(guid string) error

func (*Client) GetAllPendingClientRequestGuid

func (obj *Client) GetAllPendingClientRequestGuid() ([]string, error)

func (*Client) GetClientRequestInformation

func (obj *Client) GetClientRequestInformation(guid string) (uint8, []byte, error)

func (*Client) GetCurrentLeaderPublicInternetAddress

func (obj *Client) GetCurrentLeaderPublicInternetAddress() (string, error)

func (*Client) GetProcessMembershipTable

func (obj *Client) GetProcessMembershipTable() (map[int]map[int]string, error)

func (*Client) Initialize

func (obj *Client) Initialize() error

func (*Client) KeepConnectionAlive

func (obj *Client) KeepConnectionAlive()

func (*Client) RegisterClientRequest

func (obj *Client) RegisterClientRequest(guid string, initialStatus uint8) error

func (*Client) RegisterClientRequestAsComplete

func (obj *Client) RegisterClientRequestAsComplete(guid string, outputGuid string) error

func (*Client) RegisterNewWorkerProcess

func (obj *Client) RegisterNewWorkerProcess(processId int, processGroupId int, processPublicInternetAddress string) error

func (*Client) UpdateClientRequestStatusBackup

func (obj *Client) UpdateClientRequestStatusBackup(guid string, status uint8, data []byte) error

func (*Client) WaitForClientRequestCompletion

func (obj *Client) WaitForClientRequestCompletion(guid string) (string, error)

func (*Client) WaitUntilLeader

func (obj *Client) WaitUntilLeader(myOwnPublicInternetAddress string) error

func (*Client) WaitUntilProcessMembershipChanges

func (obj *Client) WaitUntilProcessMembershipChanges() error

type ElectionResponse

type ElectionResponse struct {
	IsLeader bool
	NodeID   string
}