protocol

package
v0.0.0-...-e5949e2 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Nov 9, 2018 License: BSD-2-Clause Imports: 2 Imported by: 2

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

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

Jump to

Keyboard shortcuts

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