service

Documentation

Index

• Constants
• type Env
  • func NewManulGlobalEnv() (env *Env, err error)
  • func (env *Env) DatabaseSetup() (err error)
  • func (env *Env) ParseAuthInfo(ctx context.Context, auth *pbUser.AuthToken) (user *model.User, err error)
  • func (env *Env) SpawnJobWorkdir() *workdir.Workdir
  • func (env *Env) SpawnMgoCli() *mongo.Client
  • func (env *Env) SpawnProjectWorkdir() *workdir.Workdir
  • func (env *Env) SpawnWorkdir() *workdir.Workdir
• type JobServiceImpl
  • func (j *JobServiceImpl) CancelJob(context.Context, *pb.CancelJobRequest) (*pb.CancelJobResponse, error)
  • func (j *JobServiceImpl) CreateJob(ctx context.Context, req *pb.CreateJobRequest) (ret *pb.CreateJobResponse, e error)
  • func (j *JobServiceImpl) GetJob(ctx context.Context, req *pb.GetJobRequest) (ret *pb.GetJobResponse, e error)
  • func (j *JobServiceImpl) ListJobs(context.Context, *pb.ListJobsRequest) (*pb.ListJobsResponse, error)
• type ProjectServiceImpl
  • func NewProjectServiceImpl(env *Env) *ProjectServiceImpl
  • func (p *ProjectServiceImpl) CreateProject(ctx context.Context, req *pb.CreateProjectRequest) (ret *pb.CreateProjectResponse, e error)
  • func (p *ProjectServiceImpl) DeleteProject(context.Context, *pb.DeleteProjectRequest) (*pb.DeleteProjectResponse, error)
  • func (p *ProjectServiceImpl) GetProject(context.Context, *pb.GetProjectRequest) (*pb.GetProjectResponse, error)
  • func (p *ProjectServiceImpl) GetProjectChecklist(context.Context, *pb.GetProjectChecklistRequest) (*pb.GetProjectChecklistResponse, error)
  • func (p *ProjectServiceImpl) InitProject(name string) (err error)
  • func (p *ProjectServiceImpl) ListProjectMembers(context.Context, *pb.ListProjectMembersRequest) (*pb.ListProjectMembersResponse, error)
  • func (p *ProjectServiceImpl) ListProjects(context.Context, *pb.ListProjectsRequest) (*pb.ListProjectsResponse, error)
  • func (p *ProjectServiceImpl) UpdateProject(context.Context, *pb.UpdateProjectRequest) (*pb.UpdateProjectResponse, error)
  • func (p *ProjectServiceImpl) UpdateProjectMember(context.Context, *pb.UpdateProjectMemberRequest) (*pb.UpdateProjectMemberResponse, error)
• type SecretServiceImpl
  • func (s *SecretServiceImpl) ForgotSecret(context.Context, *pb.ForgotSecretRequest) (*pb.ForgotSecretResponse, error)
  • func (s *SecretServiceImpl) UpdateSecret(context.Context, *pb.UpdateSecretRequest) (*pb.UpdateSecretResponse, error)
• type UserServiceImpl
  • func (u *UserServiceImpl) CreateUser(ctx context.Context, req *pb.CreateUserRequest) (ret *pb.CreateUserResponse, e error)
  • func (u *UserServiceImpl) DeleteUser(context.Context, *pb.DeleteUserRequest) (*pb.DeleteUserResponse, error)
  • func (u *UserServiceImpl) GetUser(ctx context.Context, req *pb.GetUserRequest) (ret *pb.GetUserResponse, e error)
  • func (u *UserServiceImpl) ListUsers(ctx context.Context, req *pb.ListUsersRequest) (ret *pb.ListUsersResponse, e error)
  • func (u *UserServiceImpl) ParseAuthInfo(ctx context.Context, auth *pb.AuthToken) (user *model.User, err error)
  • func (u *UserServiceImpl) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (ret *pb.UpdateUserResponse, e error)

Constants

const (
	DbUserColl    = "user"
	DbSecretColl  = "secret"
	DbProjectColl = "project"
	DbJobColl     = "job"

	FsProjectDir = "project"
	FsJobDir     = "job"
)

const (
	SysAssertAdmin = "_root"
)

Types

type Env

type Env struct {
	UserService    *UserServiceImpl
	SecretService  *SecretServiceImpl
	ProjectService *ProjectServiceImpl
	JobService     *JobServiceImpl
	// contains filtered or unexported fields
}

func NewManulGlobalEnv

func NewManulGlobalEnv() (env *Env, err error)

func (*Env) DatabaseSetup

func (env *Env) DatabaseSetup() (err error)

func (*Env) ParseAuthInfo

func (env *Env) ParseAuthInfo(ctx context.Context, auth *pbUser.AuthToken) (user *model.User, err error)

func (*Env) SpawnJobWorkdir

func (env *Env) SpawnJobWorkdir() *workdir.Workdir

func (*Env) SpawnMgoCli

func (env *Env) SpawnMgoCli() *mongo.Client

func (*Env) SpawnProjectWorkdir

func (env *Env) SpawnProjectWorkdir() *workdir.Workdir

func (*Env) SpawnWorkdir

func (env *Env) SpawnWorkdir() *workdir.Workdir

type JobServiceImpl

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

func (*JobServiceImpl) CancelJob

func (j *JobServiceImpl) CancelJob(context.Context, *pb.CancelJobRequest) (*pb.CancelJobResponse, error)

TODO:Not implemented yet

func (*JobServiceImpl) CreateJob

func (j *JobServiceImpl) CreateJob(ctx context.Context, req *pb.CreateJobRequest) (ret *pb.CreateJobResponse, e error)

TODO:Not implemented yet

func (*JobServiceImpl) GetJob

func (j *JobServiceImpl) GetJob(ctx context.Context, req *pb.GetJobRequest) (ret *pb.GetJobResponse, e error)

TODO:Not implemented yet

func (*JobServiceImpl) ListJobs

func (j *JobServiceImpl) ListJobs(context.Context, *pb.ListJobsRequest) (*pb.ListJobsResponse, error)

TODO:Not implemented yet

type ProjectServiceImpl

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

func NewProjectServiceImpl

func NewProjectServiceImpl(env *Env) *ProjectServiceImpl

func (*ProjectServiceImpl) CreateProject

func (p *ProjectServiceImpl) CreateProject(ctx context.Context, req *pb.CreateProjectRequest) (ret *pb.CreateProjectResponse, e error)

TODO:Not implemented yet

func (*ProjectServiceImpl) DeleteProject

func (p *ProjectServiceImpl) DeleteProject(context.Context, *pb.DeleteProjectRequest) (*pb.DeleteProjectResponse, error)

TODO:Not implemented yet

func (*ProjectServiceImpl) GetProject

func (p *ProjectServiceImpl) GetProject(context.Context, *pb.GetProjectRequest) (*pb.GetProjectResponse, error)

TODO:Not implemented yet

func (*ProjectServiceImpl) GetProjectChecklist

func (p *ProjectServiceImpl) GetProjectChecklist(context.Context, *pb.GetProjectChecklistRequest) (*pb.GetProjectChecklistResponse, error)

TODO:Not implemented yet

func (*ProjectServiceImpl) InitProject

func (p *ProjectServiceImpl) InitProject(name string) (err error)

func (*ProjectServiceImpl) ListProjectMembers

func (p *ProjectServiceImpl) ListProjectMembers(context.Context, *pb.ListProjectMembersRequest) (*pb.ListProjectMembersResponse, error)

TODO:Not implemented yet

func (*ProjectServiceImpl) ListProjects

func (p *ProjectServiceImpl) ListProjects(context.Context, *pb.ListProjectsRequest) (*pb.ListProjectsResponse, error)

TODO:Not implemented yet

func (*ProjectServiceImpl) UpdateProject

func (p *ProjectServiceImpl) UpdateProject(context.Context, *pb.UpdateProjectRequest) (*pb.UpdateProjectResponse, error)

TODO:Not implemented yet

func (*ProjectServiceImpl) UpdateProjectMember

func (p *ProjectServiceImpl) UpdateProjectMember(context.Context, *pb.UpdateProjectMemberRequest) (*pb.UpdateProjectMemberResponse, error)

TODO:Not implemented yet

type SecretServiceImpl

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

func (*SecretServiceImpl) ForgotSecret

func (s *SecretServiceImpl) ForgotSecret(context.Context, *pb.ForgotSecretRequest) (*pb.ForgotSecretResponse, error)

TODO:Not implemented yet

func (*SecretServiceImpl) UpdateSecret

func (s *SecretServiceImpl) UpdateSecret(context.Context, *pb.UpdateSecretRequest) (*pb.UpdateSecretResponse, error)

TODO:Not implemented yet

type UserServiceImpl

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

func (*UserServiceImpl) CreateUser

func (u *UserServiceImpl) CreateUser(ctx context.Context, req *pb.CreateUserRequest) (ret *pb.CreateUserResponse, e error)

func (*UserServiceImpl) DeleteUser

func (u *UserServiceImpl) DeleteUser(context.Context, *pb.DeleteUserRequest) (*pb.DeleteUserResponse, error)

TODO:Not implemented yet

func (*UserServiceImpl) GetUser

func (u *UserServiceImpl) GetUser(ctx context.Context, req *pb.GetUserRequest) (ret *pb.GetUserResponse, e error)

func (*UserServiceImpl) ListUsers

func (u *UserServiceImpl) ListUsers(ctx context.Context, req *pb.ListUsersRequest) (ret *pb.ListUsersResponse, e error)

func (*UserServiceImpl) ParseAuthInfo

func (u *UserServiceImpl) ParseAuthInfo(ctx context.Context, auth *pb.AuthToken) (user *model.User, err error)

func (*UserServiceImpl) UpdateUser

func (u *UserServiceImpl) UpdateUser(ctx context.Context, req *pb.UpdateUserRequest) (ret *pb.UpdateUserResponse, e error)