tinyiotserver

package module

Go to main page

Versions in this module

v1

v1.1.1

Mar 2, 2023

Changes in this version

type Message

+ func (m *Message) IsEmpty() bool

+ type MsgHandlerSelector interface

+ DefineProcessorInTaskChan func() (processorInTaskChanIndex []int)

+ SelectInTaskChanIndex func(topic string, payload []byte) (inTaskChanIndex int)

type ServerOption

+ func WithMsgHandlerSelector(msgHandlerSelector MsgHandlerSelector) ServerOption

v1.1.0

Feb 3, 2023

Changes in this version

type Client

+ func NewUnixClient(serverAddress string, clientId uint32) (Client, error)

+ QueryStreamGroup func(topic string, payload []byte) (receive func() (*common.Msg, error), err error)

+ SetTimeOut func(timeout time.Duration)

type Message

+ No int64

type MessageHandler

+ OnReceive func(requestMsg *Message) (newMessage *Message)

+ OnResponse func(responseMsg *Message, requestMsg *Message) (replyToClientMsg *Message)

+ type MsgHandlerAdapter struct

+ func (h MsgHandlerAdapter) OnResponse(responseMsg *Message, requestMsg *Message) (replyToClientMsg *Message)

type Queue

+ func NewListQueue(maxLen int) Queue

+ func NewOrderQueue(maxLen int) Queue

+ func NewSyncBlockingQueue(q Queue) Queue

+ Size func() int

+ type QueueBroadcastor struct

+ func NewQueueBroadcastor(ctx context.Context, sourceQueue Queue, topic string, ...) *QueueBroadcastor

+ func (qb *QueueBroadcastor) Broadcast(broadcastToTarget func(msg *Message) error, ...) error

type QueueMessageHandler

+ func NewQueueMessageHandler(server *server) *QueueMessageHandler

type Server

+ Close func() error

type ServerOption

+ func WithNetwork(network string) ServerOption

+ type TimeoutReadWriteCloser interface

+ SetReadTimeout func(timeout time.Duration)

+ SetWriteTimeout func(timeout time.Duration)

+ type TopicQueue struct

+ Topic string

v1.0.0

Sep 21, 2022

Changes in this version

type Client

+ func NewClientByConn(conn io.ReadWriteCloser, clientId uint32) Client

+ QueryStream func(topic string, payload []byte) (receive func() (*common.Msg, error), err error)

+ SubmitWithAsyncCallback func(topic string, payload []byte, expireAfterNowMillis uint32, ...) error

type MessageHandler

+ var DefaultMsgHandler MessageHandler = &defaultMsgHandler{}

type Queue

+ func NewBlockingQueue(q Queue) Queue

+ func NewSyncQueue(q Queue) Queue

+ Wait func() <-chan struct{}

type Server

+ Submit func(msg *common.Msg) (*common.Msg, error)

type ServerOption

+ func WithHeartbeatDuration(heartbeatDuration time.Duration) ServerOption

v0

v0.0.2

Jul 12, 2022

Changes in this version

+ const REQ_AUTH

+ const RES_AUTH

+ type Client interface

+ Auth func(payload []byte) error

+ Close func() error

+ Query func(topic string, payload []byte) (*common.Msg, error)

+ QueryPop func(topic string, payload []byte) (*common.Msg, error)

+ SetSocketTimeout func(socketTimeout time.Duration)

+ Submit func(topic string, payload []byte, expireAfterNowMillis uint32) error

+ SubmitWaitReply func(topic string, payload []byte, expireAfterNowMillis uint32) (*common.Msg, error)

+ func NewClient(serverAddress string, clientId uint32) (Client, error)

+ type HandlerRegistrar interface

+ GetHandlers func(reqType common.MsgType, topic string) []MessageHandler

+ RegisterGlobalPreHandler func(handlers ...MessageHandler)

+ RegisterHandler func(reqType common.MsgType, topic string, handlers ...MessageHandler)

+ type Message struct

+ ExpiredTime time.Time

+ ReceivedTime time.Time

+ func FailMsg(errorInfo string) *Message

+ func ResponseMsg(topic string, payload []byte) *Message

+ func SuccessMsg(payload []byte) *Message

+ func (m *Message) Copy() *Message

+ func (m *Message) IsExpired() bool

+ func (m *Message) SetPayload(payload []byte)

+ func (m *Message) SetTopic(topic string)

+ func (msg *Message) String() string

+ type MessageHandler interface

+ Handle func(message *Message) (newMessage *Message)

+ var QueryMsgHandler MessageHandler = &queryMsgHandler{}

+ var QueryPopMsgHandler MessageHandler = &queryPopMsgHandler{}

+ var SuccessResponseMsgHandler MessageHandler = &successResponseMsgHandler{}

+ func NewSimpleAuthMsgHandler(authorizeLogic func(msg *Message) bool, authCodeGen func(msg *Message) string) MessageHandler

+ type NetListenHandler struct

+ func (h NetListenHandler) Handle(inTask flowprocess.Task, dispatch func(outTask flowprocess.Task)) (err error)

+ type ProcessMessageHandler struct

+ func (h ProcessMessageHandler) Handle(inTask flowprocess.Task, dispatch func(outTask flowprocess.Task)) error

+ type Queue struct

+ func NewQueue(maxLen int) *Queue

+ func (queue *Queue) Back() (Message, bool)

+ func (queue *Queue) Front() (Message, bool)

+ func (queue *Queue) Len() int

+ func (queue *Queue) PopBack() (Message, bool)

+ func (queue *Queue) PopFront() (Message, bool)

+ func (queue *Queue) PushBack(msg Message)

+ func (queue *Queue) PushFront(msg Message)

+ type QueueMessageHandler struct

+ func (h QueueMessageHandler) Handle(inTask flowprocess.Task, dispatch func(outTask flowprocess.Task)) error

+ type ReadMessageHandler struct

+ func (h ReadMessageHandler) Handle(inTask flowprocess.Task, dispatch func(outTask flowprocess.Task)) (err error)

+ type Server interface

+ Start func() error

+ Stop func() error

+ func NewServer(address string, options ...ServerOption) Server

+ type ServerOption func(s *server)

+ func WithDefaultQueueSize(defaultQueueSize int) ServerOption

+ func WithSocketWriteDeadline(socketWriteDeadline time.Duration) ServerOption

+ func WithTopicQueueSize(topicQueueSize map[string]int) ServerOption

v0.0.1

Jun 13, 2022

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL