Versions in this module Expand all Collapse all v0 v0.9.0 Nov 10, 2020 Changes in this version + func NewPeerId() (string, error) + func NewWorker(self *Self, peers *Peers, init chan<- struct{}) + type Client struct + Peers *Peers + Self *Self + func (c Client) SetSession(sess session.Stamped) + type Peers struct + func NewPeers() *Peers + type Self struct + func NewSelf(id string, sessStore session.Store) *Self + type Server struct + Peers *Peers + Self *Self + func (s Server) Handshake(ctx context.Context, req *api.HandshakeRequest) (*api.HandshakeResponse, error) + func (s Server) SetSession(ctx context.Context, req *api.SetSessionRequest) (*api.SetSessionResponse, error) + func (s Server) StreamSessions(req *api.StreamSessionsRequest, stream api.Replication_StreamSessionsServer) error
Go to main page