network

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

type ChannelUnmarshaler func(mtype MessageType) (msg proto.Message, err error)

type Config interface {
	// Maximum number of concurrent streams open on connection
	MaxStreams() int16
	// Use QUIC Datagram
	// This model does not guarantee a packet will be delivered
	UseDatagram() bool
}

type Message struct {
	// Message Context
	Ctx MessageContext
	// Message Options
	Opt MessageOptions
	// Message Body
	Body proto.Message
}

type MessageContext struct {
	// Message ID
	Id string
	// Message needs an Acknowledgement
	Ack bool
	// Message is Acknowledgement Reply
	Ackr bool
	// Message Type
	Type MessageType
}

type MessageOptions struct {
	// Duration after which the Message Request Timesout
	Timeout time.Duration
}

type MessageType string

type NewMessageOptions struct {
	// Message requires an ACK
	Ack bool
	// Message Timeout Duration
	Timeout time.Duration
}

type PingResult struct {
	// Ping Status
	Status bool
	// Ping Status Message
	Message string
	// Ping Address
	Addr string
	// Average time taken
	AvgTime time.Duration
}

type PingResults struct {
	// Success Results
	Success []PingResult
	// Failed Results
	Failed []PingResult
}