util

package
v4.0.0-alpha9 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Mar 17, 2022 License: MIT Imports: 22 Imported by: 38

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var BigEndian bigEndian

BigEndian is the big-endian implementation of ByteOrder.

View Source 
var Crc32_Table = []uint32{}/* 256 elements not displayed */
View Source 
var LittleEndian littleEndian
View Source 
var Null = struct{}{}

Functions

func BasicAuth 

func BasicAuth(u, p string, next http.HandlerFunc) http.HandlerFunc

func BigLittleSwap 

func BigLittleSwap(v uint) uint

func Bit1 

func Bit1(b byte, index int) bool

Bit1 检查字节中的某一位是否为1 |0|1|2|3|4|5|6|7|

func ByteToUint32 

func ByteToUint32(data []byte, bigEndian bool) (ret uint32, err error)

千万注意大小端,RTMP是大端

func ByteToUint32N 

func ByteToUint32N(data []byte) (ret uint32, err error)

// 千万注意大小端,RTMP是大端

func ByteToUint64N 

func ByteToUint64N(data []byte) (ret uint64, err error)

// 千万注意大小端,RTMP是大端

func CORS 

func CORS(next http.HandlerFunc) http.HandlerFunc

func Clone 

func Clone[T any](x T) *T

func ConvertNum 

func ConvertNum[F Integer, T Integer](from F, to T) T

func CreateShutdownScript 

func CreateShutdownScript() error

func CurrentDir 

func CurrentDir(path ...string) string

func Exist 

func Exist(filename string) bool

检查文件或目录是否存在 如果由 filename 指定的文件或目录存在则返回 true，否则返回 false

func GetBE 

func GetBE[T Integer](b []byte, num *T) T

func GetFillBytes 

func GetFillBytes(data byte, n int) []byte

func GetPCR 

func GetPCR(v uint64) uint64

func GetPtsDts 

func GetPtsDts(v uint64) uint64

func GetUev 

func GetUev(buff []byte, start int) (value int, pos int)

哥伦布解码

func LastElement 

func LastElement[T any](s []T) T

func ListenUDP 

func ListenUDP(address string, networkBuffer int) (*net.UDPConn, error)

func PutBE 

func PutBE[T Integer](b []byte, num T) []byte

func PutPCR 

func PutPCR(pcr uint64) uint64

func PutPtsDts 

func PutPtsDts(v uint64) uint64

func ReadBE 

func ReadBE[T Integer](b []byte) (num T)

func ReadByteToUint16 

func ReadByteToUint16(r io.Reader, bigEndian bool) (data uint16, err error)

func ReadByteToUint24 

func ReadByteToUint24(r io.Reader, bigEndian bool) (data uint32, err error)

func ReadByteToUint32 

func ReadByteToUint32(r io.Reader, bigEndian bool) (data uint32, err error)

func ReadByteToUint40 

func ReadByteToUint40(r io.Reader, bigEndian bool) (data uint64, err error)

func ReadByteToUint48 

func ReadByteToUint48(r io.Reader, bigEndian bool) (data uint64, err error)

func ReadByteToUint64 

func ReadByteToUint64(r io.Reader, bigEndian bool) (data uint64, err error)

func ReadByteToUint8 

func ReadByteToUint8(r io.Reader) (data uint8, err error)

func ReturnJson 

func ReturnJson[T any](fetch func() T, tickDur time.Duration, rw http.ResponseWriter, r *http.Request)

func SizeOfBuffers 

func SizeOfBuffers[T ~[]byte](buf []T) (size int)

SizeOfBuffers 计算Buffers的内容长度

func SplitBuffers 

func SplitBuffers[T ~[]byte](buf []T, size int) (result [][]T)

SplitBuffers 按照一定大小分割 Buffers

func ToFloat64 

func ToFloat64(num interface{}) float64

func Uint32ToByte 

func Uint32ToByte(data uint32, bigEndian bool) (ret []byte, err error)

func WaitTerm 

func WaitTerm(cancel context.CancelFunc)

func WriteUint16ToByte 

func WriteUint16ToByte(w io.Writer, data uint16, bigEndian bool) error

func WriteUint24ToByte 

func WriteUint24ToByte(w io.Writer, data uint32, bigEndian bool) error

func WriteUint32ToByte 

func WriteUint32ToByte(w io.Writer, data uint32, bigEndian bool) error

func WriteUint40ToByte 

func WriteUint40ToByte(w io.Writer, data uint64, bigEndian bool) error

func WriteUint48ToByte 

func WriteUint48ToByte(w io.Writer, data uint64, bigEndian bool) error

func WriteUint64ToByte 

func WriteUint64ToByte(w io.Writer, data uint64, bigEndian bool) error

func WriteUint8ToByte 

func WriteUint8ToByte(w io.Writer, data uint8) error

Types

type Buffer 

type Buffer []byte

func (Buffer) CanRead 

func (b Buffer) CanRead() bool

func (Buffer) Cap 

func (b Buffer) Cap() int

func (*Buffer) Glow 

func (b *Buffer) Glow(n int)

func (Buffer) Len 

func (b Buffer) Len() int

func (*Buffer) Malloc 

func (b *Buffer) Malloc(count int) Buffer

func (*Buffer) ReadByte 

func (b *Buffer) ReadByte() byte

func (*Buffer) ReadFloat64 

func (b *Buffer) ReadFloat64() float64

func (*Buffer) ReadN 

func (b *Buffer) ReadN(n int) Buffer

func (*Buffer) ReadUint16 

func (b *Buffer) ReadUint16() uint16

func (*Buffer) ReadUint24 

func (b *Buffer) ReadUint24() uint32

func (*Buffer) ReadUint32 

func (b *Buffer) ReadUint32() uint32

func (*Buffer) ReadUint64 

func (b *Buffer) ReadUint64() uint64

func (*Buffer) Reset 

func (b *Buffer) Reset()

func (Buffer) SubBuf 

func (b Buffer) SubBuf(start int, length int) Buffer

func (*Buffer) Write 

func (b *Buffer) Write(a []byte) (n int, err error)

func (*Buffer) WriteByte 

func (b *Buffer) WriteByte(v byte)

func (*Buffer) WriteFloat64 

func (b *Buffer) WriteFloat64(v float64)

func (*Buffer) WriteString 

func (b *Buffer) WriteString(a string)

func (*Buffer) WriteUint16 

func (b *Buffer) WriteUint16(v uint16)

func (*Buffer) WriteUint24 

func (b *Buffer) WriteUint24(v uint32)

func (*Buffer) WriteUint32 

func (b *Buffer) WriteUint32(v uint32)

type Crc32Reader 

type Crc32Reader struct {
	R     io.Reader
	Crc32 uint32
}

func (*Crc32Reader) Read 

func (cr *Crc32Reader) Read(b []byte) (n int, err error)

func (*Crc32Reader) ReadCrc32UIntAndCheck 

func (cr *Crc32Reader) ReadCrc32UIntAndCheck() (err error)

type Crc32Writer 

type Crc32Writer struct {
	W     io.Writer
	Crc32 uint32
}

func (*Crc32Writer) Write 

func (wr *Crc32Writer) Write(b []byte) (n int, err error)

type IOVec 

type IOVec struct {
	Data   [][]byte
	Length int
	// contains filtered or unexported fields
}

func (*IOVec) Append 

func (iov *IOVec) Append(b []byte)

func (*IOVec) WriteTo 

func (iov *IOVec) WriteTo(w io.Writer, n int) (written int, err error)

type IOVecWriter 

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

func NewIOVecWriter 

func NewIOVecWriter(w io.Writer) (iow *IOVecWriter)

func (*IOVecWriter) Flush 

func (iow *IOVecWriter) Flush() error

func (*IOVecWriter) Write 

func (iow *IOVecWriter) Write(data []byte) (written int, err error)

type Integer 

type Integer interface {
	~int | ~int16 | ~int32 | ~int64 | ~uint | ~uint16 | ~uint32 | ~uint64
}

type Map 

type Map[K comparable, V any] struct {
	sync.RWMutex
	Map map[K]V
}

func (*Map[K, V]) Add 

func (m *Map[K, V]) Add(k K, v V) bool

func (*Map[K, V]) Delete 

func (m *Map[K, V]) Delete(k K)

func (*Map[K, V]) Get 

func (m *Map[K, V]) Get(k K) V

func (*Map[K, V]) Has 

func (m *Map[K, V]) Has(k K) (ok bool)

func (*Map[K, V]) Init 

func (m *Map[K, V]) Init()

func (*Map[K, V]) Len 

func (m *Map[K, V]) Len() int

func (*Map[K, V]) Range 

func (m *Map[K, V]) Range(f func(V))

func (*Map[K, V]) Set 

func (m *Map[K, V]) Set(k K, v V)

func (*Map[K, V]) ToList 

func (m *Map[K, V]) ToList() (r []V)

type Promise 

type Promise[S any, R any] struct {
	Value S
	// contains filtered or unexported fields
}

func NewPromise 

func NewPromise[S any, R any](value S) *Promise[S, R]

func (*Promise[S, R]) AWait 

func (p *Promise[S, R]) AWait() (R, error)

func (*Promise[S, R]) Catch 

func (p *Promise[S, R]) Catch() (err error)

func (*Promise[S, R]) Reject 

func (r *Promise[S, R]) Reject(err error)

func (*Promise[S, R]) Resolve 

func (r *Promise[S, R]) Resolve(result R)

func (*Promise[S, R]) Then 

func (p *Promise[S, R]) Then() (r R)

type Ring 

type Ring[T any] struct {
	Value T // for use by client; untouched by this library
	// contains filtered or unexported fields
}

A Ring is an element of a circular list, or ring. Rings do not have a beginning or end; a pointer to any ring element serves as reference to the entire ring. Empty rings are represented as nil Ring pointers. The zero value for a Ring is a one-element ring with a nil Value.

func NewRing 

func NewRing[T any](n int) *Ring[T]

New creates a ring of n elements.

func (*Ring[T]) Do 

func (r *Ring[T]) Do(f func(T))

Do calls function f on each element of the ring, in forward order. The behavior of Do is undefined if f changes *r.

func (*Ring[T]) Len 

func (r *Ring[T]) Len() int

Len computes the number of elements in ring r. It executes in time proportional to the number of elements. 

func (r *Ring[T]) Link(s *Ring[T]) *Ring[T]

Link connects ring r with ring s such that r.Next() becomes s and returns the original value for r.Next(). r must not be empty.

If r and s point to the same ring, linking them removes the elements between r and s from the ring. The removed elements form a subring and the result is a reference to that subring (if no elements were removed, the result is still the original value for r.Next(), and not nil).

If r and s point to different rings, linking them creates a single ring with the elements of s inserted after r. The result points to the element following the last element of s after insertion.

func (*Ring[T]) Move 

func (r *Ring[T]) Move(n int) *Ring[T]

Move moves n % r.Len() elements backward (n < 0) or forward (n >= 0) in the ring and returns that ring element. r must not be empty.

func (*Ring[T]) Next 

func (r *Ring[T]) Next() *Ring[T]

Next returns the next ring element. r must not be empty.

func (*Ring[T]) Prev 

func (r *Ring[T]) Prev() *Ring[T]

Prev returns the previous ring element. r must not be empty. 

func (r *Ring[T]) Unlink(n int) *Ring[T]

Unlink removes n % r.Len() elements from the ring r, starting at r.Next(). If n % r.Len() == 0, r remains unchanged. The result is the removed subring. r must not be empty.

type SSE 

type SSE struct {
	http.ResponseWriter
	context.Context
}

func NewSSE 

func NewSSE(w http.ResponseWriter, ctx context.Context) *SSE

func (*SSE) Write 

func (sse *SSE) Write(data []byte) (n int, err error)

func (*SSE) WriteEvent 

func (sse *SSE) WriteEvent(event string, data []byte) (err error)

func (*SSE) WriteExec 

func (sse *SSE) WriteExec(cmd *exec.Cmd) error

func (*SSE) WriteJSON 

func (sse *SSE) WriteJSON(data any) error

type SafeChan 

type SafeChan[T any] struct {
	C chan T
	// contains filtered or unexported fields
}

SafeChan安全的channel，可以防止close后被写入的问题

func (*SafeChan[T]) Close 

func (sc *SafeChan[T]) Close() bool

Close senders为0的时候可以安全关闭，否则不能关闭

func (*SafeChan[T]) Init 

func (sc *SafeChan[T]) Init(n int)

func (*SafeChan[T]) IsClosed 

func (sc *SafeChan[T]) IsClosed() bool

func (*SafeChan[T]) IsEmpty 

func (sc *SafeChan[T]) IsEmpty() bool

func (*SafeChan[T]) IsFull 

func (sc *SafeChan[T]) IsFull() bool

func (*SafeChan[T]) Send 

func (sc *SafeChan[T]) Send(v T) bool

type Slice 

type Slice[T comparable] []T

func (*Slice[T]) Add 

func (s *Slice[T]) Add(v T)

func (*Slice[T]) Delete 

func (s *Slice[T]) Delete(v T) bool

func (Slice[T]) Len 

func (s Slice[T]) Len() int

func (*Slice[T]) Reset 

func (s *Slice[T]) Reset()

func (*Slice[T]) ResetAppend 

func (s *Slice[T]) ResetAppend(first T)

type SysIOVec 

type SysIOVec struct {
	Base   uintptr
	Length uint64
}

Source Files

View all Source files

Directories

Path Synopsis
bufio
pio

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.