server

Documentation

Index

• type ActionAuthorizer
• type Authorizer
  • func NewAuthorizer(permissionChecker authorization.PermissionChecker) *Authorizer
  • func (b *Authorizer) AuthorizeAction(ctx *armadacontext.Context, perm permission.Permission) error
  • func (b *Authorizer) AuthorizeQueueAction(ctx *armadacontext.Context, queue queue.Queue, anyPerm permission.Permission, ...) error
• type EventServer
  • func NewEventServer(authorizer ActionAuthorizer, eventRepository repository.EventRepository, ...) *EventServer
  • func (s *EventServer) GetJobSetEvents(request *api.JobSetRequest, stream api.Event_GetJobSetEventsServer) error
  • func (s *EventServer) Health(_ context.Context, _ *types.Empty) (*api.HealthCheckResponse, error)
  • func (s *EventServer) Watch(req *api.WatchRequest, stream api.Event_WatchServer) error

Types

type ActionAuthorizer

type ActionAuthorizer interface {
	AuthorizeAction(ctx *armadacontext.Context, perm permission.Permission) error
	AuthorizeQueueAction(ctx *armadacontext.Context, queue queue.Queue, anyPerm permission.Permission, perm queue.PermissionVerb) error
}

type Authorizer

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

func NewAuthorizer

func NewAuthorizer(permissionChecker authorization.PermissionChecker) *Authorizer

func (*Authorizer) AuthorizeAction

func (b *Authorizer) AuthorizeAction(ctx *armadacontext.Context, perm permission.Permission) error

func (*Authorizer) AuthorizeQueueAction

func (b *Authorizer) AuthorizeQueueAction(
	ctx *armadacontext.Context,
	queue queue.Queue,
	anyPerm permission.Permission,
	perm queue.PermissionVerb,
) error

type EventServer

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

func NewEventServer

func NewEventServer(
	authorizer ActionAuthorizer,
	eventRepository repository.EventRepository,
	queueRepository repository.ReadOnlyQueueRepository,
	jobRepository repository.JobRepository,
) *EventServer

func (*EventServer) GetJobSetEvents

func (s *EventServer) GetJobSetEvents(request *api.JobSetRequest, stream api.Event_GetJobSetEventsServer) error

GetJobSetEvents streams back all events associated with a particular job set.

func (*EventServer) Health

func (s *EventServer) Health(_ context.Context, _ *types.Empty) (*api.HealthCheckResponse, error)

func (*EventServer) Watch

func (s *EventServer) Watch(req *api.WatchRequest, stream api.Event_WatchServer) error