ipc

Documentation

Index

• Variables
• type Config
• type IncomingMessage
  • func (r *IncomingMessage) Data() []byte
  • func (r *IncomingMessage) SetResponse(d []byte, e error)
• type Mode
• type Node
  • func NewNode(ctx context.Context, c Config) (*Node, error)
  • func (n *Node) ErrCh() chan error
  • func (n *Node) ReceiveCh() chan *IncomingMessage
  • func (n *Node) SendCh() chan *OutgoingMessage
• type OutgoingMessage
  • func NewOutgoingMessage(d []byte) *OutgoingMessage
  • func (r *OutgoingMessage) Data() []byte
  • func (r *OutgoingMessage) Response() ([]byte, error)

Variables

var (
	ErrEmptyGroupName = errors.New("empty group name")
)

var (
	ErrHandshake = errors.New("handshake error")
)

Types

type Config

type Config struct {
	GroupName     string
	Mode          Mode
	ReadTimeout   time.Duration
	WriteTimeout  time.Duration
	BufferSize    int
	IgnoreDialErr bool
	EnableDebug   bool
}

type IncomingMessage

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

func (*IncomingMessage) Data

func (r *IncomingMessage) Data() []byte

func (*IncomingMessage) SetResponse

func (r *IncomingMessage) SetResponse(d []byte, e error)

type Mode

type Mode string

const (
	UnknownMode Mode = ""
	MasterOnly  Mode = "master"
	ClientOnly  Mode = "client"
	Dual        Mode = "dual"
)

type Node

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

func NewNode

func NewNode(
	ctx context.Context,
	c Config,
) (*Node, error)

func (*Node) ErrCh

func (n *Node) ErrCh() chan error

func (*Node) ReceiveCh

func (n *Node) ReceiveCh() chan *IncomingMessage

func (*Node) SendCh

func (n *Node) SendCh() chan *OutgoingMessage

type OutgoingMessage

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

func NewOutgoingMessage

func NewOutgoingMessage(d []byte) *OutgoingMessage

func (*OutgoingMessage) Data

func (r *OutgoingMessage) Data() []byte

func (*OutgoingMessage) Response

func (r *OutgoingMessage) Response() ([]byte, error)