lgc

package
v0.0.3 Latest Latest
Warning

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

 Go to latest Published: Nov 16, 2024 License: GPL-2.0 Imports: 16 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type LgcDirection 

type LgcDirection int
const (
	LGC_DOWN LgcDirection = iota
	LGC_UP
)

func (LgcDirection) String 

func (direction LgcDirection) String() string

type LgcStatus 

type LgcStatus int
const (
	LGC_STATUS_NOT_STARTED LgcStatus = iota
	LGC_STATUS_RUNNING
	LGC_STATUS_DONE
	LGC_STATUS_ERROR
)

func (LgcStatus) String 

func (status LgcStatus) String() string

type LoadGeneratingConnection 

type LoadGeneratingConnection interface {
	Start(context.Context, debug.DebugLevel) bool
	TransferredInInterval() (uint64, time.Duration)
	Client() *http.Client
	Status() LgcStatus
	ClientId() uint64
	Stats() *stats.TraceStats
	WaitUntilStarted(context.Context) bool
	Direction() LgcDirection
}

type LoadGeneratingConnectionCollection 

type LoadGeneratingConnectionCollection struct {
	Lock sync.Mutex
	LGCs *[]LoadGeneratingConnection
}

func NewLoadGeneratingConnectionCollection 

func NewLoadGeneratingConnectionCollection() LoadGeneratingConnectionCollection

func (*LoadGeneratingConnectionCollection) Append 

func (collection *LoadGeneratingConnectionCollection) Append(conn LoadGeneratingConnection) error

func (*LoadGeneratingConnectionCollection) Get 

func (collection *LoadGeneratingConnectionCollection) Get(idx int) (*LoadGeneratingConnection, error)

func (*LoadGeneratingConnectionCollection) GetRandom 

func (collection *LoadGeneratingConnectionCollection) GetRandom() (*LoadGeneratingConnection, error)

func (*LoadGeneratingConnectionCollection) Len 

func (collection *LoadGeneratingConnectionCollection) Len() (int, error)

type LoadGeneratingConnectionDownload 

type LoadGeneratingConnectionDownload struct {
	ConnectToAddr string
	URL           string

	InsecureSkipVerify bool
	KeyLogger          io.Writer
	// contains filtered or unexported fields
}

TODO: All 64-bit fields that are accessed atomically must appear at the top of this struct.

func NewLoadGeneratingConnectionDownload 

func NewLoadGeneratingConnectionDownload(url string, keyLogger io.Writer, connectToAddr string, insecureSkipVerify bool, congestionControl *string) LoadGeneratingConnectionDownload

func (*LoadGeneratingConnectionDownload) Client 

func (lgd *LoadGeneratingConnectionDownload) Client() *http.Client

func (*LoadGeneratingConnectionDownload) ClientId 

func (lgd *LoadGeneratingConnectionDownload) ClientId() uint64

func (*LoadGeneratingConnectionDownload) Direction 

func (lgd *LoadGeneratingConnectionDownload) Direction() LgcDirection

func (*LoadGeneratingConnectionDownload) SetConnectDoneTimeError 

func (lgd *LoadGeneratingConnectionDownload) SetConnectDoneTimeError(
	now time.Time,
	err error,
)

func (*LoadGeneratingConnectionDownload) SetConnectStartTime 

func (lgd *LoadGeneratingConnectionDownload) SetConnectStartTime(
	now time.Time,
)

func (*LoadGeneratingConnectionDownload) SetDnsDoneTimeInfo 

func (lgd *LoadGeneratingConnectionDownload) SetDnsDoneTimeInfo(
	now time.Time,
	dnsDoneInfo httptrace.DNSDoneInfo,
)

func (*LoadGeneratingConnectionDownload) SetDnsStartTimeInfo 

func (lgd *LoadGeneratingConnectionDownload) SetDnsStartTimeInfo(
	now time.Time,
	dnsStartInfo httptrace.DNSStartInfo,
)

func (*LoadGeneratingConnectionDownload) SetGetConnTime 

func (lgd *LoadGeneratingConnectionDownload) SetGetConnTime(now time.Time)

func (*LoadGeneratingConnectionDownload) SetGotConnTimeInfo 

func (lgd *LoadGeneratingConnectionDownload) SetGotConnTimeInfo(
	now time.Time,
	gotConnInfo httptrace.GotConnInfo,
)

func (*LoadGeneratingConnectionDownload) SetHttpResponseReadyTime 

func (lgd *LoadGeneratingConnectionDownload) SetHttpResponseReadyTime(
	now time.Time,
)

func (*LoadGeneratingConnectionDownload) SetHttpWroteRequestTimeInfo 

func (lgd *LoadGeneratingConnectionDownload) SetHttpWroteRequestTimeInfo(
	now time.Time,
	info httptrace.WroteRequestInfo,
)

func (*LoadGeneratingConnectionDownload) SetTLSHandshakeDoneTimeState 

func (lgd *LoadGeneratingConnectionDownload) SetTLSHandshakeDoneTimeState(
	now time.Time,
	connectionState tls.ConnectionState,
)

func (*LoadGeneratingConnectionDownload) SetTLSHandshakeStartTime 

func (lgd *LoadGeneratingConnectionDownload) SetTLSHandshakeStartTime(
	now time.Time,
)

func (*LoadGeneratingConnectionDownload) Start 

func (lgd *LoadGeneratingConnectionDownload) Start(
	parentCtx context.Context,
	debugLevel debug.DebugLevel,
) bool

func (*LoadGeneratingConnectionDownload) Stats 

func (lgd *LoadGeneratingConnectionDownload) Stats() *stats.TraceStats

func (*LoadGeneratingConnectionDownload) Status 

func (lgd *LoadGeneratingConnectionDownload) Status() LgcStatus

func (*LoadGeneratingConnectionDownload) TransferredInInterval 

func (lgd *LoadGeneratingConnectionDownload) TransferredInInterval() (uint64, time.Duration)

func (*LoadGeneratingConnectionDownload) WaitUntilStarted 

func (lgd *LoadGeneratingConnectionDownload) WaitUntilStarted(ctxt context.Context) bool

type LoadGeneratingConnectionUpload 

type LoadGeneratingConnectionUpload struct {
	URL           string
	ConnectToAddr string

	InsecureSkipVerify bool
	KeyLogger          io.Writer
	// contains filtered or unexported fields
}

TODO: All 64-bit fields that are accessed atomically must appear at the top of this struct.

func NewLoadGeneratingConnectionUpload 

func NewLoadGeneratingConnectionUpload(url string, keyLogger io.Writer, connectToAddr string,
	insecureSkipVerify bool, congestionControl *string,
) LoadGeneratingConnectionUpload

func (*LoadGeneratingConnectionUpload) Client 

func (lgu *LoadGeneratingConnectionUpload) Client() *http.Client

func (*LoadGeneratingConnectionUpload) ClientId 

func (lgu *LoadGeneratingConnectionUpload) ClientId() uint64

func (*LoadGeneratingConnectionUpload) Direction 

func (lgd *LoadGeneratingConnectionUpload) Direction() LgcDirection

func (*LoadGeneratingConnectionUpload) SetConnectDoneTimeError 

func (lgu *LoadGeneratingConnectionUpload) SetConnectDoneTimeError(
	now time.Time,
	err error,
)

func (*LoadGeneratingConnectionUpload) SetConnectStartTime 

func (lgu *LoadGeneratingConnectionUpload) SetConnectStartTime(
	now time.Time,
)

func (*LoadGeneratingConnectionUpload) SetDnsDoneTimeInfo 

func (lgu *LoadGeneratingConnectionUpload) SetDnsDoneTimeInfo(
	now time.Time,
	dnsDoneInfo httptrace.DNSDoneInfo,
)

func (*LoadGeneratingConnectionUpload) SetDnsStartTimeInfo 

func (lgu *LoadGeneratingConnectionUpload) SetDnsStartTimeInfo(
	now time.Time,
	dnsStartInfo httptrace.DNSStartInfo,
)

func (*LoadGeneratingConnectionUpload) SetGetConnTime 

func (lgu *LoadGeneratingConnectionUpload) SetGetConnTime(now time.Time)

func (*LoadGeneratingConnectionUpload) SetGotConnTimeInfo 

func (lgu *LoadGeneratingConnectionUpload) SetGotConnTimeInfo(
	now time.Time,
	gotConnInfo httptrace.GotConnInfo,
)

func (*LoadGeneratingConnectionUpload) SetHttpResponseReadyTime 

func (lgu *LoadGeneratingConnectionUpload) SetHttpResponseReadyTime(
	now time.Time,
)

func (*LoadGeneratingConnectionUpload) SetHttpWroteRequestTimeInfo 

func (lgu *LoadGeneratingConnectionUpload) SetHttpWroteRequestTimeInfo(
	now time.Time,
	info httptrace.WroteRequestInfo,
)

func (*LoadGeneratingConnectionUpload) SetTLSHandshakeDoneTimeState 

func (lgu *LoadGeneratingConnectionUpload) SetTLSHandshakeDoneTimeState(
	now time.Time,
	connectionState tls.ConnectionState,
)

func (*LoadGeneratingConnectionUpload) SetTLSHandshakeStartTime 

func (lgu *LoadGeneratingConnectionUpload) SetTLSHandshakeStartTime(
	now time.Time,
)

func (*LoadGeneratingConnectionUpload) Start 

func (lgu *LoadGeneratingConnectionUpload) Start(
	parentCtx context.Context,
	debugLevel debug.DebugLevel,
) bool

func (*LoadGeneratingConnectionUpload) Stats 

func (lgu *LoadGeneratingConnectionUpload) Stats() *stats.TraceStats

func (*LoadGeneratingConnectionUpload) Status 

func (lgu *LoadGeneratingConnectionUpload) Status() LgcStatus

func (*LoadGeneratingConnectionUpload) TransferredInInterval 

func (lgu *LoadGeneratingConnectionUpload) TransferredInInterval() (uint64, time.Duration)

func (*LoadGeneratingConnectionUpload) WaitUntilStarted 

func (lgu *LoadGeneratingConnectionUpload) WaitUntilStarted(ctxt context.Context) bool

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.