server

type ComplexityRoot struct {
	Asset struct {
		ID func(childComplexity int) int
	}

	Mutation struct {
		CreateAsset           func(childComplexity int, input model.CreateAssetInput) int
		CreateSession         func(childComplexity int, input model.CreateSessionInput) int
		CreateSessionFromJSON func(childComplexity int, input model.CreateSessionJSONInput) int
		TerminateSession      func(childComplexity int, sessionToken string) int
	}

	Query struct {
		SessionStats func(childComplexity int, sessionToken string) int
	}

	Session struct {
		SessionToken func(childComplexity int) int
	}

	SessionStats struct {
		WorkItemsCompleted func(childComplexity int) int
		WorkItemsTotal     func(childComplexity int) int
	}

	Subscription struct {
		LogMessages func(childComplexity int, sessionToken string) int
	}
}

type Config struct {
	Schema     *ast.Schema
	Resolvers  ResolverRoot
	Directives DirectiveRoot
	Complexity ComplexityRoot
}

type DirectiveRoot struct {
}

type MutationResolver interface {
	CreateSession(ctx context.Context, input model.CreateSessionInput) (*model.Session, error)
	CreateSessionFromJSON(ctx context.Context, input model.CreateSessionJSONInput) (*model.Session, error)
	CreateAsset(ctx context.Context, input model.CreateAssetInput) (*model.Asset, error)
	TerminateSession(ctx context.Context, sessionToken string) (*bool, error)
}

type QueryResolver interface {
	SessionStats(ctx context.Context, sessionToken string) (*model.SessionStats, error)
}

type Resolver struct {
	Log        *slog.Logger
	Manager    et.SessionManager
	Dispatcher et.Dispatcher
}

type ResolverRoot interface {
	Mutation() MutationResolver
	Query() QueryResolver
	Subscription() SubscriptionResolver
}

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

type SubscriptionResolver interface {
	LogMessages(ctx context.Context, sessionToken string) (<-chan *string, error)
}