workers

Documentation

Index

• Constants
• Variables
• type Service
  • func NewService(ctx context.Context, repo common.ServersRepoFactory, ...) (Service, error)
  • func (s Service) AddWorkerTags(ctx context.Context, req *pbs.AddWorkerTagsRequest) (*pbs.AddWorkerTagsResponse, error)
  • func (s Service) CreateControllerLed(ctx context.Context, req *pbs.CreateControllerLedRequest) (*pbs.CreateControllerLedResponse, error)
  • func (s Service) CreateWorkerLed(ctx context.Context, req *pbs.CreateWorkerLedRequest) (*pbs.CreateWorkerLedResponse, error)
  • func (s Service) DeleteWorker(ctx context.Context, req *pbs.DeleteWorkerRequest) (*pbs.DeleteWorkerResponse, error)
  • func (s Service) GetWorker(ctx context.Context, req *pbs.GetWorkerRequest) (*pbs.GetWorkerResponse, error)
  • func (s Service) ListWorkers(ctx context.Context, req *pbs.ListWorkersRequest) (*pbs.ListWorkersResponse, error)
  • func (s Service) ReadCertificateAuthority(ctx context.Context, req *pbs.ReadCertificateAuthorityRequest) (*pbs.ReadCertificateAuthorityResponse, error)
  • func (s Service) ReinitializeCertificateAuthority(ctx context.Context, req *pbs.ReinitializeCertificateAuthorityRequest) (*pbs.ReinitializeCertificateAuthorityResponse, error)
  • func (s Service) RemoveWorkerTags(ctx context.Context, req *pbs.RemoveWorkerTagsRequest) (*pbs.RemoveWorkerTagsResponse, error)
  • func (s Service) SetWorkerTags(ctx context.Context, req *pbs.SetWorkerTagsRequest) (*pbs.SetWorkerTagsResponse, error)
  • func (s Service) UpdateWorker(ctx context.Context, req *pbs.UpdateWorkerRequest) (*pbs.UpdateWorkerResponse, error)

Constants

const (
	PkiWorkerType = "pki"
	KmsWorkerType = "kms"
)

Variables

var (

	// IdActions contains the set of actions that can be performed on
	// individual resources
	IdActions = action.ActionSet{
		action.NoOp,
		action.Read,
		action.Update,
		action.Delete,
		action.AddWorkerTags,
		action.SetWorkerTags,
		action.RemoveWorkerTags,
	}

	// CollectionActions contains the set of actions that can be performed on
	// this collection
	CollectionActions = action.ActionSet{
		action.CreateControllerLed,
		action.CreateWorkerLed,
		action.List,
		action.ReadCertificateAuthority,
		action.ReinitializeCertificateAuthority,
	}
)

Types

type Service

type Service struct {
	pbs.UnsafeWorkerServiceServer
	// contains filtered or unexported fields
}

Service handles request as described by the pbs.WorkerServiceServer interface.

func NewService

func NewService(ctx context.Context, repo common.ServersRepoFactory, iamRepoFn common.IamRepoFactory,
	workerAuthFn common.WorkerAuthRepoStorageFactory, ds common.Downstreamers,
) (Service, error)

NewService returns a worker service which handles worker related requests to boundary.

func (Service) AddWorkerTags

func (s Service) AddWorkerTags(ctx context.Context, req *pbs.AddWorkerTagsRequest) (*pbs.AddWorkerTagsResponse, error)

AddWorkerTags implements the interface pbs.WorkerServiceServer.

func (Service) CreateControllerLed

func (s Service) CreateControllerLed(ctx context.Context, req *pbs.CreateControllerLedRequest) (*pbs.CreateControllerLedResponse, error)

CreateControllerLed implements the interface pbs.WorkerServiceServer and handles a request to create a new worker, generating and returning an activation token

func (Service) CreateWorkerLed

func (s Service) CreateWorkerLed(ctx context.Context, req *pbs.CreateWorkerLedRequest) (*pbs.CreateWorkerLedResponse, error)

CreateWorkerLed implements the interface pbs.WorkerServiceServer and handles a request to create a new worker and consume a worker-generated authorization request

func (Service) DeleteWorker

func (s Service) DeleteWorker(ctx context.Context, req *pbs.DeleteWorkerRequest) (*pbs.DeleteWorkerResponse, error)

DeleteWorker implements the interface pbs.WorkerServiceServer.

func (Service) GetWorker

func (s Service) GetWorker(ctx context.Context, req *pbs.GetWorkerRequest) (*pbs.GetWorkerResponse, error)

GetWorker implements the interface pbs.WorkerServiceServer.

func (Service) ListWorkers

func (s Service) ListWorkers(ctx context.Context, req *pbs.ListWorkersRequest) (*pbs.ListWorkersResponse, error)

ListWorkers implements the interface pbs.WorkerServiceServer.

func (Service) ReadCertificateAuthority

func (s Service) ReadCertificateAuthority(ctx context.Context, req *pbs.ReadCertificateAuthorityRequest) (*pbs.ReadCertificateAuthorityResponse, error)

ReadCertificateAuthority will list the next and current certificates for the worker certificate authority

func (Service) ReinitializeCertificateAuthority

func (s Service) ReinitializeCertificateAuthority(ctx context.Context, req *pbs.ReinitializeCertificateAuthorityRequest) (*pbs.ReinitializeCertificateAuthorityResponse, error)

ReinitializeCertificateAuthority will delete and regenerate the next and current certificates for the worker certificate authority

func (Service) RemoveWorkerTags

func (s Service) RemoveWorkerTags(ctx context.Context, req *pbs.RemoveWorkerTagsRequest) (*pbs.RemoveWorkerTagsResponse, error)

RemoveWorkerTags implements the interface pbs.WorkerServiceServer.

func (Service) SetWorkerTags

func (s Service) SetWorkerTags(ctx context.Context, req *pbs.SetWorkerTagsRequest) (*pbs.SetWorkerTagsResponse, error)

SetWorkerTags implements the interface pbs.WorkerServiceServer.

func (Service) UpdateWorker

func (s Service) UpdateWorker(ctx context.Context, req *pbs.UpdateWorkerRequest) (*pbs.UpdateWorkerResponse, error)

UpdateWorker implements the interface pbs.WorkerServiceServer.