server

package
v0.8.10 Latest Latest
Warning

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

 Go to latest Published: Dec 6, 2018 License: Apache-2.0 Imports: 40 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source 
var Config = struct {
	Services struct {
		Pubsub     pubsub.Publisher
		Queue      queue.Queue
		Logs       logging.Log
		Senders    model.SenderService
		Secrets    model.SecretService
		Registries model.RegistryService
		Environ    model.EnvironService
		Limiter    model.Limiter
	}
	Storage struct {
		// Users  model.UserStore
		// Repos  model.RepoStore
		// Builds model.BuildStore
		// Logs   model.LogStore
		Config model.ConfigStore
		Files  model.FileStore
		Procs  model.ProcStore
	}
	Server struct {
		Key            string
		Cert           string
		Host           string
		Port           string
		Pass           string
		RepoConfig     string
		SessionExpires time.Duration
	}
	Prometheus struct {
		AuthToken string
	}
	Pipeline struct {
		Limits     model.ResourceLimit
		Volumes    []string
		Networks   []string
		Privileged []string
	}
}{}

Config is an evil global configuration that will be used as we transition / refactor the codebase to move away from storing these values in the Context.

Functions

func ChownRepo 

func ChownRepo(c *gin.Context)

func DeleteBuild 

func DeleteBuild(c *gin.Context)

func DeleteBuildLogs added in v0.8.4 

func DeleteBuildLogs(c *gin.Context)

func DeleteRegistry added in v0.6.0 

func DeleteRegistry(c *gin.Context)

DeleteRegistry deletes the named registry from the database.

func DeleteRepo 

func DeleteRepo(c *gin.Context)

func DeleteSecret 

func DeleteSecret(c *gin.Context)

DeleteSecret deletes the named secret from the database.

func DeleteToken 

func DeleteToken(c *gin.Context)

func DeleteUser 

func DeleteUser(c *gin.Context)

func EventStreamSSE added in v0.8.0 

func EventStreamSSE(c *gin.Context)

func FileGet added in v0.8.0 

func FileGet(c *gin.Context)

FileGet gets a file by process and name

func FileList added in v0.8.0 

func FileList(c *gin.Context)

FileList gets a list file by build.

func GetBadge 

func GetBadge(c *gin.Context)

func GetBuild 

func GetBuild(c *gin.Context)

func GetBuildLast 

func GetBuildLast(c *gin.Context)

func GetBuildLogs 

func GetBuildLogs(c *gin.Context)

func GetBuildQueue 

func GetBuildQueue(c *gin.Context)

func GetBuilds 

func GetBuilds(c *gin.Context)

func GetCC 

func GetCC(c *gin.Context)

func GetFeed 

func GetFeed(c *gin.Context)

func GetLoginToken 

func GetLoginToken(c *gin.Context)

func GetLogout 

func GetLogout(c *gin.Context)

func GetProcLogs added in v0.8.0 

func GetProcLogs(c *gin.Context)

func GetQueueInfo added in v0.6.0 

func GetQueueInfo(c *gin.Context)

func GetRegistry added in v0.6.0 

func GetRegistry(c *gin.Context)

GetRegistry gets the name registry from the database and writes to the response in json format.

func GetRegistryList added in v0.6.0 

func GetRegistryList(c *gin.Context)

GetRegistryList gets the registry list from the database and writes to the response in json format.

func GetRepo 

func GetRepo(c *gin.Context)

func GetRepos 

func GetRepos(c *gin.Context)

func GetSecret added in v0.6.0 

func GetSecret(c *gin.Context)

GetSecret gets the named secret from the database and writes to the response in json format.

func GetSecretList added in v0.6.0 

func GetSecretList(c *gin.Context)

GetSecretList gets the secret list from the database and writes to the response in json format.

func GetSelf 

func GetSelf(c *gin.Context)

func GetUser 

func GetUser(c *gin.Context)

func GetUsers 

func GetUsers(c *gin.Context)

func HandleAuth added in v0.8.0 

func HandleAuth(c *gin.Context)

func HandleLogin added in v0.8.0 

func HandleLogin(c *gin.Context)

func Health added in v0.8.2 

func Health(c *gin.Context)

Health endpoint returns a 500 if the server state is unhealthy.

func LogStreamSSE added in v0.8.0 

func LogStreamSSE(c *gin.Context)

func MoveRepo added in v0.8.0 

func MoveRepo(c *gin.Context)

func PatchRegistry added in v0.6.0 

func PatchRegistry(c *gin.Context)

PatchRegistry updates the registry in the database.

func PatchRepo 

func PatchRepo(c *gin.Context)

func PatchSecret added in v0.6.0 

func PatchSecret(c *gin.Context)

PatchSecret updates the secret in the database.

func PatchUser 

func PatchUser(c *gin.Context)

func PostApproval added in v0.6.0 

func PostApproval(c *gin.Context)

func PostBuild 

func PostBuild(c *gin.Context)

func PostDecline added in v0.6.0 

func PostDecline(c *gin.Context)

func PostHook 

func PostHook(c *gin.Context)

func PostRegistry added in v0.6.0 

func PostRegistry(c *gin.Context)

PostRegistry persists the registry to the database.

func PostRepo 

func PostRepo(c *gin.Context)

func PostSecret 

func PostSecret(c *gin.Context)

PostSecret persists the secret to the database.

func PostToken 

func PostToken(c *gin.Context)

func PostUser 

func PostUser(c *gin.Context)

func RepairRepo added in v0.6.0 

func RepairRepo(c *gin.Context)

func ToConfig 

func ToConfig(c *gin.Context) *model.Settings

ToConfig returns the config from the Context

func Version added in v0.8.2 

func Version(c *gin.Context)

Version endpoint returns the server version and build information.

func ZombieKill added in v0.8.0 

func ZombieKill(c *gin.Context)

ZombieKill kills zombie processes stuck in an infinite pending or running state. This can only be invoked by administrators and may have negative effects.

Types

type DroneServer added in v0.8.0 

type DroneServer struct {
	Remote remote.Remote
	Queue  queue.Queue
	Pubsub pubsub.Publisher
	Logger logging.Log
	Store  store.Store
	Host   string
}

DroneServer is a grpc server implementation.

func (*DroneServer) Done added in v0.8.0 

func (s *DroneServer) Done(c oldcontext.Context, req *proto.DoneRequest) (*proto.Empty, error)

func (*DroneServer) Extend added in v0.8.0 

func (s *DroneServer) Extend(c oldcontext.Context, req *proto.ExtendRequest) (*proto.Empty, error)

func (*DroneServer) Init added in v0.8.0 

func (s *DroneServer) Init(c oldcontext.Context, req *proto.InitRequest) (*proto.Empty, error)

func (*DroneServer) Log added in v0.8.0 

func (s *DroneServer) Log(c oldcontext.Context, req *proto.LogRequest) (*proto.Empty, error)

func (*DroneServer) Next added in v0.8.0 

func (s *DroneServer) Next(c oldcontext.Context, req *proto.NextRequest) (*proto.NextReply, error)

func (*DroneServer) Update added in v0.8.0 

func (s *DroneServer) Update(c oldcontext.Context, req *proto.UpdateRequest) (*proto.Empty, error)

func (*DroneServer) Upload added in v0.8.0 

func (s *DroneServer) Upload(c oldcontext.Context, req *proto.UploadRequest) (*proto.Empty, error)

func (*DroneServer) Wait added in v0.8.0 

func (s *DroneServer) Wait(c oldcontext.Context, req *proto.WaitRequest) (*proto.Empty, error)

type RPC added in v0.6.0 

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

func (*RPC) Done added in v0.6.0 

func (s *RPC) Done(c context.Context, id string, state rpc.State) error

Done implements the rpc.Done function

func (*RPC) Extend added in v0.6.0 

func (s *RPC) Extend(c context.Context, id string) error

Extend implements the rpc.Extend function

func (*RPC) Init added in v0.6.0 

func (s *RPC) Init(c context.Context, id string, state rpc.State) error

Init implements the rpc.Init function

func (*RPC) Log added in v0.6.0 

func (s *RPC) Log(c context.Context, id string, line *rpc.Line) error

Log implements the rpc.Log function

func (*RPC) Next added in v0.6.0 

func (s *RPC) Next(c context.Context, filter rpc.Filter) (*rpc.Pipeline, error)

Next implements the rpc.Next function

func (*RPC) Update added in v0.6.0 

func (s *RPC) Update(c context.Context, id string, state rpc.State) error

Update implements the rpc.Update function

func (*RPC) Upload added in v0.6.0 

func (s *RPC) Upload(c context.Context, id string, file *rpc.File) error

Upload implements the rpc.Upload function

func (*RPC) Wait added in v0.6.0 

func (s *RPC) Wait(c context.Context, id string) error

Wait implements the rpc.Wait function

type Syncer added in v0.8.0 

type Syncer interface {
	Sync(user *model.User) error
}

Syncer synces the user repository and permissions.

Source Files

View all Source files

Directories

Path Synopsis
Package classification Drone API.
 Package classification Drone API.

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.