sync

Documentation

Index

• type ExitLoopError
  • func (e *ExitLoopError) Error() string
• type NodeRegistration
• type SyncServer
  • func NewSyncServer(ctx context.Context, log *zap.Logger, nodeRegistry registry.NodeRegistry, ...) (*SyncServer, error)
  • func (s *SyncServer) Close()

Types

type ExitLoopError

type ExitLoopError struct {
	Message string
}

func (*ExitLoopError) Error

func (e *ExitLoopError) Error() string

type NodeRegistration

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

type SyncServer

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

func NewSyncServer

func NewSyncServer(
	ctx context.Context,
	log *zap.Logger,
	nodeRegistry registry.NodeRegistry,
	registrant *registrant.Registrant,
	store *sql.DB,
) (*SyncServer, error)

func (*SyncServer) Close

func (s *SyncServer) Close()