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) *Manager

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) NewClientStream

func (m *Manager) NewClientStream(ctx context.Context) (stream *drpcstream.Stream, err error)

func (*Manager) NewServerStream

func (m *Manager) NewServerStream(ctx context.Context) (stream *drpcstream.Stream, rpc string, err error)

Documentation

Overview

package drpcmanager reads packets from a transport to make streams.

Index

• type Manager
  • func New(tr drpc.Transport) *Manager
  • func (m *Manager) Close() error
  • func (m *Manager) NewClientStream(ctx context.Context) (stream *drpcstream.Stream, err error)
  • func (m *Manager) NewServerStream(ctx context.Context) (stream *drpcstream.Stream, rpc string, err error)

Types

type Manager

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

func New

func New(tr drpc.Transport) *Manager

func (*Manager) Close

func (m *Manager) Close() error

func (*Manager) NewClientStream

func (m *Manager) NewClientStream(ctx context.Context) (stream *drpcstream.Stream, err error)

func (*Manager) NewServerStream

func (m *Manager) NewServerStream(ctx context.Context) (stream *drpcstream.Stream, rpc string, err error)