util

package

v0.0.1 Latest Latest Go to latest Published: Jun 4, 2024 License: MIT Imports: 17 Imported by: 0

Details

This section is empty.

View Source

var (
	HeaderID    = []byte("id:")
	HeaderData  = []byte("data:")
	HeaderEvent = []byte("event:")
	HeaderRetry = []byte("retry:")
)

func Backoff(rfn Retfn) error

func Bytes2str(b []byte) string

func GetBuf() *bytes.Buffer

func GetEnvAny(names ...string) string

func HasChineseChar(str string) bool

func IsHttp20xCode(num int) bool

func IsNewline(r rune) bool

func ParseUrl(u string) (*url.URL, error)

func PutBuf(b *bytes.Buffer)

func StartLoop(r io.Reader) (chan *Event, chan error)

func Str2bytes(s string) []byte

func TimeBackoff(rfn Retfn, maxtime time.Duration) error

maxtime is 0 will forever

func Validurl(u *url.URL) error

type Event struct {
	ID      []byte
	Data    []byte
	Event   []byte
	Retry   []byte
	Comment []byte
}

Event holds all of the event source fields

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

EventStreamReader scans an io.Reader looking for EventStream messages.

func NewEventStreamReader(eventStream io.Reader, maxBufferSize int) *EventStreamReader

NewEventStreamReader creates an instance of EventStreamReader.

func (e *EventStreamReader) ReadEvent() ([]byte, error)

ReadEvent scans the EventStream for events.

type Retfn func() error

type RoundTripper struct {
	Client tlsclient.HttpClient
}

func NewRoundTripper(httpClientOption ...tlsclient.HttpClientOption) (*RoundTripper, error)

func (s RoundTripper) RoundTrip(hReq *http.Request) (*http.Response, error)