synctest

package
v0.5.0-alpha.6 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Jul 31, 2024 License: MIT Imports: 29 Imported by: 0

Documentation

Index

Constants

View Source 
const CounterGeneratorName = "countergenerator"
View Source 
const CounterName = "counter"
View Source 
const PeerGlobalName = "peerglobalpool"
View Source 
const PeerName = "net.peerservice"
View Source 
const RpcName = "rpcserver"

Variables

This section is empty.

Functions

func NewCounterStreamOpener 

func NewCounterStreamOpener() streamopener.StreamOpener

func NewCounterSyncHandler 

func NewCounterSyncHandler() syncdeps.SyncHandler

Types

type Config 

type Config struct {
}

func NewConfig 

func NewConfig() *Config

func (*Config) GetStreamConfig 

func (c *Config) GetStreamConfig() streampool.StreamConfig

func (*Config) Init 

func (c *Config) Init(a *app.App) (err error)

func (*Config) Name 

func (c *Config) Name() (name string)

type ConnProvider 

type ConnProvider struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewConnProvider 

func NewConnProvider() *ConnProvider

func (*ConnProvider) GetConn 

func (c *ConnProvider) GetConn(firstId, secondId string) (conn transport.MultiConn)

type Counter 

type Counter struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewCounter 

func NewCounter(cur, delta int32) *Counter

func (*Counter) Add 

func (c *Counter) Add(val int32)

func (*Counter) CheckComplete 

func (c *Counter) CheckComplete() bool

func (*Counter) DiffCurrentNew 

func (c *Counter) DiffCurrentNew(vals []int32) (toSend, toAsk []int32)

func (*Counter) Dump 

func (c *Counter) Dump() (ret []int32)

func (*Counter) Generate 

func (c *Counter) Generate() (ret int32)

func (*Counter) Init 

func (c *Counter) Init(a *app.App) (err error)

func (*Counter) KnownCounters 

func (c *Counter) KnownCounters() (ret []int32)

func (*Counter) Name 

func (c *Counter) Name() (name string)

type CounterGenerator 

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

func NewCounterGenerator 

func NewCounterGenerator() *CounterGenerator

func (*CounterGenerator) Close 

func (c *CounterGenerator) Close(ctx context.Context) (err error)

func (*CounterGenerator) Init 

func (c *CounterGenerator) Init(a *app.App) (err error)

func (*CounterGenerator) Name 

func (c *CounterGenerator) Name() (name string)

func (*CounterGenerator) Run 

func (c *CounterGenerator) Run(ctx context.Context) (err error)

type CounterPeerManager 

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

func NewCounterPeerManager 

func NewCounterPeerManager() *CounterPeerManager

func (*CounterPeerManager) BroadcastMessage 

func (c *CounterPeerManager) BroadcastMessage(ctx context.Context, msg drpc.Message, streamPool streampool.StreamPool) error

func (*CounterPeerManager) GetNodePeers 

func (c *CounterPeerManager) GetNodePeers(ctx context.Context) (peers []peer.Peer, err error)

func (*CounterPeerManager) GetResponsiblePeers 

func (c *CounterPeerManager) GetResponsiblePeers(ctx context.Context) (peers []peer.Peer, err error)

func (*CounterPeerManager) Init 

func (c *CounterPeerManager) Init(a *app.App) (err error)

func (*CounterPeerManager) Name 

func (c *CounterPeerManager) Name() (name string)

type CounterRequest 

type CounterRequest struct {
	*synctestproto.CounterRequest
	// contains filtered or unexported fields
}

func NewCounterRequest 

func NewCounterRequest(peerId, objectId string, counters []int32) CounterRequest

func (CounterRequest) MsgSize 

func (c CounterRequest) MsgSize() uint64

func (CounterRequest) ObjectId 

func (c CounterRequest) ObjectId() string

func (CounterRequest) PeerId 

func (c CounterRequest) PeerId() string

func (CounterRequest) Proto 

func (c CounterRequest) Proto() (proto.Message, error)

type CounterRequestHandler 

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

func (*CounterRequestHandler) HandleStreamRequest 

func (c *CounterRequestHandler) HandleStreamRequest(ctx context.Context, rq syncdeps.Request, send func(resp proto.Message) error) (syncdeps.Request, error)

type CounterRequestSender 

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

func (*CounterRequestSender) SendStreamRequest 

func (c *CounterRequestSender) SendStreamRequest(ctx context.Context, rq syncdeps.Request, receive func(stream drpc.Stream) error) (err error)

type CounterResponseCollector 

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

func NewCounterResponseCollector 

func NewCounterResponseCollector(counter *Counter) *CounterResponseCollector

func (*CounterResponseCollector) CollectResponse 

func (c *CounterResponseCollector) CollectResponse(ctx context.Context, peerId, objectId string, resp syncdeps.Response) error

func (*CounterResponseCollector) NewResponse 

func (c *CounterResponseCollector) NewResponse() syncdeps.Response

type CounterStreamOpener 

type CounterStreamOpener struct {
}

func (*CounterStreamOpener) Init 

func (c *CounterStreamOpener) Init(a *app.App) (err error)

func (*CounterStreamOpener) Name 

func (c *CounterStreamOpener) Name() (name string)

func (*CounterStreamOpener) OpenStream 

func (c *CounterStreamOpener) OpenStream(ctx context.Context, p peer.Peer) (stream drpc.Stream, tags []string, err error)

type CounterSyncHandler 

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

func (*CounterSyncHandler) ApplyRequest 

func (c *CounterSyncHandler) ApplyRequest(ctx context.Context, rq syncdeps.Request, requestSender syncdeps.RequestSender) error

func (*CounterSyncHandler) HandleDeprecatedObjectSync 

func (c *CounterSyncHandler) HandleDeprecatedObjectSync(ctx context.Context, req *spacesyncproto.ObjectSyncMessage) (resp *spacesyncproto.ObjectSyncMessage, err error)

func (*CounterSyncHandler) HandleHeadUpdate 

func (c *CounterSyncHandler) HandleHeadUpdate(ctx context.Context, headUpdate drpc.Message) (syncdeps.Request, error)

func (*CounterSyncHandler) HandleStreamRequest 

func (c *CounterSyncHandler) HandleStreamRequest(ctx context.Context, rq syncdeps.Request, updater syncdeps.QueueSizeUpdater, send func(resp proto.Message) error) (syncdeps.Request, error)

func (*CounterSyncHandler) Init 

func (c *CounterSyncHandler) Init(a *app.App) (err error)

func (*CounterSyncHandler) Name 

func (c *CounterSyncHandler) Name() (name string)

func (*CounterSyncHandler) NewMessage 

func (c *CounterSyncHandler) NewMessage() drpc.Message

func (*CounterSyncHandler) SendStreamRequest 

func (c *CounterSyncHandler) SendStreamRequest(ctx context.Context, rq syncdeps.Request, receive func(stream drpc.Stream) error) (err error)

func (*CounterSyncHandler) TryAddMessage 

func (c *CounterSyncHandler) TryAddMessage(ctx context.Context, id string, msg multiqueue.Sizeable, q *mb.MB[multiqueue.Sizeable]) error

type CounterUpdate 

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

func (*CounterUpdate) ProtoMessage 

func (c *CounterUpdate) ProtoMessage() (proto.Message, error)

func (*CounterUpdate) SetProtoMessage 

func (c *CounterUpdate) SetProtoMessage(message proto.Message) error

type CounterUpdateHandler 

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

func (*CounterUpdateHandler) HandleHeadUpdate 

func (c *CounterUpdateHandler) HandleHeadUpdate(ctx context.Context, headUpdate drpc.Message) (syncdeps.Request, error)

type PeerGlobalPool 

type PeerGlobalPool struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPeerGlobalPool 

func NewPeerGlobalPool(peerIds []string) *PeerGlobalPool

func (*PeerGlobalPool) AddCtrl 

func (p *PeerGlobalPool) AddCtrl(peerId string, addCtrl connCtrl)

func (*PeerGlobalPool) GetPeer 

func (p *PeerGlobalPool) GetPeer(id string) (peer.Peer, error)

func (*PeerGlobalPool) GetPeerIds 

func (p *PeerGlobalPool) GetPeerIds() (peerIds []string)

func (*PeerGlobalPool) Init 

func (p *PeerGlobalPool) Init(a *app.App) (err error)

func (*PeerGlobalPool) MakePeers 

func (p *PeerGlobalPool) MakePeers()

func (*PeerGlobalPool) Name 

func (p *PeerGlobalPool) Name() (name string)

type PeerProvider 

type PeerProvider struct {
	sync.Mutex
	// contains filtered or unexported fields
}

func NewPeerProvider 

func NewPeerProvider(myPeer string) *PeerProvider

func (*PeerProvider) Close 

func (c *PeerProvider) Close(ctx context.Context) (err error)

func (*PeerProvider) Dial 

func (c *PeerProvider) Dial(ctx context.Context, peerId string) (pr peer.Peer, err error)

func (*PeerProvider) GetPeer 

func (c *PeerProvider) GetPeer(peerId string) (pr peer.Peer, err error)

func (*PeerProvider) GetPeerIds 

func (c *PeerProvider) GetPeerIds() (peerIds []string)

func (*PeerProvider) Init 

func (c *PeerProvider) Init(a *app.App) (err error)

func (*PeerProvider) Name 

func (c *PeerProvider) Name() (name string)

func (*PeerProvider) Run 

func (c *PeerProvider) Run(ctx context.Context) (err error)

type RpcServer 

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

func NewRpcServer 

func NewRpcServer() *RpcServer

func (*RpcServer) CounterStream 

func (r *RpcServer) CounterStream(stream synctestproto.DRPCCounterSync_CounterStreamStream) error

func (*RpcServer) CounterStreamRequest 

func (r *RpcServer) CounterStreamRequest(request *synctestproto.CounterRequest, stream synctestproto.DRPCCounterSync_CounterStreamRequestStream) error

func (*RpcServer) Init 

func (r *RpcServer) Init(a *app.App) (err error)

func (*RpcServer) Name 

func (r *RpcServer) Name() (name string)

type SyncApp 

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

type SyncService 

type SyncService interface {
	app.Component
	HandleMessage(ctx context.Context, peerId string, msg drpc.Message) error
	HandleStreamRequest(ctx context.Context, req syncdeps.Request, stream drpc.Stream) error
	QueueRequest(ctx context.Context, rq syncdeps.Request) error
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.