README
¶
go-sbus
Pub/Sub
import "github.com/kulikov/go-sbus"
sbus.Sub("my-command-subject", func(msg sbus.Message, log *logrus.Entry) error {
log.Infof("Receive: %v", msg)
return nil
})
sbus.Pub("my-command-subject", map[string]string{"do": "any"})
Request/Reply
import "github.com/kulikov/go-sbus"
sbus.Sub("get-user", func(msg sbus.Message, log *logrus.Entry) error {
sbus.Reply(map[string]string{"name": "dima", "userId": msg.Data["userId"]})
return nil
})
sbus.Request("get-user", map[string]string{"userId":"12345"}, func(msg sbus.Message, log *logrus.Entry) error {
log.Infof("Result: %v", msg)
return nil
})
Documentation
¶
Index ¶
- func Marshal(data interface{}) []byte
- type Message
- type MessageHandler
- type Meta
- type Sbus
- func (s *Sbus) Pub(subject string, data interface{}) error
- func (s *Sbus) PubM(msg Message) error
- func (s *Sbus) Reply(msg Message, response interface{}) error
- func (s *Sbus) Request(subject string, data interface{}, handler MessageHandler, ...) error
- func (s *Sbus) RequestM(msg Message, handler MessageHandler, timeout time.Duration) error
- func (s *Sbus) Sub(subject string, handler MessageHandler)
- type Transport
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
Types ¶
type Message ¶
type Message struct {
Subject string `json:"subject"`
Data json.RawMessage `json:"data,omitempty"`
Meta Meta `json:"meta,omitempty"`
}
type MessageHandler ¶
type Sbus ¶
type Sbus struct {
// contains filtered or unexported fields
}
func (*Sbus) Sub ¶
func (s *Sbus) Sub(subject string, handler MessageHandler)
type Transport ¶
type Transport interface {
Sub(subject string, handler MessageHandler) error
SubOnce(subject string, handler MessageHandler) error
Pub(msg *Message) error
}
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.