replicator

package

v0.0.8 Latest Latest Go to latest Published: Apr 22, 2025 License: AGPL-3.0-or-later Imports: 12 Imported by: 0

Details

This section is empty.

This section is empty.

This section is empty.

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

Actor is responsible for managing the replicator.

func StartActor(ctx context.Context, params StartActorParams) *Actor

StartActor starts a new replicator actor.

The channel exposed by [C] must be consumed by the caller.

func (a *Actor) C() <-chan State

C returns a channel that will receive the current state of the replicator. The channel is never closed.

func (a *Actor) Close() error

Close closes the actor.

func (a *Actor) StartDestination(url string)

StartDestination starts a destination stream.

func (a *Actor) StopDestination(url string)

StopDestination stops a destination stream.

type StartActorParams struct {
	SourceURL       string
	ChanSize        int
	ContainerClient *container.Client
	Logger          *slog.Logger
}

StartActorParams contains the parameters for starting a new replicator actor.

type State struct {
	URL       string
	Container domain.Container
	Status    domain.DestinationStatus
}

State is the state of a single destination from the point of view of the replicator.