sync

package
v0.0.1 Latest Latest
Warning

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

Go to latest
Published: May 25, 2026 License: MIT Imports: 13 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var Component = &component.Component{
	Dependencies: component.Components{
		grpc.Component,
		grpc2.Component,
		manager.Component,
	},
	Init: component.StepFunc(func(container container.Container) error {
		return container.Provide(NewService)
	}),
	PreExecute: component.StepFunc(func(container container.Container) error {
		return container.Invoke(func(s *Service, grpc *grpc.Server) {
			service.RegisterSyncServer(grpc.GetGRPC(), s)
		})
	}),
}

Functions

This section is empty.

Types

type Service

type Service struct {
	service.UnimplementedSyncServer
	// contains filtered or unexported fields
}

func NewService

func NewService(
	manager cluster.Manager,
	delayConfig *managerConfig.Delay,
	grpcConfig *grpcClientConfig.Config,
	logger logger.Logger,
	closer closer.Closer,
) *Service

func (*Service) Hosts

func (s *Service) Hosts(_ context.Context, sync *model.Sync) (*model.Sync, error)

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL