runner

type RunnerAssociations interface {
	Video() video.VideoService
	Thumbnail() image.ThumbnailService
}

type RunnerService interface {
	// Domain
	First(ctx context.Context, arg params.FirstRunnerParams) (*domain.Runner, error)

	ValidateAuth(ctx context.Context, arg params.ValidateAuthRunnerParams) (bool, *claims.RunnerClaims, error)

	// gRPC
	Auth(ctx context.Context, arg *grpc_runner_v1.AuthRequest) (*grpc_runner_v1.AuthResponse, error)
	Operation(ctx context.Context, runner client.Client, operation *grpc_runner_v1.OperationRequest) error
	Stream(ctx context.Context, runner client.Client, stream *grpc_runner_v1.StreamRequest) error

	// Connection + Leader
	Timeout(anime domain.AnimeBase) error
	Interrupt(anime domain.AnimeBase) error
	Assign(anime domain.AnimeBase, sizeInBytes uint64, address string) (client.Client, error)

	// Connection + State
	Info() []client.Info
	Client(runnerClaims *claims.RunnerClaims) client.Client
	Connect(runnerClaims *claims.RunnerClaims) (client.Client, error)
	ToggleState(runnerClaims *claims.RunnerClaims) (client.State, error)
	Disconnect(runnerClaims *claims.RunnerClaims) error
}