replication

Documentation

Index

• func NewPeerId() (string, error)
• func NewWorker(self *Self, peers *Peers, init chan<- struct{})
• type Client
  • func (c Client) SetSession(sess session.Stamped)
• type Peers
  • func NewPeers() *Peers
• type Self
  • func NewSelf(id string, sessStore session.Store) *Self
• type Server
  • 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

Functions

func NewPeerId

func NewPeerId() (string, error)

func NewWorker

func NewWorker(self *Self, peers *Peers, init chan<- struct{})

Types

type Client

type Client struct {
	Self  *Self
	Peers *Peers
}

func (Client) SetSession

func (c Client) SetSession(sess session.Stamped)

type Peers

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

func NewPeers

func NewPeers() *Peers

type Self

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

func NewSelf

func NewSelf(id string, sessStore session.Store) *Self

type Server

type Server struct {
	api.UnimplementedReplicationServer
	Self  *Self
	Peers *Peers
}

func (Server) Handshake

func (s Server) Handshake(ctx context.Context, req *api.HandshakeRequest) (*api.HandshakeResponse, error)

func (Server) SetSession

func (s Server) SetSession(ctx context.Context, req *api.SetSessionRequest) (*api.SetSessionResponse, error)

func (Server) StreamSessions

func (s Server) StreamSessions(req *api.StreamSessionsRequest, stream api.Replication_StreamSessionsServer) error