models

package

Go to main page

Versions in this module

v0

v0.3.1

Feb 9, 2019

v0.3.0

Feb 9, 2019

Changes in this version

+ const KeyDeleted

+ const KeyUpserted

+ type KeysConfig struct

+ Filename string

+ Keys map[string]string

+ func LoadKeysConfigYAML(filename string) (*KeysConfig, error)

+ func (c *KeysConfig) DeleteKey(nodes *NodeManager, subs *pubsub.PubSub, userID string, id string) error

+ func (c *KeysConfig) UpsertKey(nodes *NodeManager, subs *pubsub.PubSub, userID string, input KeyInput) string

+ func (c *KeysConfig) UpsertNodes(nodes *NodeManager, subs *pubsub.PubSub, userID string) error

+ func (c KeysConfig) Save() error

type ModelContext

+ Keys *KeysConfig

type Process

+ Env []string

type Task

+ VariableIDs []string

+ func (t Task) Variables(ctx context.Context, after *string, before *string, first *int, last *int) (VariableConnection, error)

type TaskConfig

+ Variables []VariableConfig

type User

+ KeyIDs []string

+ func (u User) Keys(ctx context.Context, after *string, before *string, first *int, last *int) (KeyConnection, error)

+ type VariableConfig struct

+ Default *string

+ Name string

+ func (c VariableConfig) UpsertNodes(nodes *NodeManager, workspaceSlug string, taskID string, taskName string, ...) string

v0.2.4

Feb 7, 2019

v0.2.3

Feb 7, 2019

v0.2.2

Feb 6, 2019

Changes in this version

type System

+ func (s System) LastMessageID(ctx context.Context) string

v0.2.1

Feb 5, 2019

v0.2.0

Feb 5, 2019

Changes in this version

+ const ProjectUpserted

+ const SourceDeleted

+ const SourceUpserted

+ const TaskUpserted

+ const WorkspaceUpserted

+ type DirectorySource struct

+ Directory string

+ ID string

+ IsLoading bool

+ WorkspaceIDs []string

+ func (DirectorySource) IsNode()

+ func (DirectorySource) IsSource()

+ func (n DirectorySource) GetWorkspaceIDs() []string

+ func (n DirectorySource) Workspaces(ctx context.Context, after *string, before *string, first *int, last *int) (WorkspaceConnection, error)

+ type DirectorySourceConfig struct

+ Directory string

+ ID string

+ type GitSource struct

+ Branch string

+ ID string

+ IsLoading bool

+ Repository string

+ WorkspaceIDs []string

+ func (GitSource) IsNode()

+ func (GitSource) IsSource()

+ func (n GitSource) GetWorkspaceIDs() []string

+ func (n GitSource) IsCloned(ctx context.Context) bool

+ func (n GitSource) Workspaces(ctx context.Context, after *string, before *string, first *int, last *int) (WorkspaceConnection, error)

+ type GitSourceConfig struct

+ Branch string

+ ID string

+ Repository string

type ModelContext

+ GetGitSourcePath ProjectGitSourcePathGetter

+ Sources *SourcesConfig

+ type Node interface

+ GetID func() string

+ IsNode func()

type NodeManager

+ func (n *NodeManager) MustLoadSource(id string) Source

+ type ProjectConfig struct

+ Branch string

+ Description *string

+ Repository string

+ Slug string

+ func (c ProjectConfig) UpsertNodes(nodes *NodeManager, workspaceID, workspaceSlug string) string

+ type ProjectGitSourcePathGetter func(repo, branch string) string

+ type Source interface

+ GetWorkspaceIDs func() []string

+ IsSource func()

+ Workspaces func(ctx context.Context, after *string, before *string, first *int, last *int) (WorkspaceConnection, error)

+ type SourcesConfig struct

+ DirectorySources []DirectorySourceConfig

+ Filename string

+ GitSources []GitSourceConfig

+ func LoadSourcesConfigYAML(filename string) (*SourcesConfig, error)

+ func (c *SourcesConfig) DeleteSource(nodes *NodeManager, subs *pubsub.PubSub, userID string, id string) error

+ func (c *SourcesConfig) UpsertDirectorySource(nodes *NodeManager, subs *pubsub.PubSub, userID string, ...) string

+ func (c *SourcesConfig) UpsertGitSource(nodes *NodeManager, subs *pubsub.PubSub, userID string, input GitSourceInput) string

+ func (c *SourcesConfig) UpsertNodes(nodes *NodeManager, subs *pubsub.PubSub, userID string) error

+ func (c SourcesConfig) Save() error

+ type StepConfig struct

+ Commands []string

+ Projects []string

+ func (c StepConfig) UpsertNodes(nodes *NodeManager, workspaceSlug string, taskID string, taskName string, ...) (string, error)

+ type TaskConfig struct

+ Name string

+ Steps []StepConfig

+ func (c TaskConfig) UpsertNodes(nodes *NodeManager, workspaceID string, workspaceSlug string, ...) (string, error)

type User

+ SourceIDs []string

+ func (u User) Sources(ctx context.Context, after *string, before *string, first *int, last *int) (SourceConnection, error)

+ type WorkspaceConfig struct

+ Description string

+ Name string

+ Notes *string

+ Projects []ProjectConfig

+ Slug string

+ Tasks []TaskConfig

+ func (c WorkspaceConfig) UpsertNodes(nodes *NodeManager) (string, error)

+ type WorkspacesConfig struct

+ Filename string

+ Workspaces []WorkspaceConfig

+ func LoadWorkspacesConfigYAML(filename string) (WorkspacesConfig, error)

+ func (c WorkspacesConfig) UpsertNodes(nodes *NodeManager) ([]string, error)

v0.1.5

Feb 3, 2019

Changes in this version

+ const DateFormat

+ func WithModelContext(ctx context.Context, mc *ModelContext) context.Context

+ type ModelContext struct

+ GetProjectCachePath ProjectCachePathGetter

+ GetProjectPath ProjectPathGetter

+ Jobs *JobManager

+ Log *Logger

+ Nodes *NodeManager

+ PM *ProcessManager

+ Subs *pubsub.PubSub

+ SystemID string

+ ViewerID string

+ func GetModelContext(ctx context.Context) *ModelContext

+ type ProjectCachePathGetter func(workspaceSlug, repo, branch string) string

v0.1.4

Feb 2, 2019

v0.1.3

Feb 1, 2019

v0.1.2

Feb 1, 2019

v0.1.1

Feb 1, 2019

v0.1.0

Feb 1, 2019

Changes in this version

+ const JobMetricsUpdated

+ const JobUpserted

+ const LogEntryAdded

+ const LogMetricsUpdated

+ const ProcessGroupUpserted

+ const ProcessMetricsUpdated

+ const ProcessUpserted

+ const ProjectUpdated

+ const TaskUpdated

+ const WorkspaceUpdated

+ var ErrFirstNegative = errors.New("first cannot be negative")

+ var ErrLastNegative = errors.New("last cannot be negative")

+ var ErrNotFound = errors.New("not found")

+ var ErrNotRunning = errors.New("project isn't running")

+ var ErrNotStopped = errors.New("project isn't stopped")

+ var ErrType = errors.New("wrong type")

+ func CreateLineWriter(write func(ownerID, message string, a ...interface{}) string, ownerID string, ...) io.WriteCloser

+ type Config struct

+ Filename string

+ Workspaces []struct{ ... }

+ func LoadConfigYAML(filename string) (Config, error)

+ func (c Config) CreateNodes(nodes *NodeManager, userID string) error

+ type DateTime time.Time

+ func (d *DateTime) UnmarshalGQL(v interface{}) error

+ func (d DateTime) MarshalGQL(w io.Writer)

+ type Hash string

+ func (h *Hash) UnmarshalGQL(v interface{}) error

+ func (h Hash) MarshalGQL(w io.Writer)

+ type Job struct

+ CreatedAt DateTime

+ ID string

+ Name string

+ OwnerID string

+ Priority JobPriority

+ Status JobStatus

+ UpdatedAt DateTime

+ func (Job) IsNode()

+ func (j Job) Owner(nodes *NodeManager) Node

+ type JobManager struct

+ func NewJobManager(nodes *NodeManager, log *Logger, subs *pubsub.PubSub, concurrency int, ...) *JobManager

+ func (j *JobManager) Add(name string, ownerID string, priority JobPriority, ...) string

+ func (j *JobManager) Stop(id string) error

+ func (j *JobManager) Work(ctx context.Context) error

+ type LogEntry struct

+ CreatedAt DateTime

+ ID string

+ Level LogLevel

+ Message string

+ OwnerID string

+ func (LogEntry) IsNode()

+ func (l LogEntry) Owner(nodes *NodeManager) Node

+ type Logger struct

+ func NewLogger(nodes *NodeManager, subs *pubsub.PubSub, cap int, level LogLevel, ...) *Logger

+ func (l *Logger) Add(level LogLevel, ownerID string, message string) (string, error)

+ func (l *Logger) Debug(message string, a ...interface{}) string

+ func (l *Logger) DebugWithOwner(ownerID string, message string, a ...interface{}) string

+ func (l *Logger) Error(message string, a ...interface{}) string

+ func (l *Logger) ErrorWithOwner(ownerID string, message string, a ...interface{}) string

+ func (l *Logger) Info(message string, a ...interface{}) string

+ func (l *Logger) InfoWithOwner(ownerID string, message string, a ...interface{}) string

+ func (l *Logger) Warning(message string, a ...interface{}) string

+ func (l *Logger) WarningWithOwner(ownerID string, message string, a ...interface{}) string

+ type NodeManager struct

+ func (n *NodeManager) Load(id string) (Node, bool)

+ func (n *NodeManager) Lock(ids ...string)

+ func (n *NodeManager) MustLoad(id string) Node

+ func (n *NodeManager) RLock(ids ...string)

+ func (n *NodeManager) RUnlock(ids ...string)

+ func (n *NodeManager) Unlock(ids ...string)

+ type Process struct

+ Command string

+ ID string

+ ProcessGroupID string

+ ProjectID string

+ Status ProcessStatus

+ func (Process) IsNode()

+ func (p Process) ProcessGroup(nodes *NodeManager) ProcessGroup

+ func (p Process) Project(nodes *NodeManager) Project

+ type ProcessGroup struct

+ CreatedAt DateTime

+ ID string

+ ProcessIDs []string

+ TaskID string

+ func (ProcessGroup) IsNode()

+ func (p ProcessGroup) Processes(nodes *NodeManager, after *string, before *string, first *int, last *int) (ProcessConnection, error)

+ func (p ProcessGroup) Status(nodes *NodeManager) ProcessStatus

+ func (p ProcessGroup) Task(nodes *NodeManager) Task

+ type ProcessManager struct

+ func NewProcessManager(nodes *NodeManager, log *Logger, subs *pubsub.PubSub, ...) *ProcessManager

+ func (p *ProcessManager) Clean(ctx context.Context)

+ func (p *ProcessManager) CreateGroup(taskID string) string

+ func (p *ProcessManager) Run(command string, processGroupID string, projectID string) string

+ func (p *ProcessManager) Start(processID string) error

+ func (p *ProcessManager) Stop(processID string) error

+ type Project struct

+ Branch string

+ CommitIDs []string

+ Description *string

+ ID string

+ IsAhead bool

+ IsBehind bool

+ IsCloning bool

+ IsLoadingCommits bool

+ IsPulling bool

+ Repository string

+ Slug string

+ Tasks []Task

+ WorkspaceID string

+ func (Project) IsNode()

+ func (p Project) Commits(nodes *NodeManager, after *string, before *string, first *int, last *int) (CommitConnection, error)

+ func (p Project) IsCloned(nodes *NodeManager, getProjectPath ProjectPathGetter) bool

+ func (p Project) Workspace(nodes *NodeManager) Workspace

+ type ProjectPathGetter func(workspaceSlug, repo, branch string) string

+ type Step struct

+ CommandIDs []string

+ ID string

+ ProjectIDs []string

+ TaskID string

+ func (Step) IsNode()

+ func (s Step) Commands(nodes *NodeManager, after *string, before *string, first *int, last *int) (CommandConnection, error)

+ func (s Step) Projects(nodes *NodeManager, after *string, before *string, first *int, last *int) (ProjectConnection, error)

+ func (s Step) Task(nodes *NodeManager) Task

+ type System struct

+ ID string

+ JobIDs []string

+ JobMetricsID string

+ LogEntryIDs []string

+ LogMetricsID string

+ ProcessGroupIDs []string

+ ProcessMetricsID string

+ func (System) IsNode()

+ func (s System) JobMetrics(nodes *NodeManager) JobMetrics

+ func (s System) Jobs(nodes *NodeManager, after *string, before *string, first *int, last *int, ...) (JobConnection, error)

+ func (s System) LogEntries(nodes *NodeManager, after *string, before *string, first *int, last *int, ...) (LogEntryConnection, error)

+ func (s System) LogMetrics(nodes *NodeManager) LogMetrics

+ func (s System) ProcessGroups(nodes *NodeManager, after *string, before *string, first *int, last *int, ...) (ProcessGroupConnection, error)

+ func (s System) ProcessMetrics(nodes *NodeManager) ProcessMetrics

+ type Task struct

+ ID string

+ IsRunning bool

+ Name string

+ StepIDs []string

+ WorkspaceID string

+ func (Task) IsNode()

+ func (t Task) Steps(nodes *NodeManager, after *string, before *string, first *int, last *int) (StepConnection, error)

+ func (t Task) Workspace(nodes *NodeManager) Workspace

+ type User struct

+ ID string

+ WorkspaceIDs []string

+ func (User) IsNode()

+ func (u User) Projects(nodes *NodeManager, after *string, before *string, first *int, last *int) (ProjectConnection, error)

+ func (u User) Workspace(nodes *NodeManager, slug string) *Workspace

+ func (u User) Workspaces(nodes *NodeManager, after *string, before *string, first *int, last *int) (WorkspaceConnection, error)

+ type Workspace struct

+ Description string

+ ID string

+ Name string

+ Notes *string

+ ProjectIDs []string

+ Slug string

+ TaskIDs []string

+ func (Workspace) IsNode()

+ func (w Workspace) IsAhead(nodes *NodeManager) bool

+ func (w Workspace) IsBehind(nodes *NodeManager) bool

+ func (w Workspace) IsCloned(nodes *NodeManager, getProjectPath ProjectPathGetter) bool

+ func (w Workspace) IsCloning(nodes *NodeManager) bool

+ func (w Workspace) IsPulling(nodes *NodeManager) bool

+ func (w Workspace) Projects(nodes *NodeManager, after *string, before *string, first *int, last *int) (ProjectConnection, error)

+ func (w Workspace) Tasks(nodes *NodeManager, after *string, before *string, first *int, last *int) (TaskConnection, error)

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