recording

package
v1.3.5 Latest Latest
Warning

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

 Go to latest Published: Apr 14, 2022 License: Apache-2.0 Imports: 12 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

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

ErrInvalidID is returned when trying to unmarshal an invalid ID

Functions

func EncodeAnyByteArray 

func EncodeAnyByteArray(s []byte) json.RawMessage

Types

type Action 

type Action interface {
	GetActionIndex() int
	GetOccurredAt() int64
	GetActionType() string
}

type AppendFile 

type AppendFile struct {
	FileName string
	Content  []byte
	// contains filtered or unexported fields
}

func (*AppendFile) GetActionIndex 

func (action *AppendFile) GetActionIndex() int

func (*AppendFile) GetActionType 

func (action *AppendFile) GetActionType() string

func (*AppendFile) GetOccurredAt 

func (action *AppendFile) GetOccurredAt() int64

func (*AppendFile) MarshalJSON 

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

func (*AppendFile) SetActionIndex 

func (action *AppendFile) SetActionIndex(actionIndex int)

func (*AppendFile) SetActionType 

func (action *AppendFile) SetActionType(actionType string)

func (*AppendFile) SetOccurredAt 

func (action *AppendFile) SetOccurredAt(occurredAt int64)

type CallFromInbound 

type CallFromInbound struct {
	Peer     net.TCPAddr
	Request  []byte // depends on Raw,  http    | http
	Raw      []byte // decides Request, fastcgi | http
	UnixAddr net.UnixAddr
	// contains filtered or unexported fields
}

func (*CallFromInbound) GetActionIndex 

func (action *CallFromInbound) GetActionIndex() int

func (*CallFromInbound) GetActionType 

func (action *CallFromInbound) GetActionType() string

func (*CallFromInbound) GetOccurredAt 

func (action *CallFromInbound) GetOccurredAt() int64

func (*CallFromInbound) MarshalJSON 

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

func (*CallFromInbound) SetActionIndex 

func (action *CallFromInbound) SetActionIndex(actionIndex int)

func (*CallFromInbound) SetActionType 

func (action *CallFromInbound) SetActionType(actionType string)

func (*CallFromInbound) SetOccurredAt 

func (action *CallFromInbound) SetOccurredAt(occurredAt int64)

type CallOutbound 

type CallOutbound struct {
	SocketFD     int
	Peer         net.TCPAddr
	Local        *net.TCPAddr `json:"-"`
	Request      []byte
	ResponseTime int64
	Response     []byte
	UnixAddr     net.UnixAddr
	CSpanId      []byte
	IgnoreFlag   bool
	// contains filtered or unexported fields
}

func (*CallOutbound) GetActionIndex 

func (action *CallOutbound) GetActionIndex() int

func (*CallOutbound) GetActionType 

func (action *CallOutbound) GetActionType() string

func (*CallOutbound) GetOccurredAt 

func (action *CallOutbound) GetOccurredAt() int64

func (*CallOutbound) MarshalJSON 

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

func (*CallOutbound) SetActionIndex 

func (action *CallOutbound) SetActionIndex(actionIndex int)

func (*CallOutbound) SetActionType 

func (action *CallOutbound) SetActionType(actionType string)

func (*CallOutbound) SetIgnoreFlag 

func (callOutbound *CallOutbound) SetIgnoreFlag(flag bool)

func (*CallOutbound) SetOccurredAt 

func (action *CallOutbound) SetOccurredAt(occurredAt int64)

type ID 

type ID [rawLen]byte

ID represents a unique request id

func FromString 

func FromString(id string) (ID, error)

FromString reads an ID from its string representation

func (ID) Counter 

func (id ID) Counter() int32

Counter returns the incrementing value part of the id. It's a runtime error to call this method with an invalid id.

func (ID) Machine 

func (id ID) Machine() []byte

Machine returns the 3-byte machine id part of the id. It's a runtime error to call this method with an invalid id.

func (ID) MarshalText 

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

MarshalText implements encoding/text TextMarshaler interface

func (ID) Pid 

func (id ID) Pid() uint16

Pid returns the process id part of the id. It's a runtime error to call this method with an invalid id.

func (*ID) Scan 

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

Scan implements the sql.Scanner interface.

func (ID) String 

func (id ID) String() string

String returns a base32 hex lowercased with no padding representation of the id (char set is 0-9, a-v).

func (ID) Time 

func (id ID) Time() time.Time

Time returns the timestamp part of the id. It's a runtime error to call this method with an invalid id.

func (*ID) UnmarshalText 

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

UnmarshalText implements encoding/text TextUnmarshaler interface

func (ID) Value 

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

Value implements the driver.Valuer interface.

type ReadStorage 

type ReadStorage struct {
	Content []byte
	// contains filtered or unexported fields
}

func (*ReadStorage) GetActionIndex 

func (action *ReadStorage) GetActionIndex() int

func (*ReadStorage) GetActionType 

func (action *ReadStorage) GetActionType() string

func (*ReadStorage) GetOccurredAt 

func (action *ReadStorage) GetOccurredAt() int64

func (*ReadStorage) MarshalJSON 

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

func (*ReadStorage) SetActionIndex 

func (action *ReadStorage) SetActionIndex(actionIndex int)

func (*ReadStorage) SetActionType 

func (action *ReadStorage) SetActionType(actionType string)

func (*ReadStorage) SetOccurredAt 

func (action *ReadStorage) SetOccurredAt(occurredAt int64)

type ReturnInbound 

type ReturnInbound struct {
	Response []byte // http format
	Raw      []byte // fastcgi format
	// contains filtered or unexported fields
}

func (*ReturnInbound) GetActionIndex 

func (action *ReturnInbound) GetActionIndex() int

func (*ReturnInbound) GetActionType 

func (action *ReturnInbound) GetActionType() string

func (*ReturnInbound) GetOccurredAt 

func (action *ReturnInbound) GetOccurredAt() int64

func (*ReturnInbound) MarshalJSON 

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

func (*ReturnInbound) SetActionIndex 

func (action *ReturnInbound) SetActionIndex(actionIndex int)

func (*ReturnInbound) SetActionType 

func (action *ReturnInbound) SetActionType(actionType string)

func (*ReturnInbound) SetOccurredAt 

func (action *ReturnInbound) SetOccurredAt(occurredAt int64)

type SendUDP 

type SendUDP struct {
	Peer    net.UDPAddr
	Content []byte
	// contains filtered or unexported fields
}

func (*SendUDP) GetActionIndex 

func (action *SendUDP) GetActionIndex() int

func (*SendUDP) GetActionType 

func (action *SendUDP) GetActionType() string

func (*SendUDP) GetOccurredAt 

func (action *SendUDP) GetOccurredAt() int64

func (*SendUDP) MarshalJSON 

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

func (*SendUDP) SetActionIndex 

func (action *SendUDP) SetActionIndex(actionIndex int)

func (*SendUDP) SetActionType 

func (action *SendUDP) SetActionType(actionType string)

func (*SendUDP) SetOccurredAt 

func (action *SendUDP) SetOccurredAt(occurredAt int64)

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.