pkg

Documentation

Index

• func Broadcast(ctx context.Context) (err error)
• func FindWaiters(ctx context.Context, waiter chan string)
• func Retry(count int, callback func() error) (err error)
• type HeaderBuilder
  • func NewHeaderBuilder(file string) *HeaderBuilder
  • func (h *HeaderBuilder) Build() (err error)
  • func (h *HeaderBuilder) CreateHeader(index int, data []byte) []byte
  • func (h *HeaderBuilder) GetBufferCount() int
  • func (h *HeaderBuilder) GetChunk() int
  • func (h *HeaderBuilder) GetFileSize() int64
  • func (h *HeaderBuilder) GetFilename() string
• type Queue
  • func (q *Queue) Pop() (item *int)
  • func (q *Queue) Push(value int)
  • func (q *Queue) Size() int
• type SafeMap
  • func NewSafeMap(count int) (safeMap *SafeMap)
  • func (m *SafeMap) Get() *int
  • func (m *SafeMap) GetAndRemove() (target *int)
  • func (m *SafeMap) GetKeys() (result []int)
  • func (m *SafeMap) GetLowestAndRemove() (target *int)
  • func (m *SafeMap) Put(k int, val string)
  • func (m *SafeMap) Remove(k int)
  • func (m *SafeMap) Size() int
• type UDPSender
  • func NewUDPSender(ip string) *UDPSender
  • func (s *UDPSender) Send(msg chan string, file string) (err error)
  • func (s *UDPSender) WithPort(port int) *UDPSender
• type UDPWaiter
  • func NewUDPWaiter(port int) *UDPWaiter
  • func (w *UDPWaiter) ListenAddress(address string) *UDPWaiter
  • func (w *UDPWaiter) Start(msg chan string) (err error)

Functions

func Broadcast

func Broadcast(ctx context.Context) (err error)

Broadcast sends the broadcast message to all the potential ip addresses

func FindWaiters

func FindWaiters(ctx context.Context, waiter chan string)

func Retry

func Retry(count int, callback func() error) (err error)

Retry run the callback for the specific times

Types

type HeaderBuilder

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

func NewHeaderBuilder

func NewHeaderBuilder(file string) *HeaderBuilder

NewHeaderBuilder creates an instance of the HeaderBuilder

func (*HeaderBuilder) Build

func (h *HeaderBuilder) Build() (err error)

func (*HeaderBuilder) CreateHeader

func (h *HeaderBuilder) CreateHeader(index int, data []byte) []byte

CreateHeader creates the header with index

func (*HeaderBuilder) GetBufferCount

func (h *HeaderBuilder) GetBufferCount() int

GetBufferCount returns the buffer count

func (*HeaderBuilder) GetChunk

func (h *HeaderBuilder) GetChunk() int

GetChunk returns the chunk size

func (*HeaderBuilder) GetFileSize

func (h *HeaderBuilder) GetFileSize() int64

GetFileSize returns the file size

func (*HeaderBuilder) GetFilename

func (h *HeaderBuilder) GetFilename() string

GetFilename returns the file name

type Queue

type Queue struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func (*Queue) Pop

func (q *Queue) Pop() (item *int)

func (*Queue) Push

func (q *Queue) Push(value int)

func (*Queue) Size

func (q *Queue) Size() int

type SafeMap

type SafeMap struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewSafeMap

func NewSafeMap(count int) (safeMap *SafeMap)

func (*SafeMap) Get

func (m *SafeMap) Get() *int

func (*SafeMap) GetAndRemove

func (m *SafeMap) GetAndRemove() (target *int)

func (*SafeMap) GetKeys

func (m *SafeMap) GetKeys() (result []int)

func (*SafeMap) GetLowestAndRemove

func (m *SafeMap) GetLowestAndRemove() (target *int)

func (*SafeMap) Put

func (m *SafeMap) Put(k int, val string)

func (*SafeMap) Remove

func (m *SafeMap) Remove(k int)

func (*SafeMap) Size

func (m *SafeMap) Size() int

type UDPSender

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

func NewUDPSender

func NewUDPSender(ip string) *UDPSender

func (*UDPSender) Send

func (s *UDPSender) Send(msg chan string, file string) (err error)

func (*UDPSender) WithPort

func (s *UDPSender) WithPort(port int) *UDPSender

type UDPWaiter

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

UDPWaiter represents a UDP component for receiving data

func NewUDPWaiter

func NewUDPWaiter(port int) *UDPWaiter

NewUDPWaiter creates an instance of NewUDPWaiter

func (*UDPWaiter) ListenAddress

func (w *UDPWaiter) ListenAddress(address string) *UDPWaiter

ListenAddress set the listen address

func (*UDPWaiter) Start

func (w *UDPWaiter) Start(msg chan string) (err error)

Start starts UDP connection