| /dports/net-im/chatterino2/chatterino2-2.3.4/src/providers/twitch/ |
| H A D | PubsubClient.cpp | 205 PubSub::PubSub() in PubSub() function in chatterino::PubSub
|
| /dports/www/gitea/gitea-1.16.5/vendor/github.com/go-redis/redis/v8/ |
| H A D | pubsub.go | 21 type PubSub struct { struct
22 opt *Options
27 mu sync.Mutex
28 cn *pool.Conn
32 closed bool
33 exit chan struct{}
35 cmd *Cmd
37 chOnce sync.Once
38 msgCh *channel
39 allCh *channel
[all …]
|
| /dports/net/traefik/traefik-2.6.1/vendor/gopkg.in/redis.v5/ |
| H A D | pubsub.go | 16 type PubSub struct { struct
17 base baseClient
18 cmd *Cmd
20 mu sync.Mutex
21 channels []string
22 patterns []string
25 func (c *PubSub) conn() (*pool.Conn, bool, error) {
36 func (c *PubSub) putConn(cn *pool.Conn, err error) {
97 func (c *PubSub) Close() error {
101 func (c *PubSub) Ping(payload ...string) error {
[all …]
|
| H A D | sentinel.go | 110 func (c *sentinelClient) PubSub() *PubSub { func
|
| /dports/lang/rust/rustc-1.58.1-src/vendor/jsonrpc-derive/src/ |
| H A D | rpc_attr.rs | 24 PubSub { enumerator
|
| H A D | to_delegate.rs | 18 PubSub { enumerator
|
| /dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/api/dlp/v2/ |
| H A D | dlp-gen.go | 495 PubSub *GooglePrivacyDlpV2PublishToPubSub `json:"pubSub,omitempty"` member
|
| /dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/api/container/v1/ |
| H A D | container-api.json | 4685 "PubSub": { object
|
| H A D | container-gen.go | 4039 type PubSub struct { struct
4041 Enabled bool `json:"enabled,omitempty"`
4045 Topic string `json:"topic,omitempty"`
4053 ForceSendFields []string `json:"-"`
4061 NullFields []string `json:"-"`
4064 func (s *PubSub) MarshalJSON() ([]byte, error) {
|
| /dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/api/container/v1beta1/ |
| H A D | container-gen.go | 4634 type PubSub struct { struct
4636 Enabled bool `json:"enabled,omitempty"`
4640 Topic string `json:"topic,omitempty"`
4648 ForceSendFields []string `json:"-"`
4656 NullFields []string `json:"-"`
4659 func (s *PubSub) MarshalJSON() ([]byte, error) {
|
| H A D | container-api.json | 5035 "PubSub": { object
|
| /dports/www/gohugo/hugo-0.91.2/vendor/google.golang.org/genproto/googleapis/privacy/dlp/v2/ |
| H A D | dlp.pb.go | 7826 PubSub *Action_PublishToPubSub `protobuf:"bytes,2,opt,name=pub_sub,json=pubSub,proto3,oneof"` member
|
| /dports/net-im/dendrite/dendrite-0.5.1/cmd/dendrite-demo-libp2p/ |
| H A D | publicrooms.go | 50 func newPublicRoomsProvider(ps *pubsub.PubSub, rsAPI roomserverAPI.RoomserverInternalAPI) *publicRo…
|
| /dports/www/tusd/tusd-1.8.0/vendor/google.golang.org/api/container/v1/ |
| H A D | container-api.json | 4664 "PubSub": { object
|
| H A D | container-gen.go | 3973 type PubSub struct { struct
3975 Enabled bool `json:"enabled,omitempty"`
3979 Topic string `json:"topic,omitempty"`
3987 ForceSendFields []string `json:"-"`
3995 NullFields []string `json:"-"`
3998 func (s *PubSub) MarshalJSON() ([]byte, error) {
|
| /dports/www/tusd/tusd-1.8.0/vendor/google.golang.org/api/container/v1beta1/ |
| H A D | container-api.json | 5020 "PubSub": { object
|
| H A D | container-gen.go | 4601 type PubSub struct { struct
4603 Enabled bool `json:"enabled,omitempty"`
4607 Topic string `json:"topic,omitempty"`
4615 ForceSendFields []string `json:"-"`
4623 NullFields []string `json:"-"`
4626 func (s *PubSub) MarshalJSON() ([]byte, error) {
|
| /dports/www/tusd/tusd-1.8.0/vendor/google.golang.org/api/dlp/v2/ |
| H A D | dlp-gen.go | 495 PubSub *GooglePrivacyDlpV2PublishToPubSub `json:"pubSub,omitempty"` member
|
| /dports/www/mattermost-server/mattermost-server-6.0.2/vendor/github.com/go-redis/redis/v8/ |
| H A D | pubsub.go | 21 type PubSub struct { struct
22 opt *Options
27 mu sync.Mutex
28 cn *pool.Conn
32 closed bool
33 exit chan struct{}
35 cmd *Cmd
37 chOnce sync.Once
38 msgCh *channel
39 allCh *channel
[all …]
|
| /dports/www/tusd/tusd-1.8.0/vendor/google.golang.org/genproto/googleapis/privacy/dlp/v2/ |
| H A D | dlp.pb.go | 7826 PubSub *Action_PublishToPubSub `protobuf:"bytes,2,opt,name=pub_sub,json=pubSub,proto3,oneof"` member
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/grafana/loki/vendor/github.com/go-redis/redis/v8/ |
| H A D | pubsub.go | 21 type PubSub struct { struct
22 opt *Options
27 mu sync.Mutex
28 cn *pool.Conn
32 closed bool
33 exit chan struct{}
35 cmd *Cmd
37 chOnce sync.Once
38 msgCh *channel
39 allCh *channel
[all …]
|
| /dports/www/grafana8/grafana-8.3.6/vendor/github.com/cortexproject/cortex/vendor/github.com/go-redis/redis/v8/ |
| H A D | pubsub.go | 21 type PubSub struct { struct
22 opt *Options
27 mu sync.Mutex
28 cn *pool.Conn
32 closed bool
33 exit chan struct{}
35 cmd *Cmd
37 chOnce sync.Once
38 msgCh *channel
39 allCh *channel
[all …]
|
| /dports/net-im/gajim/gajim-gajim-1.3.3/gajim/common/modules/ |
| H A D | pubsub.py | 30 class PubSub(BaseModule): class
|
| /dports/net-im/py-nbxmpp/nbxmpp-2.0.4/nbxmpp/modules/ |
| H A D | pubsub.py | 37 class PubSub(BaseModule): class
|
| /dports/net/cloudquery/cloudquery-0.16.0/vendor/google.golang.org/genproto/googleapis/privacy/dlp/v2/ |
| H A D | dlp.pb.go | 7826 PubSub *Action_PublishToPubSub `protobuf:"bytes,2,opt,name=pub_sub,json=pubSub,proto3,oneof"` member
|