Documentation ¶
Index ¶
- Variables
- type AuthService
- type PackageService
- func (service *PackageService) AddPackage(source *http.Request, request *proto.RequestAddPackage, ...) error
- func (service *PackageService) GetBus(source *http.Request, request *proto.RequestGetBus, ...) error
- func (service *PackageService) GetLogs(source *http.Request, request *proto.RequestGetLogs, ...) error
- func (service *PackageService) GetPackage(source *http.Request, request *proto.RequestGetPackage, ...) error
- func (service *PackageService) ListPackages(source *http.Request, request *proto.RequestListPackages, ...) error
- func (service *PackageService) RemovePackage(source *http.Request, request *proto.RequestRemovePackage, ...) error
Constants ¶
This section is empty.
Variables ¶
Functions ¶
This section is empty.
Types ¶
type AuthService ¶
type AuthService struct {
// contains filtered or unexported fields
}
func NewAuthService ¶
func NewAuthService(authorizedKeysDir string) (*AuthService, error)
func (*AuthService) Verify ¶
func (service *AuthService) Verify(signature *signature.Signature) *signature.Signer
func (*AuthService) WhoAmI ¶
func (service *AuthService) WhoAmI( source *http.Request, request *proto.RequestWhoAmI, response *proto.ResponseWhoAmI, ) error
type PackageService ¶
type PackageService struct {
// contains filtered or unexported fields
}
PackageService handles all interactions with packages, including:
- adding/removing a package to the queue - retrieving list of packages - retrieving info about a package - retrieving logs after build - watching logs from bus
Should be splitted into several services in order to decrease responsibilities.
func NewPackageService ¶
func NewPackageService( collection *mgo.Collection, auth *AuthService, logsDir string, instance string, ) *PackageService
func (*PackageService) AddPackage ¶
func (service *PackageService) AddPackage( source *http.Request, request *proto.RequestAddPackage, response *proto.ResponseAddPackage, ) error
func (*PackageService) GetBus ¶
func (service *PackageService) GetBus( source *http.Request, request *proto.RequestGetBus, response *proto.ResponseGetBus, ) error
func (*PackageService) GetLogs ¶
func (service *PackageService) GetLogs( source *http.Request, request *proto.RequestGetLogs, response *proto.ResponseGetLogs, ) error
func (*PackageService) GetPackage ¶
func (service *PackageService) GetPackage( source *http.Request, request *proto.RequestGetPackage, response *proto.ResponseGetPackage, ) error
func (*PackageService) ListPackages ¶
func (service *PackageService) ListPackages( source *http.Request, request *proto.RequestListPackages, response *proto.ResponseListPackages, ) error
func (*PackageService) RemovePackage ¶
func (service *PackageService) RemovePackage( source *http.Request, request *proto.RequestRemovePackage, response *proto.ResponseRemovePackage, ) error
Click to show internal directories.
Click to hide internal directories.