myredis

Documentation

Index

• func Connect(addr string, password string) *redis.Client
• func Del() (int64, error)
• func Entries(group string, stream string) ([]redis.XStream, error)
• func Messages(entries []redis.XStream) []redis.XMessage
• func PublishHref(stream string, href string, group string) error
• func SAdd(href string) (int64, error)
• func SMembers() ([]string, error)
• func Stream(stream string, group string) error
• type MsgPost
  • func Process(messages []redis.XMessage, stream string, group string) []MsgPost

Functions

func Connect

func Connect(addr string, password string) *redis.Client

func Del

func Del() (int64, error)

func Entries

func Entries(group string, stream string) ([]redis.XStream, error)

func Messages

func Messages(entries []redis.XStream) []redis.XMessage

func PublishHref

func PublishHref(stream string, href string, group string) error

func SAdd

func SAdd(href string) (int64, error)

func SMembers

func SMembers() ([]string, error)

func Stream

func Stream(stream string, group string) error

Types

type MsgPost

type MsgPost struct {
	Href  string `json:"href"`
	Group string `json:"group"`
}

func Process

func Process(messages []redis.XMessage, stream string, group string) []MsgPost