pulsar

README

pulsar-client-go

English | 中文版

Introduction

Tuya pulsar client SDK for Golang

Get Started

Support

You can get support from Tuya with the following methods:

• Tuya Smart Help Center: https://support.tuya.com/en/help
• Technical Support Council: https://iot.tuya.com/council

Documentation

Index

• Constants
• func NewAuthProvider(accessID, accessKey string) *authProvider
• func SetInternalLogLevel(level logrus.Level)
• func TopicForAccessID(accessID string) string
• type AuthProvider
• type Client
  • func NewClient(cfg ClientConfig) Client
• type ClientConfig
• type Consumer
• type ConsumerConfig
• type ConsumerList
  • func (l *ConsumerList) CronFlow()
  • func (l *ConsumerList) ReceiveAndHandle(ctx context.Context, handler PayloadHandler)
  • func (l *ConsumerList) Stop()
• type Message
• type PayloadHandler

Constants

const (
	DefaultFlowPeriodSecond = 30
	DefaultFlowPermit       = 10

	PulsarAddrCN = "pulsar://mqe.tuyacn.com:7285"
	PulsarAddrEU = "pulsar://mqe.tuyaeu.com:7285"
	PulsarAddrUS = "pulsar://mqe.tuyaus.com:7285"
)

Functions

func NewAuthProvider

func NewAuthProvider(accessID, accessKey string) *authProvider

func SetInternalLogLevel

func SetInternalLogLevel(level logrus.Level)

func TopicForAccessID

func TopicForAccessID(accessID string) string

Types

type AuthProvider

type AuthProvider interface {
	AuthMethod() string
	AuthData() []byte
}

type Client

type Client interface {
	NewConsumer(config ConsumerConfig) (Consumer, error)
}

func NewClient

func NewClient(cfg ClientConfig) Client

type ClientConfig

type ClientConfig struct {
	PulsarAddr string
}

type Consumer

type Consumer interface {
	ReceiveAndHandle(ctx context.Context, handler PayloadHandler)
	Stop()
}

type ConsumerConfig

type ConsumerConfig struct {
	Topic string
	Auth  AuthProvider
}

type ConsumerList

type ConsumerList struct {
	FlowPeriodSecond int
	FlowPermit       uint32
	Topic            string
	Stopped          chan struct{}
	// contains filtered or unexported fields
}

func (*ConsumerList) CronFlow

func (l *ConsumerList) CronFlow()

func (*ConsumerList) ReceiveAndHandle

func (l *ConsumerList) ReceiveAndHandle(ctx context.Context, handler PayloadHandler)

func (*ConsumerList) Stop

func (l *ConsumerList) Stop()

type Message

type Message = msg.Message

type PayloadHandler

type PayloadHandler interface {
	HandlePayload(ctx context.Context, msg *Message, payload []byte) error
}