piping_util

Documentation

Index

• Constants
• func DuplexConnect(httpClient *http.Client, headers []KeyValue, uploadUrl, downloadUrl string) (*pipingDuplex, error)
• func DuplexConnectWithHandlers(post postHandler, get getHandler) (*pipingDuplex, error)
• func HandleDuplex(httpClient *http.Client, duplex io.ReadWriteCloser, headers []KeyValue, ...) error
• func PipingGet(httpClient *http.Client, headers []KeyValue, downloadUrl string) (*http.Response, error)
• func PipingGetWithContext(ctx context.Context, httpClient *http.Client, headers []KeyValue, ...) (*http.Response, error)
• func PipingSend(httpClient *http.Client, headers []KeyValue, uploadUrl string, ...) (*http.Response, error)
• func PipingSendWithContext(ctx context.Context, httpClient *http.Client, headers []KeyValue, ...) (*http.Response, error)
• type KeyValue
  • func ParseKeyValueStrings(strKeyValues []string) ([]KeyValue, error)

Constants

const (
	CipherTypeOpenpgp          string = "openpgp"
	CipherTypeAesCtr                  = "aes-ctr"
	CipherTypeOpensslAes128Ctr        = "openssl-aes-128-ctr"
	CipherTypeOpensslAes256Ctr        = "openssl-aes-256-ctr"
)

Functions

func DuplexConnect

func DuplexConnect(httpClient *http.Client, headers []KeyValue, uploadUrl, downloadUrl string) (*pipingDuplex, error)

func DuplexConnectWithHandlers

func DuplexConnectWithHandlers(post postHandler, get getHandler) (*pipingDuplex, error)

func HandleDuplex

func HandleDuplex(httpClient *http.Client, duplex io.ReadWriteCloser, headers []KeyValue, uploadUrl string, downloadUrl string, downloadBufSize uint, arriveCh chan<- struct{}, showProgress bool, makeProgressMessage func(progress *io_progress.IOProgress) string) error

NOTE: duplex is usually conn

func PipingGet

func PipingGet(httpClient *http.Client, headers []KeyValue, downloadUrl string) (*http.Response, error)

func PipingGetWithContext

func PipingGetWithContext(ctx context.Context, httpClient *http.Client, headers []KeyValue, downloadUrl string) (*http.Response, error)

func PipingSend

func PipingSend(httpClient *http.Client, headers []KeyValue, uploadUrl string, reader io.Reader) (*http.Response, error)

func PipingSendWithContext

func PipingSendWithContext(ctx context.Context, httpClient *http.Client, headers []KeyValue, uploadUrl string, reader io.Reader) (*http.Response, error)

Types

type KeyValue

type KeyValue struct {
	Key   string
	Value string
}

func ParseKeyValueStrings

func ParseKeyValueStrings(strKeyValues []string) ([]KeyValue, error)