listen

package

v0.23.0 Latest Latest Go to latest Published: Oct 21, 2026 License: BSD-2-Clause Imports: 12 Imported by: 2

Details

This section is empty.

This section is empty.

func Jitter(mul int) time.Duration

Return a random duration from -1s to +1s

func RetryingWatch(
	target string, header http.Header, finish <-chan struct{},
) (<-chan []byte, <-chan error)

This function is like Watch() except if the transport fails, it is automatically retried.

func Watch(
	target string, header http.Header, finish <-chan struct{},
) (<-chan []byte, <-chan error, error)

type ErrConnectionFail struct {
	// contains filtered or unexported fields
}

func (e *ErrConnectionFail) Error() string

type Message struct {
	*http.Request
}

func (r Message) MarshalJSON() ([]byte, error)

func (m Message) Payload() ([]byte, error)

Read out the full request body and replace it with a buffer

func (r *Message) UnmarshalJSON(data []byte) error