ipc

Documentation

Index

• func Read(ipsid string, ipcid string, msg string) (string, error)
• type IPC
  • func NewIPCServer() (*IPC, error)
  • func NewListenerIPCServer(l net.Listener, id string) (*IPC, error)
  • func (p *IPC) Accept() error
  • func (p *IPC) AppendConsumer(ipcc *IPCConsumer)
  • func (p *IPC) Close() error
  • func (p *IPC) GetUUID() string
  • func (p *IPC) IsClosed() bool
  • func (p *IPC) OutConsumer(ipcc *IPCConsumer)
  • func (p *IPC) SetListener(l net.Listener)
• type IPCConsumer
  • func (c *IPCConsumer) ExposeStoreVars(store base.IStore) chan bool
• type PipeData
  • func (d *PipeData) Close() error
  • func (d *PipeData) Resp(r string) error
  • func (d *PipeData) RespClose(r string) error

Functions

func Read

func Read(ipsid string, ipcid string, msg string) (string, error)

Types

type IPC

type IPC struct {
	Errors chan error
	// contains filtered or unexported fields
}

func NewIPCServer

func NewIPCServer() (*IPC, error)

func NewListenerIPCServer

func NewListenerIPCServer(l net.Listener, id string) (*IPC, error)

func (*IPC) Accept

func (p *IPC) Accept() error

func (*IPC) AppendConsumer

func (p *IPC) AppendConsumer(ipcc *IPCConsumer)

func (*IPC) Close

func (p *IPC) Close() error

func (*IPC) GetUUID

func (p *IPC) GetUUID() string

func (*IPC) IsClosed

func (p *IPC) IsClosed() bool

func (*IPC) OutConsumer

func (p *IPC) OutConsumer(ipcc *IPCConsumer)

func (*IPC) SetListener

func (p *IPC) SetListener(l net.Listener)

type IPCConsumer

type IPCConsumer struct {
	ID     string
	Stream chan *PipeData
}

func (*IPCConsumer) ExposeStoreVars

func (c *IPCConsumer) ExposeStoreVars(store base.IStore) chan bool

type PipeData

type PipeData struct {
	IPCSID  string
	IPCCID  string
	COMMAND string
	VARNAME string
	// contains filtered or unexported fields
}

func (*PipeData) Close

func (d *PipeData) Close() error

func (*PipeData) Resp

func (d *PipeData) Resp(r string) error

func (*PipeData) RespClose

func (d *PipeData) RespClose(r string) error