client

package

v0.5.1 Latest Latest Go to latest Published: Feb 25, 2023 License: MIT Imports: 16 Imported by: 0

Details

View Source

const (
	DefaultPort = 8883
)

This section is empty.

func AttachToCmdrCommand(tcp cmdr.OptCmd, opts ...CmdrOpt)

func DefaultCmdrCommandAction(cmd *cmdr.Command, args []string, mainLoop MainLoop, prefixPrefix string, opts ...Opt) (err error)

func DefaultCommandAction(config *base.Config, mainLoop MainLoop, opts ...Opt) (err error)

func New(udpMode bool, config *base.Config, opts ...Opt) error

type BuildPackageFunc func(i, threadId int, destAddr string) []byte

type CmdrOpt func(*builder)

func WithCmdrClientBuildPackageFunc(fn BuildPackageFunc) CmdrOpt

func WithCmdrClientOptions(opts ...Opt) CmdrOpt

func WithCmdrClientProtocolInterceptor(pic protocol.ClientInterceptor) CmdrOpt

func WithCmdrCommandAction(action CommandAction) CmdrOpt

func WithCmdrInteractiveCommand(enabled bool) CmdrOpt

func WithCmdrMainLoop(mainLoop MainLoop) CmdrOpt

func WithCmdrNil() CmdrOpt

func WithCmdrPort(port int) CmdrOpt

func WithCmdrPrefixPrefix(prefixPrefix string) CmdrOpt

func WithCmdrUDPMode(mode bool) CmdrOpt

type CommandAction func(cmd *cmdr.Command, args []string, mainLoop MainLoop, prefixPrefix string, opts ...Opt) (err error)

type MainLoop func(ctx context.Context, conn base.Conn, done chan bool, config *base.Config)

type MainLoopHolder interface {
	MainLoop(ctx context.Context, conn base.Conn, done chan bool, config *base.Config)
}

type Opt func(obj *clientObj)

func WithClientBuildPackageFunc(fn BuildPackageFunc) Opt

func WithClientMainLoop(mainLoop MainLoop) Opt

func WithClientPrefixPrefix(prefixPrefix string) Opt

func WithClientProtocolInterceptor(pic protocol.ClientInterceptor) Opt

func WithClientUDPMode(udpMode bool) Opt