service

Documentation

Overview

Package service application logic

Index

• type AccessControl
  • func NewAccessControl(simpleGraph domain.Graph) *AccessControl
  • func (ac *AccessControl) ModifyAccessControlList(_ context.Context, op *domain.UpdateAccessControlList) error
  • func (ac *AccessControl) ServiceRegistered(_ context.Context, op *domain.NewServiceRegistered) (*domain.ServiceRegistered, error)
  • func (ac *AccessControl) ServiceUpdated(_ context.Context, _ *domain.UpdateRegisteredService) error
  • func (ac *AccessControl) VerifyServiceAccess(_ context.Context, ace *domain.AccessControlEntry) error
  • func (ac *AccessControl) VerifyUserAccess(_ context.Context, ace *domain.AccessControlEntry) error
• type Bundle
  • func NewBundle(logger *zap.Logger, accessControl domain.AccessController, ...) *Bundle
  • func (b *Bundle) Close() error
  • func (b *Bundle) Subscribe(ctx context.Context) error

Types

type AccessControl

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

AccessControl access controller implementation

func NewAccessControl

func NewAccessControl(simpleGraph domain.Graph) *AccessControl

NewAccessControl constructor

func (*AccessControl) ModifyAccessControlList

func (ac *AccessControl) ModifyAccessControlList(_ context.Context, op *domain.UpdateAccessControlList) error

ModifyAccessControlList update existing access control list entry

func (*AccessControl) ServiceRegistered

func (ac *AccessControl) ServiceRegistered(_ context.Context, op *domain.NewServiceRegistered) (*domain.ServiceRegistered, error)

ServiceRegistered add new entry to access control list

func (*AccessControl) ServiceUpdated

func (ac *AccessControl) ServiceUpdated(_ context.Context, _ *domain.UpdateRegisteredService) error

ServiceUpdated todo

func (*AccessControl) VerifyServiceAccess

func (ac *AccessControl) VerifyServiceAccess(_ context.Context, ace *domain.AccessControlEntry) error

VerifyServiceAccess with graph

func (*AccessControl) VerifyUserAccess

func (ac *AccessControl) VerifyUserAccess(_ context.Context, ace *domain.AccessControlEntry) error

VerifyUserAccess with graph

type Bundle

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

Bundle application global

func NewBundle

func NewBundle(logger *zap.Logger, accessControl domain.AccessController, broker pkgdomain.MessageBroker) *Bundle

NewBundle constructor

func (*Bundle) Close

func (b *Bundle) Close() error

Close external service connections

func (*Bundle) Subscribe

func (b *Bundle) Subscribe(ctx context.Context) error

Subscribe to subscriptions topics