streamhandler

Documentation

Index

• Constants
• type StreamHandler

Constants

const CName = "common.streampool.streamhandler"

Types

type StreamHandler

type StreamHandler interface {
	app.Component
	// OpenStream opens stream with given peer
	OpenStream(ctx context.Context, p peer.Peer) (stream drpc.Stream, tags []string, queueSize int, err error)
	// HandleMessage handles incoming message
	HandleMessage(ctx context.Context, peerId string, msg drpc.Message) (err error)
	// NewReadMessage creates new empty message for unmarshalling into it
	NewReadMessage() drpc.Message
}

StreamHandler handles incoming messages from streams