handle

Documentation

Index

• type ActivateObject
  • func NewActivateObject(dep *proc.Dependencies, msg payload.Meta, passed bool) *ActivateObject
  • func (s *ActivateObject) Present(ctx context.Context, f flow.Flow) error
• type DeactivateObject
  • func NewDeactivateObject(dep *proc.Dependencies, msg payload.Meta, passed bool) *DeactivateObject
  • func (s *DeactivateObject) Present(ctx context.Context, f flow.Flow) error
• type Error
  • func NewError(msg *message.Message) *Error
  • func (s *Error) Present(ctx context.Context, f flow.Flow) error
• type GetCode
  • func NewGetCode(dep *proc.Dependencies, meta payload.Meta, passed bool) *GetCode
  • func (s *GetCode) Present(ctx context.Context, f flow.Flow) error
• type GetFilament
  • func NewGetFilament(dep *proc.Dependencies, meta payload.Meta) *GetFilament
  • func (s *GetFilament) Present(ctx context.Context, f flow.Flow) error
• type GetJet
  • func NewGetJet(dep *proc.Dependencies, meta payload.Meta, passed bool) *GetJet
  • func (h *GetJet) Present(ctx context.Context, f flow.Flow) error
• type GetObject
  • func NewGetObject(dep *proc.Dependencies, meta payload.Meta, passed bool) *GetObject
  • func (s *GetObject) Present(ctx context.Context, f flow.Flow) error
• type GetPendings
  • func NewGetPendings(dep *proc.Dependencies, meta payload.Meta, passed bool) *GetPendings
  • func (s *GetPendings) Present(ctx context.Context, f flow.Flow) error
• type GetRequest
  • func NewGetRequest(dep *proc.Dependencies, msg payload.Meta, passed bool) *GetRequest
  • func (s *GetRequest) Present(ctx context.Context, f flow.Flow) error
• type GetRequestInfo
  • func NewGetRequestInfo(dep *proc.Dependencies, meta payload.Meta) *GetRequestInfo
  • func (s *GetRequestInfo) Present(ctx context.Context, f flow.Flow) error
• type HasPendings
  • func NewHasPendings(dep *proc.Dependencies, meta payload.Meta, passed bool) *HasPendings
  • func (s *HasPendings) Present(ctx context.Context, f flow.Flow) error
• type HotObjects
  • func NewHotObjects(dep *proc.Dependencies, meta payload.Meta) *HotObjects
  • func (s *HotObjects) Present(ctx context.Context, f flow.Flow) error
• type Init
  • func NewInit(dep *proc.Dependencies, sender bus.Sender, msg *message.Message) *Init
  • func (s *Init) Future(ctx context.Context, f flow.Flow) error
  • func (s *Init) Past(ctx context.Context, f flow.Flow) error
  • func (s *Init) Present(ctx context.Context, f flow.Flow) error
• type PassState
  • func NewPassState(dep *proc.Dependencies, meta payload.Meta) *PassState
  • func (s *PassState) Present(ctx context.Context, f flow.Flow) error
• type SetCode
  • func NewSetCode(dep *proc.Dependencies, msg payload.Meta, passed bool) *SetCode
  • func (s *SetCode) Present(ctx context.Context, f flow.Flow) error
• type SetIncomingRequest
  • func NewSetIncomingRequest(dep *proc.Dependencies, msg payload.Meta, passed bool) *SetIncomingRequest
  • func (s *SetIncomingRequest) Present(ctx context.Context, f flow.Flow) error
• type SetOutgoingRequest
  • func NewSetOutgoingRequest(dep *proc.Dependencies, msg payload.Meta, passed bool) *SetOutgoingRequest
  • func (s *SetOutgoingRequest) Present(ctx context.Context, f flow.Flow) error
• type SetResult
  • func NewSetResult(dep *proc.Dependencies, msg payload.Meta, passed bool) *SetResult
  • func (s *SetResult) Present(ctx context.Context, f flow.Flow) error
• type UpdateObject
  • func NewUpdateObject(dep *proc.Dependencies, msg payload.Meta, passed bool) *UpdateObject
  • func (s *UpdateObject) Present(ctx context.Context, f flow.Flow) error

Types

type ActivateObject

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

func NewActivateObject

func NewActivateObject(dep *proc.Dependencies, msg payload.Meta, passed bool) *ActivateObject

func (*ActivateObject) Present

func (s *ActivateObject) Present(ctx context.Context, f flow.Flow) error

type DeactivateObject

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

func NewDeactivateObject

func NewDeactivateObject(dep *proc.Dependencies, msg payload.Meta, passed bool) *DeactivateObject

func (*DeactivateObject) Present

func (s *DeactivateObject) Present(ctx context.Context, f flow.Flow) error

type Error

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

func NewError

func NewError(msg *message.Message) *Error

func (*Error) Present

func (s *Error) Present(ctx context.Context, f flow.Flow) error

type GetCode

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

func NewGetCode

func NewGetCode(dep *proc.Dependencies, meta payload.Meta, passed bool) *GetCode

func (*GetCode) Present

func (s *GetCode) Present(ctx context.Context, f flow.Flow) error

type GetFilament

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

func NewGetFilament

func NewGetFilament(dep *proc.Dependencies, meta payload.Meta) *GetFilament

func (*GetFilament) Present

func (s *GetFilament) Present(ctx context.Context, f flow.Flow) error

type GetJet

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

func NewGetJet

func NewGetJet(dep *proc.Dependencies, meta payload.Meta, passed bool) *GetJet

func (*GetJet) Present

func (h *GetJet) Present(ctx context.Context, f flow.Flow) error

type GetObject

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

func NewGetObject

func NewGetObject(dep *proc.Dependencies, meta payload.Meta, passed bool) *GetObject

func (*GetObject) Present

func (s *GetObject) Present(ctx context.Context, f flow.Flow) error

type GetPendings

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

func NewGetPendings

func NewGetPendings(dep *proc.Dependencies, meta payload.Meta, passed bool) *GetPendings

func (*GetPendings) Present

func (s *GetPendings) Present(ctx context.Context, f flow.Flow) error

type GetRequest

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

func NewGetRequest

func NewGetRequest(dep *proc.Dependencies, msg payload.Meta, passed bool) *GetRequest

func (*GetRequest) Present

func (s *GetRequest) Present(ctx context.Context, f flow.Flow) error

type GetRequestInfo

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

func NewGetRequestInfo

func NewGetRequestInfo(dep *proc.Dependencies, meta payload.Meta) *GetRequestInfo

func (*GetRequestInfo) Present

func (s *GetRequestInfo) Present(ctx context.Context, f flow.Flow) error

type HasPendings

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

func NewHasPendings

func NewHasPendings(dep *proc.Dependencies, meta payload.Meta, passed bool) *HasPendings

func (*HasPendings) Present

func (s *HasPendings) Present(ctx context.Context, f flow.Flow) error

type HotObjects

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

func NewHotObjects

func NewHotObjects(dep *proc.Dependencies, meta payload.Meta) *HotObjects

func (*HotObjects) Present

func (s *HotObjects) Present(ctx context.Context, f flow.Flow) error

type Init

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

func NewInit

func NewInit(dep *proc.Dependencies, sender bus.Sender, msg *message.Message) *Init

func (*Init) Future

func (s *Init) Future(ctx context.Context, f flow.Flow) error

func (*Init) Past

func (s *Init) Past(ctx context.Context, f flow.Flow) error

func (*Init) Present

func (s *Init) Present(ctx context.Context, f flow.Flow) error

type PassState

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

func NewPassState

func NewPassState(dep *proc.Dependencies, meta payload.Meta) *PassState

func (*PassState) Present

func (s *PassState) Present(ctx context.Context, f flow.Flow) error

type SetCode

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

func NewSetCode

func NewSetCode(dep *proc.Dependencies, msg payload.Meta, passed bool) *SetCode

func (*SetCode) Present

func (s *SetCode) Present(ctx context.Context, f flow.Flow) error

type SetIncomingRequest

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

func NewSetIncomingRequest

func NewSetIncomingRequest(dep *proc.Dependencies, msg payload.Meta, passed bool) *SetIncomingRequest

func (*SetIncomingRequest) Present

func (s *SetIncomingRequest) Present(ctx context.Context, f flow.Flow) error

type SetOutgoingRequest

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

func NewSetOutgoingRequest

func NewSetOutgoingRequest(dep *proc.Dependencies, msg payload.Meta, passed bool) *SetOutgoingRequest

func (*SetOutgoingRequest) Present

func (s *SetOutgoingRequest) Present(ctx context.Context, f flow.Flow) error

type SetResult

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

func NewSetResult

func NewSetResult(dep *proc.Dependencies, msg payload.Meta, passed bool) *SetResult

func (*SetResult) Present

func (s *SetResult) Present(ctx context.Context, f flow.Flow) error

type UpdateObject

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

func NewUpdateObject

func NewUpdateObject(dep *proc.Dependencies, msg payload.Meta, passed bool) *UpdateObject

func (*UpdateObject) Present

func (s *UpdateObject) Present(ctx context.Context, f flow.Flow) error