transporter

Documentation

Index

• Constants
• Variables
• type Channel
• type DaemonCmd
• type Event
• type PayloadDiscovery
• type PayloadMessage
  • func NewPayloadMessage(data any) PayloadMessage
  • func (pa *PayloadMessage) DataBytes(data any) ([]byte, error)
  • func (pa *PayloadMessage) JSON() ([]byte, error)
• type PubDaemon
  • func NewPubDaemon(channel Channel, redisClient *redis.Client) PubDaemon
  • func (pd *PubDaemon) Start()
  • func (pd *PubDaemon) Stop()
• type Redis
  • func NewRedis(nodeID types.NodeID, configRedis *config.RedisTransporter) (*Redis, error)
  • func (r *Redis) Connect() error
  • func (r *Redis) Disconnect() error
  • func (r *Redis) Send(channel Channel, payload []byte) error
  • func (r *Redis) Subscribe(channel Channel, callback func(payload []byte)) error
• type SubDaemon
  • func NewSubDaemon(nodeID types.NodeID, channel Channel, redisSub *redis.PubSub) SubDaemon
  • func (sd *SubDaemon) OutChan() chan []byte
  • func (sd *SubDaemon) Start(callback func(payload []byte))
  • func (sd *SubDaemon) Stop()
• type Tcp
  • func New() *Tcp
• type Transporter

Constants

const (
	RandomDelivery types.DeliveryMethod = "random"
)

Variables

var (
	ErrInvalidDeliveryMethod = errors.New("Error: invalid delivery method..")
)

Types

type Channel

type Channel string

const (
	ChanPrefix                  = "bn_"
	ChanDiscovery       Channel = ChanPrefix + "discovery"
	ChanMessage         Channel = ChanPrefix + "msg"
	ChanMessageResponse Channel = ChanPrefix + "msg_res"
	ChanStorage         Channel = ChanPrefix + "storage"
)

type DaemonCmd

type DaemonCmd uint

const (
	DaemonStop DaemonCmd = iota
	DaemonStart
)

type Event

type Event uint

const (
	EventConnected Event = iota + 1
	EventDisconnected
	EventHeartbeat
)

type PayloadDiscovery

type PayloadDiscovery struct {
	Blocks map[types.BlockName][]types.ActionName `json:"blocks"`
	Event  Event                                  `json:"event"`
}

type PayloadMessage

type PayloadMessage struct {
	Data any `json:"data"`
}

func NewPayloadMessage

func NewPayloadMessage(data any) PayloadMessage

func (*PayloadMessage) DataBytes

func (pa *PayloadMessage) DataBytes(data any) ([]byte, error)

func (*PayloadMessage) JSON

func (pa *PayloadMessage) JSON() ([]byte, error)

type PubDaemon

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

func NewPubDaemon

func NewPubDaemon(channel Channel, redisClient *redis.Client) PubDaemon

func (*PubDaemon) Start

func (pd *PubDaemon) Start()

func (*PubDaemon) Stop

func (pd *PubDaemon) Stop()

type Redis

type Redis struct {
	Transporter
	// contains filtered or unexported fields
}

func NewRedis

func NewRedis(nodeID types.NodeID, configRedis *config.RedisTransporter) (*Redis, error)

func (*Redis) Connect

func (r *Redis) Connect() error

func (*Redis) Disconnect

func (r *Redis) Disconnect() error

func (*Redis) Send

func (r *Redis) Send(channel Channel, payload []byte) error

func (*Redis) Subscribe

func (r *Redis) Subscribe(channel Channel, callback func(payload []byte)) error

type SubDaemon

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

func NewSubDaemon

func NewSubDaemon(nodeID types.NodeID, channel Channel, redisSub *redis.PubSub) SubDaemon

func (*SubDaemon) OutChan

func (sd *SubDaemon) OutChan() chan []byte

func (*SubDaemon) Start

func (sd *SubDaemon) Start(callback func(payload []byte))

func (*SubDaemon) Stop

func (sd *SubDaemon) Stop()

type Tcp

type Tcp struct {
	// transporter.Transporter
	Transporter
}

func New

func New() *Tcp

type Transporter

type Transporter interface {
	Connect() error
	Disconnect() error
	Send(channel Channel, payload []byte) error
	Subscribe(channel Channel, callback func(payload []byte)) error
}