operator

Documentation

Index

• type Service
  • func New() *Service
  • func (s *Service) EnsureAsyncContext(ctx context.Context, aSession *session.Session, ...) (context.Context, error)
  • func (s *Service) EnsureContext(ctx context.Context, aSession *session.Session, ...) (context.Context, error)
  • func (s *Service) EnsureInput(ctx context.Context, aComponent *repository.Component, ...) (context.Context, error)
  • func (s *Service) HandleError(ctx context.Context, aSession *session.Session, ...) (interface{}, error)
  • func (s *Service) HandlerSession(ctx context.Context, aComponent *repository.Component, ...) (xhandler.Session, error)
  • func (s *Service) InvocationType(ctx context.Context) async.InvocationType
  • func (s *Service) IsEventInvocation(ctx context.Context) bool
  • func (s *Service) Job(ctx context.Context) *async.Job
  • func (s *Service) Operate(ctx context.Context, aSession *session.Session, ...) (interface{}, error)

Types

type Service

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

func New

func New() *Service

func (*Service) EnsureAsyncContext

func (s *Service) EnsureAsyncContext(ctx context.Context, aSession *session.Session, aComponent *repository.Component) (context.Context, error)

func (*Service) EnsureContext

func (s *Service) EnsureContext(ctx context.Context, aSession *session.Session, aComponent *repository.Component) (context.Context, error)

func (*Service) EnsureInput

func (s *Service) EnsureInput(ctx context.Context, aComponent *repository.Component, aSession *session.Session, populateView bool) (context.Context, error)

func (*Service) HandleError

func (s *Service) HandleError(ctx context.Context, aSession *session.Session, aComponent *repository.Component, err error) (interface{}, error)

HandleError processes output with error

func (*Service) HandlerSession

func (s *Service) HandlerSession(ctx context.Context, aComponent *repository.Component, aSession *session.Session) (xhandler.Session, error)

HandlerSession returns a handler session

func (*Service) InvocationType

func (s *Service) InvocationType(ctx context.Context) async.InvocationType

func (*Service) IsEventInvocation

func (s *Service) IsEventInvocation(ctx context.Context) bool

func (*Service) Job

func (s *Service) Job(ctx context.Context) *async.Job

func (*Service) Operate

func (s *Service) Operate(ctx context.Context, aSession *session.Session, aComponent *repository.Component) (interface{}, error)

Operate processes data component with data session