internal

Documentation

Index

• type Writer
  • func NewWriter(h host.Host) *Writer
  • func (w *Writer) AddStream(id state.Peer, stream network.Stream)
  • func (w *Writer) RemoveStream(id state.Peer)
  • func (w *Writer) Send(ctx context.Context, target state.Peer, msg *pb.Message) error
  • func (w *Writer) SetProtocol(proto protocol.ID)

Types

type Writer

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

func NewWriter

func NewWriter(h host.Host) *Writer

func (*Writer) AddStream

func (w *Writer) AddStream(id state.Peer, stream network.Stream)

func (*Writer) RemoveStream

func (w *Writer) RemoveStream(id state.Peer)

func (*Writer) Send

func (w *Writer) Send(ctx context.Context, target state.Peer, msg *pb.Message) error

func (*Writer) SetProtocol

func (w *Writer) SetProtocol(proto protocol.ID)