handle

package
v0.9.15 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Oct 1, 2019 License: Apache-2.0 Imports: 11 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

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

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL