receiver

package

v0.7.0 Latest Latest Go to latest Published: Dec 6, 2021 License: Apache-2.0 Imports: 21 Imported by: 2

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

View Source

const (
	Connected    = 1
	Disconnected = 2
)

View Source

const (
	// CLIENT is an end user.
	CLIENT = 0
)

View Source

const DataTag uint8 = 0x33

View Source

var (
	DisconnectedPacket = packets.NewControlPacket(packets.Disconnect).(*packets.DisconnectPacket)
)

func ProcessMessage(msg *Message)

type Config struct {
	ServerAddr string `json:"serverAddr"`
	Worker     int    `json:"workerNum"`
	Debug      bool   `json:"debug"`
}

var (
	DefaultConfig *Config
)

type ISourceClient interface {
	GetWriter() ISourceWriter
	Create() yomo.Source
	Close() error
	Retry()
	Init()
}

func NewSourceStream(appName string, zipperAddr string) ISourceClient

type ISourceWriter interface {
	Write(b []byte) (int, error)
}

func NewSourceWriter(w io.Writer) ISourceWriter

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

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

func NewReceiver(config *Config) (*Receiver, error)

func (b *Receiver) CheckConnectAuth(clientID, username, password string) bool

func (b *Receiver) Start(handler func(topic string, payload []byte, writer ISourceWriter) error, sourceStream ISourceClient)

func (b *Receiver) StartClientListening(Tls bool)

func (b *Receiver) SubmitWork(clientId string, msg *Message)

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

func CreateRunner(appName string, zipperAddr string) *Runner

func (b *Runner) Run()

func (b *Runner) WithDebug(debug bool) *Runner

func (b *Runner) WithHandler(handler func(topic string, payload []byte, writer ISourceWriter) error) *Runner

func (b *Runner) WithServerAddr(addr string) *Runner

func (b *Runner) WithStream(stream ISourceClient) *Runner

type SourceError struct {
	Message string `json:"message"`
}

func NewSourceError(message string) *SourceError

func (e *SourceError) Error() string