transport

Documentation

Overview

File upload by Elkeid

Index

• Variables
• func Startup(ctx context.Context, wg *sync.WaitGroup)
• func TaskError(token string, msg string)
• func TaskSuccess(token string, msg string)
• func UploadFile(req UploadRequest) (err error)
• type Transfer
  • func NewTransfer() *Transfer
  • func (t *Transfer) GetState(now time.Time) (txTPS, rxTPS float64)
  • func (t *Transfer) Receive(client proto.Transfer_TransferClient) (err error)
  • func (t *Transfer) Send(client proto.Transfer_TransferClient) (err error)
  • func (t *Transfer) Transmission(rec *proto.Record, important bool) (err error)
  • func (t *Transfer) TransmissionSDK(rec protocol.ProtoType, important bool) (err error)
• type UploadRequest

Variables

var (
	ErrBufferOverflow = errors.New("buffer overflow")
	ErrAgentDataType  = errors.New("agent datatype is not support")
)

var (
	PluginTaskChan   = make(chan *proto.Task)
	PluginConfigChan = make(chan map[string]*proto.Config)
)

The channel to dispatch to plugin

var Trans = NewTransfer()

Functions

func Startup

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

retries here, and some bugs

func TaskError

func TaskError(token string, msg string)

func TaskSuccess

func TaskSuccess(token string, msg string)

func UploadFile

func UploadFile(req UploadRequest) (err error)

Types

type Transfer

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

func NewTransfer

func NewTransfer() *Transfer

func (*Transfer) GetState

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

func (*Transfer) Receive

func (t *Transfer) Receive(client proto.Transfer_TransferClient) (err error)

func (*Transfer) Send

func (t *Transfer) Send(client proto.Transfer_TransferClient) (err error)

Send the record from buffer

func (*Transfer) Transmission

func (t *Transfer) Transmission(rec *proto.Record, important bool) (err error)

Save the record to the buffer, control the buffer

func (*Transfer) TransmissionSDK

func (t *Transfer) TransmissionSDK(rec protocol.ProtoType, important bool) (err error)

TransmissionSDK is an wrapper to satisfy the SDK interface

type UploadRequest

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