state

package
v0.7.2 Latest Latest
Warning

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

 Go to latest Published: Feb 24, 2022 License: MPL-2.0 Imports: 49 Imported by: 0

Documentation

Overview

Package state manages the state that the singleprocess server has, providing operations to mutate that state safely as needed.

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type IndexTime 

type IndexTime struct {
	Field string

	// Asc if true will index with ascending order. Usually you want to
	// find the most recent data so this is false by default.
	Asc bool
}

IndexTime indexes a time.Time field of a struct. TODO(mitchellh): test

func (*IndexTime) FromArgs 

func (idx *IndexTime) FromArgs(args ...interface{}) ([]byte, error)

func (*IndexTime) FromObject 

func (idx *IndexTime) FromObject(obj interface{}) (bool, []byte, error)

type InstanceExec 

type InstanceExec struct {
	Id         int64
	InstanceId string

	Args []string
	Pty  *pb.ExecStreamRequest_PTY

	ClientEventCh     <-chan *pb.ExecStreamRequest
	EntrypointEventCh chan<- *pb.EntrypointExecRequest
	Connected         uint32

	// This is the context that the client side is running inside.
	// It is used by the entrypoint side to detect if the client is still
	// around or not.
	Context context.Context
}

type InstanceLogs added in v0.3.0 

type InstanceLogs struct {
	Id         int64
	InstanceId string

	LogBuffer *logbuffer.Buffer
}

InstanceLogs is a value that can be created to assist in coordination log writers and readers. It is a lighter weight version of an Instance used to manage virtual CEBs sending logs.

type State 

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

State is the primary API for state mutation for the server.

func New 

func New(log hclog.Logger, db *bolt.DB) (*State, error)

New initializes a new State store.

func TestState 

func TestState(t testing.T) *State

TestState returns an initialized State for testing.

func TestStateRestart added in v0.2.0 

func TestStateRestart(t testing.T, s *State) (*State, error)

TestStateRestart closes the given state and restarts it against the same DB file.

func (*State) AppDelete 

func (s *State) AppDelete(ref *pb.Ref_Application) error

AppDelete deletes an application from a project. This will also delete all the operations associated with this application.

func (*State) AppGet 

func (s *State) AppGet(ref *pb.Ref_Application) (*pb.Application, error)

AppGet retrieves the application..

func (*State) AppPut 

func (s *State) AppPut(app *pb.Application) (*pb.Application, error)

AppPut creates or updates the application.

func (*State) ApplicationPollComplete added in v0.5.0 

func (s *State) ApplicationPollComplete(
	project *pb.Project,
	t time.Time,
) error

ApplicationPollComplete sets the next poll time for a given project given the app reference along with the time interval "t".

func (*State) ApplicationPollPeek added in v0.5.0 

func (s *State) ApplicationPollPeek(
	ws memdb.WatchSet,
) (*pb.Project, time.Time, error)

ApplicationPollPeek peeks at the next available project that will be polled against, and returns the project as the result along with the poll time. The poll queuer will queue a job against every defined application for the given project. For more information on how ProjectPollPeek works, refer to the ProjectPollPeek docs.

func (*State) ArtifactGet 

func (s *State) ArtifactGet(ref *pb.Ref_Operation) (*pb.PushedArtifact, error)

ArtifactGet gets a artifact by ref.

func (*State) ArtifactLatest 

func (s *State) ArtifactLatest(
	ref *pb.Ref_Application,
	ws *pb.Ref_Workspace,
) (*pb.PushedArtifact, error)

ArtifactLatest gets the latest artifact that was completed successfully.

func (*State) ArtifactList 

func (s *State) ArtifactList(
	ref *pb.Ref_Application,
	opts ...serverstate.ListOperationOption,
) ([]*pb.PushedArtifact, error)

func (*State) ArtifactPut 

func (s *State) ArtifactPut(update bool, b *pb.PushedArtifact) error

ArtifactPut inserts or updates a artifact record.

func (*State) AuthMethodDelete added in v0.5.0 

func (s *State) AuthMethodDelete(ref *pb.Ref_AuthMethod) error

AuthMethodDelete deletes an auth method by reference.

func (*State) AuthMethodGet added in v0.5.0 

func (s *State) AuthMethodGet(ref *pb.Ref_AuthMethod) (*pb.AuthMethod, error)

AuthMethodGet gets a auth method by reference.

func (*State) AuthMethodList added in v0.5.0 

func (s *State) AuthMethodList() ([]*pb.AuthMethod, error)

AuthMethodList returns the list of projects.

func (*State) AuthMethodPut added in v0.5.0 

func (s *State) AuthMethodPut(v *pb.AuthMethod) error

AuthMethodPut creates or updates the given auth method. .

func (*State) BuildGet 

func (s *State) BuildGet(ref *pb.Ref_Operation) (*pb.Build, error)

BuildGet gets a build by ref.

func (*State) BuildLatest 

func (s *State) BuildLatest(
	ref *pb.Ref_Application,
	ws *pb.Ref_Workspace,
) (*pb.Build, error)

BuildLatest gets the latest build that was completed successfully.

func (*State) BuildList 

func (s *State) BuildList(
	ref *pb.Ref_Application,
	opts ...serverstate.ListOperationOption,
) ([]*pb.Build, error)

func (*State) BuildPut 

func (s *State) BuildPut(update bool, b *pb.Build) error

BuildPut inserts or updates a build record.

func (*State) Close 

func (s *State) Close() error

Close should be called to gracefully close any resources.

func (*State) ConfigGet 

func (s *State) ConfigGet(req *pb.ConfigGetRequest) ([]*pb.ConfigVar, error)

ConfigGet gets all the configuration for the given request.

func (*State) ConfigGetWatch 

func (s *State) ConfigGetWatch(req *pb.ConfigGetRequest, ws memdb.WatchSet) ([]*pb.ConfigVar, error)

ConfigGetWatch gets all the configuration for the given request. If a non-nil WatchSet is given, this can be watched for potential changes in the config.

func (*State) ConfigSet 

func (s *State) ConfigSet(vs ...*pb.ConfigVar) error

ConfigSet writes a configuration variable to the data store. Deletes are always ordered before writes so that you can't delete a new value in a single ConfigSet (you should never want to do this).

func (*State) ConfigSourceGet added in v0.2.0 

func (s *State) ConfigSourceGet(req *pb.GetConfigSourceRequest) ([]*pb.ConfigSource, error)

ConfigSourceGet gets all the configuration sources for the given request.

func (*State) ConfigSourceGetWatch added in v0.2.0 

func (s *State) ConfigSourceGetWatch(req *pb.GetConfigSourceRequest, ws memdb.WatchSet) ([]*pb.ConfigSource, error)

ConfigSourceGetWatch gets all the configuration sources for the given request. If a non-nil WatchSet is given, this can be watched for potential changes in the config source settings.

func (*State) ConfigSourceSet added in v0.2.0 

func (s *State) ConfigSourceSet(vs ...*pb.ConfigSource) error

ConfigSourceSet writes a set of config source values to the database.

func (*State) CreateSnapshot added in v0.2.0 

func (s *State) CreateSnapshot(w io.Writer) error

CreateSnapshot creates a database snapshot and writes it to the given writer.

This will NOT buffer data to w, so you should wrap w in a bufio.Writer if you want buffering.

func (*State) DeploymentGet 

func (s *State) DeploymentGet(ref *pb.Ref_Operation) (*pb.Deployment, error)

DeploymentGet gets a deployment by ref.

func (*State) DeploymentLatest 

func (s *State) DeploymentLatest(
	ref *pb.Ref_Application,
	ws *pb.Ref_Workspace,
) (*pb.Deployment, error)

DeploymentLatest gets the latest deployment that was completed successfully.

func (*State) DeploymentList 

func (s *State) DeploymentList(
	ref *pb.Ref_Application,
	opts ...serverstate.ListOperationOption,
) ([]*pb.Deployment, error)

func (*State) DeploymentPut 

func (s *State) DeploymentPut(update bool, b *pb.Deployment) error

DeploymentPut inserts or updates a deployment record.

func (*State) GetFileChangeSignal added in v0.4.0 

func (s *State) GetFileChangeSignal(scope *pb.Ref_Application) (string, error)

GetFileChangeSignal checks the metadata for the given application and its project, returning the value of FileChangeSignal that is most relevent.

func (*State) HMACKeyCreateIfNotExist 

func (s *State) HMACKeyCreateIfNotExist(id string, size int) (*pb.HMACKey, error)

HMACKeyCreateIfNotExist creates a new HMAC key with the given ID and size. If a key with the given ID exists already it will be returned.

func (*State) HMACKeyEmpty 

func (s *State) HMACKeyEmpty() bool

HMACKeyEmpty returns true if no HMAC keys have been created. This will be true only when the server is in a bootstrap state.

func (*State) HMACKeyGet 

func (s *State) HMACKeyGet(id string) (*pb.HMACKey, error)

HMACKeyGet gets an HMAC key by ID. This will return a nil value if it doesn't exist.

func (*State) InstanceById 

func (s *State) InstanceById(id string) (*serverstate.Instance, error)

func (*State) InstanceCreate 

func (s *State) InstanceCreate(rec *serverstate.Instance) error

func (*State) InstanceDelete 

func (s *State) InstanceDelete(id string) error

func (*State) InstanceExecById 

func (s *State) InstanceExecById(id int64) (*InstanceExec, error)

func (*State) InstanceExecCreateByDeployment 

func (s *State) InstanceExecCreateByDeployment(did string, exec *InstanceExec) error

func (*State) InstanceExecCreateByTargetedInstance added in v0.3.0 

func (s *State) InstanceExecCreateByTargetedInstance(id string, exec *InstanceExec) error

func (*State) InstanceExecCreateForVirtualInstance added in v0.3.0 

func (s *State) InstanceExecCreateForVirtualInstance(ctx context.Context, id string, exec *InstanceExec) error

InstanceExecCreateForVirtualInstance registers the given InstanceExec record on the instance specified. The instance does not yet have to be known (as it may not yet have connected to the server) so this code will use memdb watchers to detect the instance as it connects and then register the exec.

func (*State) InstanceExecDelete 

func (s *State) InstanceExecDelete(id int64) error

func (*State) InstanceExecListByInstanceId 

func (s *State) InstanceExecListByInstanceId(id string, ws memdb.WatchSet) ([]*InstanceExec, error)

func (*State) InstanceLogsById added in v0.3.0 

func (s *State) InstanceLogsById(id int64) (*InstanceLogs, error)

func (*State) InstanceLogsByInstanceId added in v0.3.0 

func (s *State) InstanceLogsByInstanceId(id string) (*InstanceLogs, error)

func (*State) InstanceLogsCreate added in v0.3.0 

func (s *State) InstanceLogsCreate(id string, logs *InstanceLogs) error

func (*State) InstanceLogsDelete added in v0.3.0 

func (s *State) InstanceLogsDelete(id int64) error

func (*State) InstanceLogsListByInstanceId added in v0.3.0 

func (s *State) InstanceLogsListByInstanceId(id string, ws memdb.WatchSet) ([]*InstanceLogs, error)

func (*State) InstancesByApp 

func (s *State) InstancesByApp(
	ref *pb.Ref_Application,
	refws *pb.Ref_Workspace,
	ws memdb.WatchSet,
) ([]*serverstate.Instance, error)

func (*State) InstancesByDeployment 

func (s *State) InstancesByDeployment(id string, ws memdb.WatchSet) ([]*serverstate.Instance, error)

func (*State) JobAck 

func (s *State) JobAck(id string, ack bool) (*serverstate.Job, error)

JobAck acknowledges that a job has been accepted or rejected by the runner. If ack is false, then this will move the job back to the queued state and be eligible for assignment.

func (*State) JobAssignForRunner 

func (s *State) JobAssignForRunner(ctx context.Context, r *pb.Runner) (*serverstate.Job, error)

JobAssignForRunner will wait for and assign a job to a specific runner. This will automatically evaluate any conditions that the runner and/or job may have on assignability.

The assigned job is put into a "waiting" state until the runner acks the assignment which can be set with JobAck.

If ctx is provided and assignment has to block waiting for new jobs, this will cancel when the context is done.

func (*State) JobById 

func (s *State) JobById(id string, ws memdb.WatchSet) (*serverstate.Job, error)

JobById looks up a job by ID. The returned Job will be a deep copy of the job so it is safe to read/write. If the job can't be found, a nil result with no error is returned.

func (*State) JobCancel 

func (s *State) JobCancel(id string, force bool) error

JobCancel marks a job as cancelled. This will set the internal state and request the cancel but if the job is running then it is up to downstream to listen for and react to Job changes for cancellation.

func (*State) JobComplete 

func (s *State) JobComplete(id string, result *pb.Job_Result, cerr error) error

JobComplete marks a running job as complete. If an error is given, the job is marked as failed (a completed state). If no error is given, the job is marked as successful.

func (*State) JobCreate 

func (s *State) JobCreate(jobs ...*pb.Job) error

JobCreate queues the given jobs. If any job fails to queue, no jobs are queued. If partial failures are acceptible, call this multiple times with a single job.

func (*State) JobExpire 

func (s *State) JobExpire(id string) error

JobExpire expires a job. This will cancel the job if it is still queued.

func (*State) JobHeartbeat 

func (s *State) JobHeartbeat(id string) error

JobHeartbeat resets the heartbeat timer for a running job. If the job is not currently running this does nothing, it will not return an error. If the job doesn't exist then this will return an error.

func (*State) JobIsAssignable 

func (s *State) JobIsAssignable(ctx context.Context, jobpb *pb.Job) (bool, error)

JobIsAssignable returns whether there is a registered runner that meets the requirements to run this job.

If this returns true, the job if queued should eventually be assigned successfully to a runner. An assignable result does NOT mean that it will be in queue a short amount of time.

Note the result is a point-in-time result. If the only candidate runners deregister between this returning true and queueing, the job may still sit in a queue indefinitely.

func (*State) JobList 

func (s *State) JobList() ([]*pb.Job, error)

JobList returns the list of jobs.

func (*State) JobPeekForRunner added in v0.6.0 

func (s *State) JobPeekForRunner(ctx context.Context, r *pb.Runner) (*serverstate.Job, error)

JobPeekForRunner effectively simulates JobAssignForRunner with two changes: (1) jobs are not actually assigned (they remain queued) and (2) this will not block if a job isn't available. If a job isn't available, this will return (nil, nil).

func (*State) JobProjectScopedRequest added in v0.7.0 

func (s *State) JobProjectScopedRequest(
	pRef *pb.Ref_Project,
	jobTemplate *pb.Job,
) ([]*pb.QueueJobRequest, error)

Given a Project Ref and a Job Template, this function will generate a slice of QueueJobRequests for every application inside the requested Project

func (*State) JobUpdate added in v0.6.0 

func (s *State) JobUpdate(id string, cb func(jobpb *pb.Job) error) error

JobUpdate calls the given callback to update fields on the job data. The callback is called in the context of a database write lock so it should NOT compute anything and should be fast. The callback can return an error to abort the transaction.

Job states should NOT be modified using this, only metadata.

func (*State) JobUpdateRef added in v0.3.0 

func (s *State) JobUpdateRef(id string, ref *pb.Job_DataSource_Ref) error

JobUpdateRef sets the data_source_ref field for a job. This job can be in any state.

func (*State) OnDemandRunnerConfigDefault added in v0.6.0 

func (s *State) OnDemandRunnerConfigDefault() ([]*pb.Ref_OnDemandRunnerConfig, error)

OnDemandRunnerConfigDefault returns the list of ondemandRunners that are defaults.

func (*State) OnDemandRunnerConfigDelete added in v0.6.0 

func (s *State) OnDemandRunnerConfigDelete(ref *pb.Ref_OnDemandRunnerConfig) error

OnDemandRunnerConfigDelete deletes a ondemandRunner by reference. This is a complete data delete. This will delete all operations associated with this ondemandRunner as well.

func (*State) OnDemandRunnerConfigGet added in v0.6.0 

func (s *State) OnDemandRunnerConfigGet(ref *pb.Ref_OnDemandRunnerConfig) (*pb.OnDemandRunnerConfig, error)

OnDemandRunnerConfigGet gets a ondemandRunner by reference.

func (*State) OnDemandRunnerConfigList added in v0.6.0 

func (s *State) OnDemandRunnerConfigList() ([]*pb.OnDemandRunnerConfig, error)

OnDemandRunnerConfigList returns the list of ondemandRunners.

func (*State) OnDemandRunnerConfigPut added in v0.6.0 

func (s *State) OnDemandRunnerConfigPut(o *pb.OnDemandRunnerConfig) error

OnDemandRunnerConfigPut creates or updates the given ondemandRunner.

Application changes will be ignored, you must use the Application APIs.

func (*State) ProjectDelete 

func (s *State) ProjectDelete(ref *pb.Ref_Project) error

ProjectDelete deletes a project by reference. This is a complete data delete. This will delete all operations associated with this project as well.

func (*State) ProjectGet 

func (s *State) ProjectGet(ref *pb.Ref_Project) (*pb.Project, error)

ProjectGet gets a project by reference.

func (*State) ProjectList 

func (s *State) ProjectList() ([]*pb.Ref_Project, error)

ProjectList returns the list of projects.

func (*State) ProjectListWorkspaces added in v0.3.0 

func (s *State) ProjectListWorkspaces(ref *pb.Ref_Project) ([]*pb.Workspace_Project, error)

ProjectListWorkspaces returns the list of workspaces that a project is in.

func (*State) ProjectPollComplete added in v0.3.0 

func (s *State) ProjectPollComplete(p *pb.Project, t time.Time) error

ProjectPollComplete sets the next poll time for the given project to the time "t" plus the interval time for the project.

func (*State) ProjectPollPeek added in v0.3.0 

func (s *State) ProjectPollPeek(ws memdb.WatchSet) (*pb.Project, time.Time, error)

ProjectPollPeek returns the next project that should be polled. This will return (nil,nil) if there are no projects to poll currently.

This is a "peek" operation so it does not update the project's next poll time. Therefore, calling this multiple times should return the same result unless a function like ProjectPollComplete is called.

If ws is non-nil, the WatchSet can be watched for any changes to projects to poll. This can be watched, for example, to detect when projects to poll are added. This is important functionality since callers may be sleeping on a deadline for awhile when a new project is inserted to poll immediately.

func (*State) ProjectPut 

func (s *State) ProjectPut(p *pb.Project) error

ProjectPut creates or updates the given project.

Application changes will be ignored, you must use the Application APIs.

func (*State) ProjectUpdateDataRef added in v0.3.0 

func (s *State) ProjectUpdateDataRef(
	ref *pb.Ref_Project,
	ws *pb.Ref_Workspace,
	dataRef *pb.Job_DataSource_Ref,
) error

ProjectUpdateDataRef updates the latest data ref used for a project. This data is available via the APIs for querying workspaces.

func (*State) Prune added in v0.3.0 

func (s *State) Prune() error

Prune should be called in a on a regular interval to allow State to prune out old data.

func (*State) ReleaseGet 

func (s *State) ReleaseGet(ref *pb.Ref_Operation) (*pb.Release, error)

ReleaseGet gets a release by ref.

func (*State) ReleaseLatest 

func (s *State) ReleaseLatest(
	ref *pb.Ref_Application,
	ws *pb.Ref_Workspace,
) (*pb.Release, error)

ReleaseLatest gets the latest release that was completed successfully.

func (*State) ReleaseList 

func (s *State) ReleaseList(
	ref *pb.Ref_Application,
	opts ...serverstate.ListOperationOption,
) ([]*pb.Release, error)

func (*State) ReleasePut 

func (s *State) ReleasePut(update bool, b *pb.Release) error

ReleasePut inserts or updates a release record.

func (*State) RunnerById 

func (s *State) RunnerById(id string) (*pb.Runner, error)

func (*State) RunnerCreate 

func (s *State) RunnerCreate(r *pb.Runner) error

func (*State) RunnerDelete 

func (s *State) RunnerDelete(id string) error

func (*State) RunnerList added in v0.7.0 

func (s *State) RunnerList() ([]*pb.Runner, error)

func (*State) ServerConfigGet 

func (s *State) ServerConfigGet() (*pb.ServerConfig, error)

ServerConfigGet gets the server configuration.

func (*State) ServerConfigSet 

func (s *State) ServerConfigSet(c *pb.ServerConfig) error

ServerConfigSet writes the server configuration.

func (*State) ServerIdGet 

func (s *State) ServerIdGet() (string, error)

ServerIdGet gets the server ID.

func (*State) ServerIdSet 

func (s *State) ServerIdSet(id string) error

ServerIdSet writes the server ID.

func (*State) ServerURLTokenGet added in v0.3.0 

func (s *State) ServerURLTokenGet() (string, error)

ServerURLTokenGet gets the server URL token.

func (*State) ServerURLTokenSet added in v0.3.0 

func (s *State) ServerURLTokenSet(token string) error

ServerURLTokenSet writes the server URL token.

func (*State) StageRestoreSnapshot added in v0.2.0 

func (s *State) StageRestoreSnapshot(r io.Reader) error

StageRestoreSnapshot stages a database restore for the next server restart. This will create a temporary file alongside the data file so we must have write access to the directory containing the database.

func (*State) StatusReportGet added in v0.4.0 

func (s *State) StatusReportGet(ref *pb.Ref_Operation) (*pb.StatusReport, error)

get status report by referenced operation

func (*State) StatusReportLatest added in v0.4.0 

func (s *State) StatusReportLatest(
	ref *pb.Ref_Application,
	ws *pb.Ref_Workspace,
	filter func(*pb.StatusReport) (bool, error),
) (*pb.StatusReport, error)

StatusReportLatest gets the latest generated status report

func (*State) StatusReportList added in v0.4.0 

func (s *State) StatusReportList(
	ref *pb.Ref_Application,
	opts ...serverstate.ListOperationOption,
) ([]*pb.StatusReport, error)

func (*State) StatusReportPut added in v0.4.0 

func (s *State) StatusReportPut(update bool, report *pb.StatusReport) error

create or update the latest status report

func (*State) TriggerDelete added in v0.7.0 

func (s *State) TriggerDelete(ref *pb.Ref_Trigger) error

TriggerDelete deletes a trigger by reference.

func (*State) TriggerGet added in v0.7.0 

func (s *State) TriggerGet(ref *pb.Ref_Trigger) (*pb.Trigger, error)

TriggerGet gets a trigger by reference.

func (*State) TriggerList added in v0.7.0 

func (s *State) TriggerList(
	refws *pb.Ref_Workspace,
	refproj *pb.Ref_Project,
	refapp *pb.Ref_Application,
	tagFilter []string,
) ([]*pb.Trigger, error)

TriggerList returns the list of triggers.

func (*State) TriggerPut added in v0.7.0 

func (s *State) TriggerPut(t *pb.Trigger) error

TriggerPut creates or updates the given Trigger.

func (*State) UserDelete added in v0.5.0 

func (s *State) UserDelete(ref *pb.Ref_User) error

UserDelete deletes a user by reference.

func (*State) UserEmpty added in v0.5.0 

func (s *State) UserEmpty() (bool, error)

UserEmpty returns true if there are no users yet (bootstrap state).

func (*State) UserGet added in v0.5.0 

func (s *State) UserGet(ref *pb.Ref_User) (*pb.User, error)

UserGet gets a user by reference.

func (*State) UserGetEmail added in v0.5.0 

func (s *State) UserGetEmail(email string) (*pb.User, error)

UserGetEmail gets a user by by email lookup. This will return a codes.NotFound error if the user is not found.

func (*State) UserGetOIDC added in v0.5.0 

func (s *State) UserGetOIDC(iss, sub string) (*pb.User, error)

UserGetOIDC gets a user by by OIDC link lookup. This will return a codes.NotFound error if the user is not found.

func (*State) UserList added in v0.5.0 

func (s *State) UserList() ([]*pb.User, error)

UserList returns the list of projects.

func (*State) UserPut added in v0.5.0 

func (s *State) UserPut(user *pb.User) error

UserPut creates or updates the given user. If the user has no ID set then an ID will be written directly to the parameter.

func (*State) WorkspaceGet 

func (s *State) WorkspaceGet(n string) (*pb.Workspace, error)

WorkspaceGet gets a workspace with a specific name. If it doesn't exist, this will return an error with codes.NotFound.

func (*State) WorkspaceList 

func (s *State) WorkspaceList() ([]*pb.Workspace, error)

WorkspaceList lists all the workspaces.

func (*State) WorkspaceListByApp added in v0.4.0 

func (s *State) WorkspaceListByApp(ref *pb.Ref_Application) ([]*pb.Workspace, error)

WorkspaceListByApp lists all the workspaces used by a specific application.

func (*State) WorkspaceListByProject added in v0.4.0 

func (s *State) WorkspaceListByProject(ref *pb.Ref_Project) ([]*pb.Workspace, error)

WorkspaceListByProject lists all the workspaces used by a project.

func (*State) WorkspacePut added in v0.7.0 

func (s *State) WorkspacePut(workspace *pb.Workspace) error

WorkspacePut creates or updates the given Workspace.

Project changes will be ignored

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.