drpcmanager

README

package drpcmanager

import "storj.io/drpc/drpcmanager"

package drpcmanager reads packets from a transport to make streams.

Usage

type Manager

type Manager struct {
}

func New

func New(tr drpc.Transport, srv Server) *Manager

func (*Manager) Close

func (m *Manager) Close() (err error)

func (*Manager) DoneSig

func (m *Manager) DoneSig() *drpcsignal.Signal

func (*Manager) NewStream

func (m *Manager) NewStream(ctx context.Context, sid uint64) (*drpcstream.Stream, error)

type Server

type Server interface {
	HandleRPC(stream *drpcstream.Stream, rpc string) error
}

Documentation

Overview

package drpcmanager reads packets from a transport to make streams.

Index

• type Manager
  • func New(tr drpc.Transport, srv Server) *Manager
  • func (m *Manager) Close() (err error)
  • func (m *Manager) DoneSig() *drpcsignal.Signal
  • func (m *Manager) NewStream(ctx context.Context, sid uint64) (*drpcstream.Stream, error)
• type Server

Types

type Manager

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

func New

func New(tr drpc.Transport, srv Server) *Manager

func (*Manager) Close

func (m *Manager) Close() (err error)

func (*Manager) DoneSig

func (m *Manager) DoneSig() *drpcsignal.Signal

func (*Manager) NewStream

func (m *Manager) NewStream(ctx context.Context, sid uint64) (*drpcstream.Stream, error)

type Server

type Server interface {
	HandleRPC(stream *drpcstream.Stream, rpc string) error
}