connection

README

Connection Package Documentation

This package contains the events that are triggered during the ingress call, capturing both the input and output of the user API call.

Documentation

Index

• Variables
• func ConvertUnixNanoToTime(unixNano uint64) time.Time
• type Factory
  • func NewFactory(inactivityThreshold time.Duration, logger *zap.Logger) *Factory
  • func (factory *Factory) GetOrCreate(connectionID structs.ConnID) *Tracker
  • func (factory *Factory) HandleReadyConnections(db platform.TestCaseDB, ctx context.Context, filters *models.Filters)
• type Tracker
  • func NewTracker(connID structs2.ConnID, logger *zap.Logger) *Tracker
  • func (conn *Tracker) AddCloseEvent(event structs2.SocketCloseEvent)
  • func (conn *Tracker) AddDataEvent(event structs2.SocketDataEvent)
  • func (conn *Tracker) AddOpenEvent(event structs2.SocketOpenEvent)
  • func (conn *Tracker) IsComplete() (bool, []byte, []byte, time.Time, time.Time)
  • func (conn *Tracker) IsInactive(duration time.Duration) bool
  • func (conn *Tracker) ToBytes() ([]byte, []byte)
  • func (conn *Tracker) UpdateTimestamps()

Variables

var Emoji = "\U0001F430" + " Keploy:"

Functions

func ConvertUnixNanoToTime

func ConvertUnixNanoToTime(unixNano uint64) time.Time

ConvertUnixNanoToTime takes a Unix timestamp in nanoseconds as a uint64 and returns the corresponding time.Time

Types

type Factory

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

Factory is a routine-safe container that holds a trackers with unique ID, and able to create new tracker.

func NewFactory

func NewFactory(inactivityThreshold time.Duration, logger *zap.Logger) *Factory

NewFactory creates a new instance of the factory.

func (*Factory) GetOrCreate

func (factory *Factory) GetOrCreate(connectionID structs.ConnID) *Tracker

GetOrCreate returns a tracker that related to the given connection and transaction ids. If there is no such tracker we create a new one.

func (*Factory) HandleReadyConnections

func (factory *Factory) HandleReadyConnections(db platform.TestCaseDB, ctx context.Context, filters *models.Filters)

type Tracker

type Tracker struct {
	SentBuf []byte
	RecvBuf []byte
	// contains filtered or unexported fields
}

func NewTracker

func NewTracker(connID structs2.ConnID, logger *zap.Logger) *Tracker

func (*Tracker) AddCloseEvent

func (conn *Tracker) AddCloseEvent(event structs2.SocketCloseEvent)

func (*Tracker) AddDataEvent

func (conn *Tracker) AddDataEvent(event structs2.SocketDataEvent)

func (*Tracker) AddOpenEvent

func (conn *Tracker) AddOpenEvent(event structs2.SocketOpenEvent)

func (*Tracker) IsComplete

func (conn *Tracker) IsComplete() (bool, []byte, []byte, time.Time, time.Time)

IsComplete() checks if the current connection has valid request & response info to capture and also returns the request and response data buffer.

func (*Tracker) IsInactive

func (conn *Tracker) IsInactive(duration time.Duration) bool

func (*Tracker) ToBytes

func (conn *Tracker) ToBytes() ([]byte, []byte)

func (*Tracker) UpdateTimestamps

func (conn *Tracker) UpdateTimestamps()