udp

README

UDP

Provides two sub-packages

• udps (UDP Server)
• udpc (UDP Client)

Example

TODO

Documentation

Overview

Package udp provides common functionality used in udpc and udps packages

Index

• type Client
• type Stream
  • func HandleStream(logger *logrus.Logger, stream quic.Stream, ...) (cstream *Stream, err error)
  • func NewStream(data map[string]string, channel *network.Channel) (s *Stream, err error)
  • func NewStreamFromData(data *model.StreamConnectionData, channel *network.Channel) *Stream
  • func (s *Stream) Channel() *network.Channel
  • func (s *Stream) Close()
  • func (s *Stream) Stream() quic.Stream
  • func (s *Stream) String() string
• type StreamHandler

Types

type Client

type Client interface {
	ID() string
	String() string
	Close(code int, reason string)

	Send(msg *network.Message) (rmsg *network.Message, err error)
	OpenStream(data map[string]string) (stream *Stream, err error)
	CloseStream(id string)
}

Client Interface stipulates functions which should be present in a client

type Stream

type Stream struct {
	// Stream ID
	Id string

	// Stream Metadata
	Data map[string]string

	// Exit Channel
	Exit chan bool
	// Closed Status
	Closed bool
	// contains filtered or unexported fields
}

Stream

func HandleStream

func HandleStream(logger *logrus.Logger, stream quic.Stream, unmarshalers []network.ChannelUnmarshaler) (cstream *Stream, err error)

func NewStream

func NewStream(data map[string]string, channel *network.Channel) (s *Stream, err error)

func NewStreamFromData

func NewStreamFromData(data *model.StreamConnectionData, channel *network.Channel) *Stream

func (*Stream) Channel

func (s *Stream) Channel() *network.Channel

func (*Stream) Close

func (s *Stream) Close()

func (*Stream) Stream

func (s *Stream) Stream() quic.Stream

func (*Stream) String

func (s *Stream) String() string

type StreamHandler

type StreamHandler func(Client, *Stream)

On New Stream Handler