protocol

Documentation

Index

• func CreateKeyValuePair(key string, value []byte) ([]byte, error)
• func DeleteKeyValuePair(key string) ([]byte, error)
• func UpdateLeaderHTTP(leaderAddr string) ([]byte, error)
• type CommandPipeline
• type CommandPipelineReceiver
  • func Pipeline() CommandPipelineReceiver

Functions

func CreateKeyValuePair

func CreateKeyValuePair(key string, value []byte) ([]byte, error)

CreateKeyValuePair creates the byte stream for adding key value pairs.

func DeleteKeyValuePair

func DeleteKeyValuePair(key string) ([]byte, error)

DeleteKeyValuePair creates the byte stream for removing key/value pairs.

func UpdateLeaderHTTP

func UpdateLeaderHTTP(leaderAddr string) ([]byte, error)

UpdateLeaderHTTP creates the byte stream to update the leader http ip and port.

Types

type CommandPipeline

type CommandPipeline chan interface{}

CommandPipeline defines a channel type for sending and receiving commands

type CommandPipelineReceiver

type CommandPipelineReceiver <-chan interface{}

CommandPipelineReceiver accepts commands that were put into the Pipeline

func Pipeline

func Pipeline() CommandPipelineReceiver

Pipeline returns