transport

Documentation

Index

• func GetState(now time.Time) (txTPS, rxTPS float64)
• func Startup(ctx context.Context, wg *sync.WaitGroup)
• func UploadFile(req UploadRequest) (err error)
• type UploadRequest

Functions

func GetState

func GetState(now time.Time) (txTPS, rxTPS float64)

func Startup

func Startup(ctx context.Context, wg *sync.WaitGroup)

func UploadFile

func UploadFile(req UploadRequest) (err error)

Types

type UploadRequest

type UploadRequest struct {
	Path    string `json:"path"`
	BufSize int64  `json:"buf_size"`
	// contains filtered or unexported fields
}