utils

Documentation

Index

• Variables
• func AskPassword(prompt string) (string, error)
• func AskYesNo(prompt string) bool
• func ConfigureZstdParams(level, minSizeB, chunkSizeB int)
• func ControlProtocol(base string) string
• func DataProtocol(base string) string
• func DataProtocolZstd(base string) string
• func GetProtocol() string
• func GetUserAgent() string
• func PipeBothWithIdle(a, b io.ReadWriteCloser, idle time.Duration)
• type ZstdDuplex
  • func NewZstdDuplex(base io.ReadWriteCloser) (*ZstdDuplex, error)
  • func (z *ZstdDuplex) Close() error
  • func (z *ZstdDuplex) Read(p []byte) (int, error)
  • func (z *ZstdDuplex) SetInfo(side, service, peer, protocol string) *ZstdDuplex
  • func (z *ZstdDuplex) Write(p []byte) (int, error)

Variables

var ErrPasswordInterrupted = errors.New("password input interrupted")

ErrPasswordInterrupted returned when password input is interrupted by signal.

Functions

func AskPassword

func AskPassword(prompt string) (string, error)

AskPassword read password with no echo

func AskYesNo

func AskYesNo(prompt string) bool

AskYesNoWithCancel behaves like AskYesNo but terminates the program on Ctrl+C.

func ConfigureZstdParams

func ConfigureZstdParams(level, minSizeB, chunkSizeB int)

func ControlProtocol

func ControlProtocol(base string) string

func DataProtocol

func DataProtocol(base string) string

func DataProtocolZstd

func DataProtocolZstd(base string) string

func GetProtocol

func GetProtocol() string

func GetUserAgent

func GetUserAgent() string

func PipeBothWithIdle

func PipeBothWithIdle(a, b io.ReadWriteCloser, idle time.Duration)

PipeBothWithIdle copies data in both directions between a and b. It closes both sides when any direction finishes or when idle timeout elapses.

Types

type ZstdDuplex

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

func NewZstdDuplex

func NewZstdDuplex(base io.ReadWriteCloser) (*ZstdDuplex, error)

func (*ZstdDuplex) Close

func (z *ZstdDuplex) Close() error

func (*ZstdDuplex) Read

func (z *ZstdDuplex) Read(p []byte) (int, error)

func (*ZstdDuplex) SetInfo

func (z *ZstdDuplex) SetInfo(side, service, peer, protocol string) *ZstdDuplex

func (*ZstdDuplex) Write

func (z *ZstdDuplex) Write(p []byte) (int, error)