chatmq

README

chatmq

message queue, just for chat.

Documentation

Index

• func Cluster(host, secret string, nodes []string) error
• func Decode(b []byte, e interface{}) error
• func DeleteNotice(key string)
• func Get(key string, e interface{}) bool
• func Overdue(duration time.Duration)
• func PingTimeout(duration time.Duration)
• func Put(key string, e interface{})
• func SendNotice(key string, e interface{})
• func SetLogLevel(level LogLevel)
• func SetNotice(key string, notice Notice)
• type LogLevel
• type Notice

Functions

func Cluster

func Cluster(host, secret string, nodes []string) error

Cluster cluster.

func Decode

func Decode(b []byte, e interface{}) error

Decode decode.

func DeleteNotice

func DeleteNotice(key string)

DeleteNotice delete notice.

func Get

func Get(key string, e interface{}) bool

Get get.

func Overdue

func Overdue(duration time.Duration)

Overdue set queue overdue duration.

func PingTimeout

func PingTimeout(duration time.Duration)

PingTimeout ping timeout.

func Put

func Put(key string, e interface{})

Put put.

func SendNotice

func SendNotice(key string, e interface{})

SendNotice send notice to other nodes.

func SetLogLevel

func SetLogLevel(level LogLevel)

SetLogLevel set log level.

func SetNotice

func SetNotice(key string, notice Notice)

SetNotice set notice.

Types

type LogLevel

type LogLevel int

LogLevel log level

const (
	//LogLevelDebug log level debug.
	LogLevelDebug LogLevel = 0
	//LogLevelInfo log level info.
	LogLevelInfo LogLevel = 1
	//LogLevelWarn log level warn.
	LogLevelWarn LogLevel = 2
	//LogLevelOff log level off.
	LogLevelOff LogLevel = 3
)

type Notice

type Notice func(data []byte)

Notice notice.