rpc

package
v0.0.0-...-31dc5ed Latest Latest
Warning

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

Go to latest
Published: Sep 22, 2020 License: MIT Imports: 15 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

View Source
var ErrorUnauthorized = errors.New("you are not authorized to perform this action")

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

Jump to

Keyboard shortcuts

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