Home
last modified time | relevance | path

Searched defs:Poller (Results 1 – 25 of 284) sorted by relevance

12345678910>>...12

/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/
H A Dpolling.go20 type Poller struct { struct
21 items []C.zmq_pollitem_t
22 socks []*Socket
39 func (p *Poller) Add(soc *Socket, events State) int {
54 func (p *Poller) Update(id int, events State) (previous State, err error) {
82 func (p *Poller) Remove(id int) error {
99 func (p *Poller) RemoveBySocket(soc *Socket) error {
135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) {
149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) {
153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) {
[all …]
/dports/net-p2p/bitmark-daemon/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/
H A Dpolling.go20 type Poller struct { struct
21 items []C.zmq_pollitem_t
22 socks []*Socket
39 func (p *Poller) Add(soc *Socket, events State) int {
54 func (p *Poller) Update(id int, events State) (previous State, err error) {
82 func (p *Poller) Remove(id int) error {
99 func (p *Poller) RemoveBySocket(soc *Socket) error {
135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) {
149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) {
153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) {
[all …]
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/
H A Dpolling.go20 type Poller struct { struct
21 items []C.zmq_pollitem_t
22 socks []*Socket
39 func (p *Poller) Add(soc *Socket, events State) int {
54 func (p *Poller) Update(id int, events State) (previous State, err error) {
82 func (p *Poller) Remove(id int) error {
99 func (p *Poller) RemoveBySocket(soc *Socket) error {
135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) {
149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) {
153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) {
[all …]
/dports/net-p2p/bitmark-recorder/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/
H A Dpolling.go20 type Poller struct { struct
21 items []C.zmq_pollitem_t
22 socks []*Socket
39 func (p *Poller) Add(soc *Socket, events State) int {
54 func (p *Poller) Update(id int, events State) (previous State, err error) {
82 func (p *Poller) Remove(id int) error {
99 func (p *Poller) RemoveBySocket(soc *Socket) error {
135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) {
149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) {
153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) {
[all …]
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/
H A Dpolling.go20 type Poller struct { struct
21 items []C.zmq_pollitem_t
22 socks []*Socket
39 func (p *Poller) Add(soc *Socket, events State) int {
54 func (p *Poller) Update(id int, events State) (previous State, err error) {
82 func (p *Poller) Remove(id int) error {
99 func (p *Poller) RemoveBySocket(soc *Socket) error {
135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) {
149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) {
153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) {
[all …]
/dports/net-p2p/bitmark-cli/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/
H A Dpolling.go20 type Poller struct { struct
21 items []C.zmq_pollitem_t
22 socks []*Socket
39 func (p *Poller) Add(soc *Socket, events State) int {
54 func (p *Poller) Update(id int, events State) (previous State, err error) {
82 func (p *Poller) Remove(id int) error {
99 func (p *Poller) RemoveBySocket(soc *Socket) error {
135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) {
149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) {
153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) {
[all …]
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/
H A Dpolling.go20 type Poller struct { struct
21 items []C.zmq_pollitem_t
22 socks []*Socket
39 func (p *Poller) Add(soc *Socket, events State) int {
54 func (p *Poller) Update(id int, events State) (previous State, err error) {
82 func (p *Poller) Remove(id int) error {
99 func (p *Poller) RemoveBySocket(soc *Socket) error {
135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) {
149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) {
153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) {
[all …]
/dports/net-p2p/bitmark/bitmarkd-0.13.3/vendor/github.com/pebbe/zmq4/draft/
H A Dpolling.go20 type Poller struct { struct
21 items []C.zmq_pollitem_t
22 socks []*Socket
39 func (p *Poller) Add(soc *Socket, events State) int {
54 func (p *Poller) Update(id int, events State) (previous State, err error) {
82 func (p *Poller) Remove(id int) error {
99 func (p *Poller) RemoveBySocket(soc *Socket) error {
135 func (p *Poller) Poll(timeout time.Duration) ([]Polled, error) {
149 func (p *Poller) PollAll(timeout time.Duration) ([]Polled, error) {
153 func (p *Poller) poll(timeout time.Duration, all bool) ([]Polled, error) {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/armcore/internal/pollers/async/
H A Dasync.go29 type Poller struct { struct
31 Type string `json:"type"`
34 AsyncURL string `json:"asyncURL"`
37 LocURL string `json:"locURL"`
40 OrigURL string `json:"origURL"`
43 Method string `json:"method"`
46 FinalState string `json:"finalState"`
49 CurState string `json:"state"`
90 func (p *Poller) Done() bool {
126 func (p *Poller) URL() string {
[all …]
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/Azure/azure-sdk-for-go/sdk/armcore/internal/pollers/async/
H A Dasync.go29 type Poller struct { struct
31 Type string `json:"type"`
34 AsyncURL string `json:"asyncURL"`
37 LocURL string `json:"locURL"`
40 OrigURL string `json:"origURL"`
43 Method string `json:"method"`
46 FinalState string `json:"finalState"`
49 CurState string `json:"state"`
90 func (p *Poller) Done() bool {
126 func (p *Poller) URL() string {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-internal-v0.7.0/sdk/armcore/internal/pollers/async/
H A Dasync.go29 type Poller struct { struct
31 Type string `json:"type"`
34 AsyncURL string `json:"asyncURL"`
37 LocURL string `json:"locURL"`
40 OrigURL string `json:"origURL"`
43 Method string `json:"method"`
46 FinalState string `json:"finalState"`
49 CurState string `json:"state"`
90 func (p *Poller) Done() bool {
126 func (p *Poller) URL() string {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/internal/pollers/
H A Dpoller.go53 func PollerType(p *Poller) reflect.Type {
63 type Poller struct { struct
64 lro Operation
65 pl pipeline.Pipeline
66 eu func(*http.Response) error
67 resp *http.Response
68 err error
72 func (l *Poller) Done() bool {
80 func (l *Poller) Poll(ctx context.Context) (*http.Response, error) {
118 func (l *Poller) ResumeToken() (string, error) {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/internal/pollers/
H A Dpoller.go53 func PollerType(p *Poller) reflect.Type {
63 type Poller struct { struct
64 lro Operation
65 pl pipeline.Pipeline
66 eu func(*http.Response) error
67 resp *http.Response
68 err error
72 func (l *Poller) Done() bool {
80 func (l *Poller) Poll(ctx context.Context) (*http.Response, error) {
118 func (l *Poller) ResumeToken() (string, error) {
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/internal/pollers/
H A Dpoller.go53 func PollerType(p *Poller) reflect.Type {
63 type Poller struct { struct
64 lro Operation
65 pl pipeline.Pipeline
66 eu func(*http.Response) error
67 resp *http.Response
68 err error
72 func (l *Poller) Done() bool {
80 func (l *Poller) Poll(ctx context.Context) (*http.Response, error) {
118 func (l *Poller) ResumeToken() (string, error) {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/arm/internal/pollers/async/
H A Dasync.go35 type Poller struct { struct
37 Type string `json:"type"`
40 AsyncURL string `json:"asyncURL"`
43 LocURL string `json:"locURL"`
46 OrigURL string `json:"origURL"`
49 Method string `json:"method"`
52 FinalState string `json:"finalState"`
55 CurState string `json:"state"`
96 func (p *Poller) Done() bool {
132 func (p *Poller) URL() string {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/arm/internal/pollers/async/
H A Dasync.go35 type Poller struct { struct
37 Type string `json:"type"`
40 AsyncURL string `json:"asyncURL"`
43 LocURL string `json:"locURL"`
46 OrigURL string `json:"origURL"`
49 Method string `json:"method"`
52 FinalState string `json:"finalState"`
55 CurState string `json:"state"`
96 func (p *Poller) Done() bool {
132 func (p *Poller) URL() string {
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/arm/internal/pollers/async/
H A Dasync.go35 type Poller struct { struct
37 Type string `json:"type"`
40 AsyncURL string `json:"asyncURL"`
43 LocURL string `json:"locURL"`
46 OrigURL string `json:"origURL"`
49 Method string `json:"method"`
52 FinalState string `json:"finalState"`
55 CurState string `json:"state"`
96 func (p *Poller) Done() bool {
132 func (p *Poller) URL() string {
[all …]
/dports/sysutils/sensu-go/sensu-go-5.11.1/vendor/github.com/libp2p/go-reuseport/poll/
H A Dpoll_linux.go13 type Poller struct { struct
14 epfd int
16 eventMain unix.EpollEvent
17 eventWait unix.EpollEvent
18 events []unix.EpollEvent
20 wake *eventfd.EventFD // Use eventfd to wakeup epoll
21 wakeMutex sync.Mutex
57 func (p *Poller) Close() error {
73 func (p *Poller) WaitWriteCtx(ctx context.Context) error {
/dports/www/grafana8/azure-sdk-for-go-sdk-azidentity-v0.10.0/sdk/azcore/internal/pollers/op/
H A Dop.go28 type Poller struct { struct
29 Type string `json:"type"`
30 PollURL string `json:"pollURL"`
31 LocURL string `json:"locURL"`
32 FinalGET string `json:"finalGET"`
33 CurState string `json:"state"`
79 func (p *Poller) URL() string {
83 func (p *Poller) Done() bool {
87 func (p *Poller) Update(resp *http.Response) error {
109 func (p *Poller) FinalGetURL() string {
[all …]
/dports/net-mgmt/prometheus2/prometheus-2.30.3/vendor/github.com/Azure/azure-sdk-for-go/sdk/azcore/internal/pollers/op/
H A Dop.go28 type Poller struct { struct
29 Type string `json:"type"`
30 PollURL string `json:"pollURL"`
31 LocURL string `json:"locURL"`
32 FinalGET string `json:"finalGET"`
33 CurState string `json:"state"`
79 func (p *Poller) URL() string {
83 func (p *Poller) Done() bool {
87 func (p *Poller) Update(resp *http.Response) error {
109 func (p *Poller) FinalGetURL() string {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/azcore/internal/pollers/op/
H A Dop.go28 type Poller struct { struct
29 Type string `json:"type"`
30 PollURL string `json:"pollURL"`
31 LocURL string `json:"locURL"`
32 FinalGET string `json:"finalGET"`
33 CurState string `json:"state"`
79 func (p *Poller) URL() string {
83 func (p *Poller) Done() bool {
87 func (p *Poller) Update(resp *http.Response) error {
109 func (p *Poller) FinalGetURL() string {
[all …]
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/armcore/internal/pollers/loc/
H A Dloc.go23 type Poller struct { struct
25 Type string `json:"type"`
28 PollURL string `json:"pollURL"`
31 CurState string `json:"state"`
53 func (p *Poller) URL() string {
58 func (p *Poller) Done() bool {
63 func (p *Poller) Update(resp *azcore.Response) error {
90 func (p *Poller) FinalGetURL() string {
95 func (p *Poller) Status() string {
/dports/www/grafana8/azure-sdk-for-go-sdk-azcore-v0.19.0/sdk/armcore/internal/pollers/body/
H A Dbody.go25 type Poller struct { struct
27 Type string `json:"type"`
30 PollURL string `json:"pollURL"`
33 CurState string `json:"state"`
68 func (p *Poller) URL() string {
73 func (p *Poller) Done() bool {
78 func (p *Poller) Update(resp *azcore.Response) error {
98 func (*Poller) FinalGetURL() string {
103 func (p *Poller) Status() string {
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/Azure/azure-sdk-for-go/sdk/armcore/internal/pollers/body/
H A Dbody.go25 type Poller struct { struct
27 Type string `json:"type"`
30 PollURL string `json:"pollURL"`
33 CurState string `json:"state"`
68 func (p *Poller) URL() string {
73 func (p *Poller) Done() bool {
78 func (p *Poller) Update(resp *azcore.Response) error {
98 func (*Poller) FinalGetURL() string {
103 func (p *Poller) Status() string {
/dports/sysutils/restic/restic-0.12.1/vendor/github.com/Azure/azure-sdk-for-go/sdk/armcore/internal/pollers/loc/
H A Dloc.go23 type Poller struct { struct
25 Type string `json:"type"`
28 PollURL string `json:"pollURL"`
31 CurState string `json:"state"`
53 func (p *Poller) URL() string {
58 func (p *Poller) Done() bool {
63 func (p *Poller) Update(resp *azcore.Response) error {
90 func (p *Poller) FinalGetURL() string {
95 func (p *Poller) Status() string {

12345678910>>...12