action

package
v0.0.0-...-0ae59ff Latest Latest
Warning

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

Go to latest
Published: Feb 20, 2020 License: MIT Imports: 8 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func CopyShard

func CopyShard(srcAddr, dstAddr, shardID string) error

func CopyShardStatus

func CopyShardStatus(addr string) error

func DecodeTLV

func DecodeTLV(r io.Reader, expTyp byte, v interface{}) error

func Dial

func Dial(addr string) (net.Conn, error)

func KillCopyShard

func KillCopyShard(srcAddr, dstAddr, shardID string) error

func RemoveDataNode

func RemoveDataNode(addr string) error

func RemoveShard

func RemoveShard(addr, shardID string) error

func RequestAndWaitResp

func RequestAndWaitResp(addr string, reqTyp, respTyp byte, req interface{}, resp interface{}) error

func ShowDataNodes

func ShowDataNodes(addr string) error

func TruncateShards

func TruncateShards(delay string, addr string) error

Types

This section is empty.

Jump to

Keyboard shortcuts

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