debugger

package
v0.0.4 Latest Latest
Warning

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

Go to latest
Published: Mar 8, 2023 License: MIT Imports: 10 Imported by: 0

Documentation

Index

Constants

View Source
const (
	TimestampFormat = "2006-01-02 15:04:05.999999999 (MST)"

	FieldTimestamp    = "time"
	FieldMessage      = "msg"
	FieldPeerId       = logging.PeerIdContextLabel
	FieldConnectionId = logging.ConnectionIdContextLabel
	FieldStreamId     = logging.StreamIdContextLabel

	MessageLogFieldRequestNumber = "header.number"
	MessageLogFieldFlags         = "header.flags"
	MessageLogFieldBody          = "body"
	MessageLogMessageSent        = "sending a message"
	MessageLogMessageReceived    = "received a message"
)

Variables

View Source
var (
	MessageTypeReceived = MessageType{"received"}
	MessageTypeSent     = MessageType{"sent"}
)

Functions

This section is empty.

Types

type Connection

type Connection map[string]Stream

Connection uses stream ids as keys.

func NewConnection

func NewConnection() Connection

func (Connection) AddEvent

func (s Connection) AddEvent(event Event) error

type Connections

type Connections map[string]Connection

Connections uses connection ids as keys.

func NewConnections

func NewConnections() Connections

func (Connections) AddEvent

func (s Connections) AddEvent(event Event) error

type Event

type Event struct {
	Timestamp time.Time

	PeerId       string
	ConnectionId string
	StreamId     string

	Message *Message
	Entry   log.Entry
}

func NewEvent

func NewEvent(e log.Entry) (*Event, error)

type Message

type Message struct {
	Type          MessageType
	Flags         string
	RequestNumber int
	Body          string
}

func NewMessage

func NewMessage(entry log.Entry) (Message, error)

type MessageType

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

type Peers

type Peers map[string]Connections

Peers uses peer ids as keys.

func NewPeers

func NewPeers() Peers

func (Peers) Add

func (p Peers) Add(e log.Entry) error

type Stream

type Stream struct {
	Events []Event
}

func NewStream

func NewStream() Stream

Directories

Path Synopsis

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL