rueian/rueidis

View on GitHub
internal/cmds/gen_pubsub.go

Summary

Maintainability
B
5 hrs
Test Coverage
A
100%
// Code generated DO NOT EDIT

package cmds

type Psubscribe Incomplete

func (b Builder) Psubscribe() (c Psubscribe) {
    c = Psubscribe{cs: get(), ks: b.ks, cf: int16(noRetTag)}
    c.cs.s = append(c.cs.s, "PSUBSCRIBE")
    return c
}

func (c Psubscribe) Pattern(pattern ...string) PsubscribePattern {
    c.cs.s = append(c.cs.s, pattern...)
    return (PsubscribePattern)(c)
}

type PsubscribePattern Incomplete

func (c PsubscribePattern) Pattern(pattern ...string) PsubscribePattern {
    c.cs.s = append(c.cs.s, pattern...)
    return c
}

func (c PsubscribePattern) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type Publish Incomplete

func (b Builder) Publish() (c Publish) {
    c = Publish{cs: get(), ks: b.ks}
    c.cs.s = append(c.cs.s, "PUBLISH")
    return c
}

func (c Publish) Channel(channel string) PublishChannel {
    c.cs.s = append(c.cs.s, channel)
    return (PublishChannel)(c)
}

type PublishChannel Incomplete

func (c PublishChannel) Message(message string) PublishMessage {
    c.cs.s = append(c.cs.s, message)
    return (PublishMessage)(c)
}

type PublishMessage Incomplete

func (c PublishMessage) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubChannels Incomplete

func (b Builder) PubsubChannels() (c PubsubChannels) {
    c = PubsubChannels{cs: get(), ks: b.ks, cf: int16(readonly)}
    c.cs.s = append(c.cs.s, "PUBSUB", "CHANNELS")
    return c
}

func (c PubsubChannels) Pattern(pattern string) PubsubChannelsPattern {
    c.cs.s = append(c.cs.s, pattern)
    return (PubsubChannelsPattern)(c)
}

func (c PubsubChannels) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubChannelsPattern Incomplete

func (c PubsubChannelsPattern) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubHelp Incomplete

func (b Builder) PubsubHelp() (c PubsubHelp) {
    c = PubsubHelp{cs: get(), ks: b.ks, cf: int16(readonly)}
    c.cs.s = append(c.cs.s, "PUBSUB", "HELP")
    return c
}

func (c PubsubHelp) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubNumpat Incomplete

func (b Builder) PubsubNumpat() (c PubsubNumpat) {
    c = PubsubNumpat{cs: get(), ks: b.ks, cf: int16(readonly)}
    c.cs.s = append(c.cs.s, "PUBSUB", "NUMPAT")
    return c
}

func (c PubsubNumpat) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubNumsub Incomplete

func (b Builder) PubsubNumsub() (c PubsubNumsub) {
    c = PubsubNumsub{cs: get(), ks: b.ks, cf: int16(readonly)}
    c.cs.s = append(c.cs.s, "PUBSUB", "NUMSUB")
    return c
}

func (c PubsubNumsub) Channel(channel ...string) PubsubNumsubChannel {
    c.cs.s = append(c.cs.s, channel...)
    return (PubsubNumsubChannel)(c)
}

func (c PubsubNumsub) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubNumsubChannel Incomplete

func (c PubsubNumsubChannel) Channel(channel ...string) PubsubNumsubChannel {
    c.cs.s = append(c.cs.s, channel...)
    return c
}

func (c PubsubNumsubChannel) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubShardchannels Incomplete

func (b Builder) PubsubShardchannels() (c PubsubShardchannels) {
    c = PubsubShardchannels{cs: get(), ks: b.ks}
    c.cs.s = append(c.cs.s, "PUBSUB", "SHARDCHANNELS")
    return c
}

func (c PubsubShardchannels) Pattern(pattern string) PubsubShardchannelsPattern {
    c.cs.s = append(c.cs.s, pattern)
    return (PubsubShardchannelsPattern)(c)
}

func (c PubsubShardchannels) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubShardchannelsPattern Incomplete

func (c PubsubShardchannelsPattern) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubShardnumsub Incomplete

func (b Builder) PubsubShardnumsub() (c PubsubShardnumsub) {
    c = PubsubShardnumsub{cs: get(), ks: b.ks}
    c.cs.s = append(c.cs.s, "PUBSUB", "SHARDNUMSUB")
    return c
}

func (c PubsubShardnumsub) Channel(channel ...string) PubsubShardnumsubChannel {
    c.cs.s = append(c.cs.s, channel...)
    return (PubsubShardnumsubChannel)(c)
}

func (c PubsubShardnumsub) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PubsubShardnumsubChannel Incomplete

func (c PubsubShardnumsubChannel) Channel(channel ...string) PubsubShardnumsubChannel {
    c.cs.s = append(c.cs.s, channel...)
    return c
}

func (c PubsubShardnumsubChannel) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type Punsubscribe Incomplete

func (b Builder) Punsubscribe() (c Punsubscribe) {
    c = Punsubscribe{cs: get(), ks: b.ks, cf: int16(noRetTag)}
    c.cs.s = append(c.cs.s, "PUNSUBSCRIBE")
    return c
}

func (c Punsubscribe) Pattern(pattern ...string) PunsubscribePattern {
    c.cs.s = append(c.cs.s, pattern...)
    return (PunsubscribePattern)(c)
}

func (c Punsubscribe) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type PunsubscribePattern Incomplete

func (c PunsubscribePattern) Pattern(pattern ...string) PunsubscribePattern {
    c.cs.s = append(c.cs.s, pattern...)
    return c
}

func (c PunsubscribePattern) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type Spublish Incomplete

func (b Builder) Spublish() (c Spublish) {
    c = Spublish{cs: get(), ks: b.ks}
    c.cs.s = append(c.cs.s, "SPUBLISH")
    return c
}

func (c Spublish) Channel(channel string) SpublishChannel {
    if c.ks&NoSlot == NoSlot {
        c.ks = NoSlot | slot(channel)
    } else {
        c.ks = check(c.ks, slot(channel))
    }
    c.cs.s = append(c.cs.s, channel)
    return (SpublishChannel)(c)
}

type SpublishChannel Incomplete

func (c SpublishChannel) Message(message string) SpublishMessage {
    c.cs.s = append(c.cs.s, message)
    return (SpublishMessage)(c)
}

type SpublishMessage Incomplete

func (c SpublishMessage) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type Ssubscribe Incomplete

func (b Builder) Ssubscribe() (c Ssubscribe) {
    c = Ssubscribe{cs: get(), ks: b.ks, cf: int16(noRetTag)}
    c.cs.s = append(c.cs.s, "SSUBSCRIBE")
    return c
}

func (c Ssubscribe) Channel(channel ...string) SsubscribeChannel {
    if c.ks&NoSlot == NoSlot {
        for _, k := range channel {
            c.ks = NoSlot | slot(k)
            break
        }
    } else {
        for _, k := range channel {
            c.ks = check(c.ks, slot(k))
        }
    }
    c.cs.s = append(c.cs.s, channel...)
    return (SsubscribeChannel)(c)
}

type SsubscribeChannel Incomplete

func (c SsubscribeChannel) Channel(channel ...string) SsubscribeChannel {
    if c.ks&NoSlot == NoSlot {
        for _, k := range channel {
            c.ks = NoSlot | slot(k)
            break
        }
    } else {
        for _, k := range channel {
            c.ks = check(c.ks, slot(k))
        }
    }
    c.cs.s = append(c.cs.s, channel...)
    return c
}

func (c SsubscribeChannel) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type Subscribe Incomplete

func (b Builder) Subscribe() (c Subscribe) {
    c = Subscribe{cs: get(), ks: b.ks, cf: int16(noRetTag)}
    c.cs.s = append(c.cs.s, "SUBSCRIBE")
    return c
}

func (c Subscribe) Channel(channel ...string) SubscribeChannel {
    c.cs.s = append(c.cs.s, channel...)
    return (SubscribeChannel)(c)
}

type SubscribeChannel Incomplete

func (c SubscribeChannel) Channel(channel ...string) SubscribeChannel {
    c.cs.s = append(c.cs.s, channel...)
    return c
}

func (c SubscribeChannel) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type Sunsubscribe Incomplete

func (b Builder) Sunsubscribe() (c Sunsubscribe) {
    c = Sunsubscribe{cs: get(), ks: b.ks, cf: int16(noRetTag)}
    c.cs.s = append(c.cs.s, "SUNSUBSCRIBE")
    return c
}

func (c Sunsubscribe) Channel(channel ...string) SunsubscribeChannel {
    if c.ks&NoSlot == NoSlot {
        for _, k := range channel {
            c.ks = NoSlot | slot(k)
            break
        }
    } else {
        for _, k := range channel {
            c.ks = check(c.ks, slot(k))
        }
    }
    c.cs.s = append(c.cs.s, channel...)
    return (SunsubscribeChannel)(c)
}

func (c Sunsubscribe) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type SunsubscribeChannel Incomplete

func (c SunsubscribeChannel) Channel(channel ...string) SunsubscribeChannel {
    if c.ks&NoSlot == NoSlot {
        for _, k := range channel {
            c.ks = NoSlot | slot(k)
            break
        }
    } else {
        for _, k := range channel {
            c.ks = check(c.ks, slot(k))
        }
    }
    c.cs.s = append(c.cs.s, channel...)
    return c
}

func (c SunsubscribeChannel) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type Unsubscribe Incomplete

func (b Builder) Unsubscribe() (c Unsubscribe) {
    c = Unsubscribe{cs: get(), ks: b.ks, cf: int16(noRetTag)}
    c.cs.s = append(c.cs.s, "UNSUBSCRIBE")
    return c
}

func (c Unsubscribe) Channel(channel ...string) UnsubscribeChannel {
    c.cs.s = append(c.cs.s, channel...)
    return (UnsubscribeChannel)(c)
}

func (c Unsubscribe) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}

type UnsubscribeChannel Incomplete

func (c UnsubscribeChannel) Channel(channel ...string) UnsubscribeChannel {
    c.cs.s = append(c.cs.s, channel...)
    return c
}

func (c UnsubscribeChannel) Build() Completed {
    c.cs.Build()
    return Completed{cs: c.cs, cf: uint16(c.cf), ks: c.ks}
}