adapters

Documentation

Index

• type EventAdapter
  • func NewEventAdapter(conn messaging2.EventConnection) *EventAdapter
  • func (adapter *EventAdapter) SetHandlers(handlers ports.IncomingEventHandlers)
  • func (adapter *EventAdapter) Start(ctx context.Context, wg *sync.WaitGroup) error
• type MongoAdapter
  • func (adapter *MongoAdapter) Close() error
  • func (adapter *MongoAdapter) Create(actor service.Actor, provider types.Provider) error
  • func (adapter *MongoAdapter) Delete(actor service.Actor, providerID common.ID) error
  • func (adapter *MongoAdapter) Get(providerID common.ID) (types.Provider, error)
  • func (adapter *MongoAdapter) Init(config *types.Config) error
  • func (adapter *MongoAdapter) ListAll(skip, limit uint) ([]types.Provider, error)
  • func (adapter *MongoAdapter) ListPublicAndOwnedByUser(actor string, skip, limit uint) ([]types.Provider, error)
  • func (adapter *MongoAdapter) Update(providerID common.ID, update types.ProviderUpdate) error
• type QueryAdapter
  • func NewQueryAdapter(conn messaging2.QueryConnection) *QueryAdapter
  • func (adapter *QueryAdapter) SetHandlers(handlers ports.IncomingQueryHandlers)
  • func (adapter *QueryAdapter) Start(ctx context.Context, wg *sync.WaitGroup) error
• type UserSvc
  • func NewUserSvc(queryConn messaging2.QueryConnection) *UserSvc
  • func (u *UserSvc) CheckForAdmin(actor service.Actor) (actorIsAdmin bool, err error)
  • func (u *UserSvc) Init(config *types.Config) error

Types

type EventAdapter

type EventAdapter struct {
	EventWaitGroup sync.WaitGroup
	// contains filtered or unexported fields
}

EventAdapter communicates to IncomingEventPort

func NewEventAdapter

func NewEventAdapter(conn messaging2.EventConnection) *EventAdapter

NewEventAdapter ...

func (*EventAdapter) SetHandlers

func (adapter *EventAdapter) SetHandlers(handlers ports.IncomingEventHandlers)

SetHandlers ...

func (*EventAdapter) Start

func (adapter *EventAdapter) Start(ctx context.Context, wg *sync.WaitGroup) error

Start starts the adapter

type MongoAdapter

type MongoAdapter struct {
	Config *types.Config
	Store  db.ObjectStore
	// contains filtered or unexported fields
}

MongoAdapter implements PersistentStoragePort

func (*MongoAdapter) Close

func (adapter *MongoAdapter) Close() error

Close finalizes mongodb adapter

func (*MongoAdapter) Create

func (adapter *MongoAdapter) Create(actor service.Actor, provider types.Provider) error

Create inserts a Provider

func (*MongoAdapter) Delete

func (adapter *MongoAdapter) Delete(actor service.Actor, providerID common.ID) error

Delete deletes a Provider

func (*MongoAdapter) Get

func (adapter *MongoAdapter) Get(providerID common.ID) (types.Provider, error)

Get returns the Provider with the ID

func (*MongoAdapter) Init

func (adapter *MongoAdapter) Init(config *types.Config) error

Init initialize mongodb adapter

func (*MongoAdapter) ListAll

func (adapter *MongoAdapter) ListAll(skip, limit uint) ([]types.Provider, error)

ListAll ...

func (*MongoAdapter) ListPublicAndOwnedByUser

func (adapter *MongoAdapter) ListPublicAndOwnedByUser(actor string, skip, limit uint) ([]types.Provider, error)

ListPublicAndOwnedByUser returns Providers

func (*MongoAdapter) Update

func (adapter *MongoAdapter) Update(providerID common.ID, update types.ProviderUpdate) error

Update updates/edits a Provider

type QueryAdapter

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

QueryAdapter communicates to IncomingQueryPort

func NewQueryAdapter

func NewQueryAdapter(conn messaging2.QueryConnection) *QueryAdapter

NewQueryAdapter ...

func (*QueryAdapter) SetHandlers

func (adapter *QueryAdapter) SetHandlers(handlers ports.IncomingQueryHandlers)

SetHandlers ...

func (*QueryAdapter) Start

func (adapter *QueryAdapter) Start(ctx context.Context, wg *sync.WaitGroup) error

Start starts the adapter

type UserSvc

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

UserSvc implements UserService, this communicates with user service to check if a user is admin.

func NewUserSvc

func NewUserSvc(queryConn messaging2.QueryConnection) *UserSvc

NewUserSvc ...

func (*UserSvc) CheckForAdmin

func (u *UserSvc) CheckForAdmin(actor service.Actor) (actorIsAdmin bool, err error)

CheckForAdmin communicates with user service to check if a user is admin. Return error if check fails or user is NOT admin.

func (*UserSvc) Init

func (u *UserSvc) Init(config *types.Config) error

Init ...