transport_pipe

Documentation

Index

• Constants
• func NewPipeTransport(opts ...meepo_interface.NewTransportOption) (meepo_interface.Transport, error)
• type PipeChannel
  • func (c *PipeChannel) Close(context.Context) (err error)
  • func (c *PipeChannel) Conn() meepo_interface.Conn
  • func (c *PipeChannel) GetLogger() logging.Logger
  • func (c *PipeChannel) ID() uint16
  • func (c *PipeChannel) IsSink() bool
  • func (c *PipeChannel) IsSource() bool
  • func (c *PipeChannel) Mode() string
  • func (c *PipeChannel) SinkAddr() net.Addr
  • func (c *PipeChannel) State() meepo_interface.ChannelState
  • func (c *PipeChannel) WaitReady() error
• type PipeTransport
  • func (t *PipeTransport) Addr() meepo_interface.Addr
  • func (t *PipeTransport) Call(ctx context.Context, method string, req meepo_interface.CallRequest, ...) (err error)
  • func (t *PipeTransport) Close(ctx context.Context) error
  • func (t *PipeTransport) GetChannel(ctx context.Context, id uint16) (meepo_interface.Channel, error)
  • func (t *PipeTransport) GetLogger() logging.Logger
  • func (t *PipeTransport) GetRawLogger() logging.Logger
  • func (t *PipeTransport) Handle(method string, fn meepo_interface.HandleFunc, ...)
  • func (t *PipeTransport) ListChannels(ctx context.Context, opts ...meepo_interface.ListChannelsOption) ([]meepo_interface.Channel, error)
  • func (t *PipeTransport) NewChannel(ctx context.Context, network string, address string, ...) (meepo_interface.Channel, error)
  • func (t *PipeTransport) Session() string
  • func (t *PipeTransport) State() meepo_interface.TransportState
  • func (t *PipeTransport) WaitReady() error

Constants

const (
	TRANSPORT_PIPE = "pipe"
)

Functions

func NewPipeTransport

func NewPipeTransport(opts ...meepo_interface.NewTransportOption) (meepo_interface.Transport, error)

Types

type PipeChannel

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

func (*PipeChannel) Close

func (c *PipeChannel) Close(context.Context) (err error)

func (*PipeChannel) Conn

func (c *PipeChannel) Conn() meepo_interface.Conn

func (*PipeChannel) GetLogger

func (c *PipeChannel) GetLogger() logging.Logger

func (*PipeChannel) ID

func (c *PipeChannel) ID() uint16

func (*PipeChannel) IsSink

func (c *PipeChannel) IsSink() bool

func (*PipeChannel) IsSource

func (c *PipeChannel) IsSource() bool

func (*PipeChannel) Mode

func (c *PipeChannel) Mode() string

func (*PipeChannel) SinkAddr

func (c *PipeChannel) SinkAddr() net.Addr

func (*PipeChannel) State

func (c *PipeChannel) State() meepo_interface.ChannelState

func (*PipeChannel) WaitReady

func (c *PipeChannel) WaitReady() error

type PipeTransport

type PipeTransport struct {
	transport_core.TransportHooks
	transport_core.ChannelHooks
	// contains filtered or unexported fields
}

func (*PipeTransport) Addr

func (t *PipeTransport) Addr() meepo_interface.Addr

func (*PipeTransport) Call

func (t *PipeTransport) Call(ctx context.Context, method string, req meepo_interface.CallRequest, res meepo_interface.CallResponse, opts ...meepo_interface.CallOption) (err error)

func (*PipeTransport) Close

func (t *PipeTransport) Close(ctx context.Context) error

func (*PipeTransport) GetChannel

func (t *PipeTransport) GetChannel(ctx context.Context, id uint16) (meepo_interface.Channel, error)

func (*PipeTransport) GetLogger

func (t *PipeTransport) GetLogger() logging.Logger

func (*PipeTransport) GetRawLogger

func (t *PipeTransport) GetRawLogger() logging.Logger

func (*PipeTransport) Handle

func (t *PipeTransport) Handle(method string, fn meepo_interface.HandleFunc, opts ...meepo_interface.HandleOption)

func (*PipeTransport) ListChannels

func (t *PipeTransport) ListChannels(ctx context.Context, opts ...meepo_interface.ListChannelsOption) ([]meepo_interface.Channel, error)

func (*PipeTransport) NewChannel

func (t *PipeTransport) NewChannel(ctx context.Context, network string, address string, opts ...meepo_interface.NewChannelOption) (meepo_interface.Channel, error)

func (*PipeTransport) Session

func (t *PipeTransport) Session() string

func (*PipeTransport) State

func (t *PipeTransport) State() meepo_interface.TransportState

func (*PipeTransport) WaitReady

func (t *PipeTransport) WaitReady() error