hbucast

Documentation

Overview

Package hbucast implement a hb unicast driver

Example:

msgC := make(chan *hbtype.Msg) // a global *hbtype.Msg chan for received Msg
n := clusterhb.New()
registeredDataC := make([]chan []byte, 0) // list send data chan where tx can send data
for _, h := range n.Hbs() {
	h.Configure(ctx) // configure tx and rx
	if err := h.Rx().Start(data.Cmd(), msgC); err != nil {
		return err
	}
	localDataC := make(chan []byte) // []byte chan dedicated to this tx
	if err := h.Tx().Start(data.Cmd(), localDataC); err != nil {
		return err
	}
	registeredDataC = append(registeredDataC, localDataC)
}

Index

• func New() hbcfg.Confer
• type T
  • func (t *T) Configure(ctx context.Context)

Functions

func New

func New() hbcfg.Confer

Types

type T

type T struct {
	hbcfg.T
}

func (*T) Configure

func (t *T) Configure(ctx context.Context)

Configure implements the Configure function of Confer interface for T