rpc

type Caller ¶

type Caller func(string, interface{}) (interface{}, error)

Caller is a function that meets the rpc Call signature.

type MessageHandler ¶

type MessageHandler func(interface{}) (interface{}, error)

type MessageID ¶

type MessageID string

MessageID should be a unique string across the DVID code base. By convention, the package name should be prefixed to the type of session being performed, e.g., "datastore.Push"

type NewSessionHandlerFunc ¶

type NewSessionHandlerFunc func(MessageID) (SessionHandler, error)

NewSessionHandlerFunc is a function that creates new session handlers

type Session ¶

type Session struct {
	sync.WaitGroup
	// contains filtered or unexported fields
}

Session provides ability to send data to remote DVID using multiple RPCs.

func NewSession(addr string, mid MessageID) (Session, error)

func (s *Session) Call() Caller

func (s *Session) Close() error

func (s *Session) ID() SessionID

func (s *Session) StartJob()

func (s *Session) StopJob()

type SessionHandler ¶

type SessionHandler interface {
	ID() SessionID
	Open(SessionID) error
	Close() error
}

SessionHandler has a state, processes incoming messages via a finite state machine, and knows how to terminate itself upon receiving a termination message, calling the rpc package EndSession.

func GetSessionHandler(sid SessionID) (SessionHandler, error)

type SessionID ¶

type SessionID uint64

SessionID uniquely identifies a rpc session.

type Transmit ¶

type Transmit uint8

Transmit describes how data is being transferred from DVID-to-DVID.

const (
	TransmitUnknown Transmit = iota
	TransmitAll              // send all versions to maintain the full DAG
	TransmitBranch           // send versions in ancestor path that are not in local DAG
	TransmitFlatten          // send just the version required and do required copy from earlier versions
)