Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

definition

package

Go to main page

Versions in this module

v0

v0.0.2

Mar 13, 2025

Changes in this version

+ const DELETE_KEY_VALUE

+ const GET_KEY_VALUE

+ const LEN

+ const SET_KEY_VALUE

type Mq

+ DeleteKeyValue func(mq string, key string) (err error)

+ GetKeyValue func(mq string, key string) (value *Value, ok bool, err error)

+ Len func(mq string) (int, error)

+ SetKeyValue func(mq string, key string, value string, expire time.Duration) (err error)

+ type MqDeleteKeyValueArgs struct

+ Key string

+ Mq string

+ type MqDeleteKeyValueReply struct

+ type MqGetKeyValueArgs struct

+ Key string

+ Mq string

+ type MqGetKeyValueReply struct

+ Ok bool

+ Value *Value

+ type MqLenArgs struct

+ Mq string

+ type MqLenReply struct

+ Len int

type MqRPC

+ DeleteKeyValue func(args MqDeleteKeyValueArgs, reply *MqDeleteKeyValueReply) (err error)

+ GetKeyValue func(args MqGetKeyValueArgs, reply *MqGetKeyValueReply) (err error)

+ Len func(args MqLenArgs, reply *MqLenReply) (err error)

+ SetKeyValue func(args MqSetKeyValueArgs, reply *MqSetKeyValueReply) (err error)

+ type MqSetKeyValueArgs struct

+ Expire *time.Time

+ Key string

+ Mq string

+ Value string

+ type MqSetKeyValueReply struct

+ type Value struct

+ ExpireAt time.Time

+ UpdatedAt time.Time

+ Value string

v0.0.1

Feb 19, 2025

Changes in this version

+ const ACTIVE

+ const AUTH

+ const CREATE_MQ

+ const DELETE

+ const DELETE_MQ

+ const DROP

+ const MqRpcName

+ const PING

+ const POP

+ const PUSH

+ const READ

+ type AuthArgs struct

+ Token string

+ type AuthReply struct

+ type CreateMqArgs struct

+ Mq string

+ type CreateMqReply struct

+ type DeleteMqArgs struct

+ Mq string

+ type DeleteMqReply struct

+ type Mq interface

+ Active func(mq string, id uint64) (err error)

+ CreateMq func(mq string) (err error)

+ Delete func(mq string, id uint64) (err error)

+ DeleteMq func(mq string) (err error)

+ Drop func(mq string) (err error)

+ Pop func(mq string, num int) (msgs []Msg, err error)

+ Push func(mq string, msg string) (id uint64, err error)

+ Read func(mq string, num int, timeout time.Duration) (msgs []Msg, err error)

+ type MqActiveArgs struct

+ Id uint64

+ Mq string

+ type MqActiveReply struct

+ type MqDeleteArgs struct

+ Id uint64

+ Mq string

+ type MqDeleteReply struct

+ type MqDropArgs struct

+ Mq string

+ type MqDropReply struct

+ type MqPopArgs struct

+ Mq string

+ Num int

+ type MqPopReply struct

+ Msgs []Msg

+ type MqPushArgs struct

+ Mq string

+ Msg string

+ type MqPushReply struct

+ Id uint64

+ type MqRPC interface

+ Active func(args MqActiveArgs, reply *MqActiveReply) (err error)

+ Auth func(args AuthArgs, reply *AuthReply) (err error)

+ CreateMq func(args CreateMqArgs, reply *CreateMqReply) (err error)

+ Delete func(args MqDeleteArgs, reply *MqDeleteReply) (err error)

+ DeleteMq func(args DeleteMqArgs, reply *DeleteMqReply) (err error)

+ Drop func(args MqDropArgs, reply *MqDropReply) (err error)

+ Ping func(PingArgs, *PingReply) (err error)

+ Pop func(args MqPopArgs, reply *MqPopReply) (err error)

+ Push func(args MqPushArgs, reply *MqPushReply) (err error)

+ Read func(args MqReadArgs, reply *MqReadReply) (err error)

+ type MqReadArgs struct

+ Mq string

+ Num int

+ Timeout time.Duration

+ type MqReadReply struct

+ Msgs []Msg

+ type Msg struct

+ CreatedAt time.Time

+ Id uint64

+ Text string

+ type PingArgs struct

+ type PingReply struct