Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

recording

package

Go to main page

Versions in this module

v0

v0.0.6

Apr 17, 2019

v0.0.5

Apr 17, 2019

Changes in this version

type CallOutbound

+ func (callOutbound *CallOutbound) GetIdentifier() string

v0.0.4

Mar 4, 2019

v0.0.3

Feb 26, 2019

v0.0.2

Feb 21, 2019

v0.0.1

Feb 20, 2019

Changes in this version

+ var ErrInvalidID = errors.New("xid: invalid ID")

+ var Recorders = []Recorder

+ var ShouldRecordAction = func(action Action) bool

+ var TraceHeaderKeySpanId = TraceHeaderKey("si")

+ var TraceHeaderKeyTraceId = TraceHeaderKey("ti")

+ func EncodeAnyByteArray(s []byte) json.RawMessage

+ type Action interface

+ GetActionIndex func() int

+ GetActionType func() string

+ GetOccurredAt func() int64

+ type AppendFile struct

+ Content []byte

+ FileName string

+ func (action *AppendFile) GetActionIndex() int

+ func (action *AppendFile) GetActionType() string

+ func (action *AppendFile) GetOccurredAt() int64

+ func (appendFile *AppendFile) MarshalJSON() ([]byte, error)

+ type AsyncRecorder struct

+ Context context.Context

+ func NewAsyncRecorder(realRecorder Recorder) *AsyncRecorder

+ func (recorder *AsyncRecorder) Record(session *Session)

+ func (recorder *AsyncRecorder) Start()

+ type CallFromInbound struct

+ Peer net.TCPAddr

+ Request []byte

+ UnixAddr net.UnixAddr

+ func (action *CallFromInbound) GetActionIndex() int

+ func (action *CallFromInbound) GetActionType() string

+ func (action *CallFromInbound) GetOccurredAt() int64

+ func (callFromInbound *CallFromInbound) MarshalJSON() ([]byte, error)

+ type CallOutbound struct

+ CSpanId []byte

+ Local *net.TCPAddr

+ Peer net.TCPAddr

+ Request []byte

+ Response []byte

+ ResponseTime int64

+ SocketFD int

+ UnixAddr net.UnixAddr

+ func (action *CallOutbound) GetActionIndex() int

+ func (action *CallOutbound) GetActionType() string

+ func (action *CallOutbound) GetOccurredAt() int64

+ func (callOutbound *CallOutbound) MarshalJSON() ([]byte, error)

+ type ID [rawLen]byte

+ func FromString(id string) (ID, error)

+ func (id *ID) Scan(value interface{}) (err error)

+ func (id *ID) UnmarshalText(text []byte) error

+ func (id ID) Counter() int32

+ func (id ID) Machine() []byte

+ func (id ID) MarshalText() ([]byte, error)

+ func (id ID) Pid() uint16

+ func (id ID) String() string

+ func (id ID) Time() time.Time

+ func (id ID) Value() (driver.Value, error)

+ type ReadStorage struct

+ Content []byte

+ func (action *ReadStorage) GetActionIndex() int

+ func (action *ReadStorage) GetActionType() string

+ func (action *ReadStorage) GetOccurredAt() int64

+ func (readStorage *ReadStorage) MarshalJSON() ([]byte, error)

+ type Recorder interface

+ Record func(session *Session)

+ type ReturnInbound struct

+ Response []byte

+ func (action *ReturnInbound) GetActionIndex() int

+ func (action *ReturnInbound) GetActionType() string

+ func (action *ReturnInbound) GetOccurredAt() int64

+ func (returnInbound *ReturnInbound) MarshalJSON() ([]byte, error)

+ type SendUDP struct

+ Content []byte

+ Peer net.UDPAddr

+ func (action *SendUDP) GetActionIndex() int

+ func (action *SendUDP) GetActionType() string

+ func (action *SendUDP) GetOccurredAt() int64

+ func (sendUDP *SendUDP) MarshalJSON() ([]byte, error)

+ type Session struct

+ Actions []Action

+ CallFromInbound *CallFromInbound

+ Context string

+ NextSessionId string

+ ReturnInbound *ReturnInbound

+ SessionId string

+ SpanId []byte

+ ThreadId int32

+ TraceHeader TraceHeader

+ TraceId []byte

+ func NewSession(threadId int32) *Session

+ func (session *Session) AppendFile(ctx context.Context, content []byte, fileName string)

+ func (session *Session) BeforeSendToOutbound(ctx context.Context, peer net.TCPAddr, local *net.TCPAddr, socketFD int)

+ func (session *Session) GetTraceHeader() TraceHeader

+ func (session *Session) HasResponded() bool

+ func (session *Session) MarshalJSON() ([]byte, error)

+ func (session *Session) ReadStorage(ctx context.Context, span []byte)

+ func (session *Session) RecvFromInbound(ctx context.Context, span []byte, peer net.TCPAddr, unix net.UnixAddr)

+ func (session *Session) RecvFromOutbound(ctx context.Context, span []byte, peer net.TCPAddr, local *net.TCPAddr, ...)

+ func (session *Session) SendToInbound(ctx context.Context, span []byte, peer net.TCPAddr)

+ func (session *Session) SendToOutbound(ctx context.Context, span []byte, peer net.TCPAddr, local *net.TCPAddr, ...)

+ func (session *Session) SendUDP(ctx context.Context, span []byte, peer net.UDPAddr)

+ func (session *Session) Shutdown(ctx context.Context, newSession *Session)

+ func (session *Session) Summary(newSession *Session)

+ type Talk struct

+ Peer net.TCPAddr

+ Request []byte

+ Response []byte

+ ResponseTime int64

+ type TraceHeader []byte

+ func (header TraceHeader) Get(targetKey TraceHeaderKey) TraceHeaderValue

+ func (header TraceHeader) MarshalJSON() ([]byte, error)

+ func (header TraceHeader) Next() (TraceHeaderKey, TraceHeaderValue, TraceHeader)

+ func (header TraceHeader) Set(key TraceHeaderKey, value TraceHeaderValue) TraceHeader

+ type TraceHeaderKey []byte

+ type TraceHeaderValue []byte