askflume

Documentation

Index

• func GetQuery(message *mashupsdk.MashupDetailedElement)
• func InitGoogleChat(authToken string) error
• func ProcessAskFlumeController(tfmContext *flowcore.TrcFlowMachineContext, ...) error
• type FlumeHandler
  • func (msdk *FlumeHandler) GetElements() (*mashupsdk.MashupDetailedElementBundle, error)
  • func (msdk *FlumeHandler) GetMashupElements() (*mashupsdk.MashupDetailedElementBundle, error)
  • func (msdk *FlumeHandler) OnDisplayChange(displayHint *mashupsdk.MashupDisplayHint)
  • func (msdk *FlumeHandler) OnResize(displayHint *mashupsdk.MashupDisplayHint)
  • func (msdk *FlumeHandler) ResetG3NDetailedElementStates()
  • func (msdk *FlumeHandler) ResetStates()
  • func (msdk *FlumeHandler) TweakStates(elementStateBundle *mashupsdk.MashupElementStateBundle) (*mashupsdk.MashupElementStateBundle, error)
  • func (msdk *FlumeHandler) TweakStatesByMotiv(mashupsdk.Motiv)
  • func (msdk *FlumeHandler) UpsertElements(detailedElementBundle *mashupsdk.MashupDetailedElementBundle) (*mashupsdk.MashupDetailedElementBundle, error)
  • func (msdk *FlumeHandler) UpsertMashupElements(detailedElementBundle *mashupsdk.MashupDetailedElementBundle) (*mashupsdk.MashupDetailedElementBundle, error)
  • func (msdk *FlumeHandler) UpsertMashupElementsState(elementStateBundle *mashupsdk.MashupElementStateBundle) (*mashupsdk.MashupElementStateBundle, error)
• type FlumeWorldApp
  • func (w *FlumeWorldApp) InitServer(callerCreds string, insecure bool, maxMessageLength int)
• type FlumeWorldContext
• type WorldClientInitHandler
  • func (w *WorldClientInitHandler) RegisterContext(context *mashupsdk.MashupContext)

Functions

func GetQuery

func GetQuery(message *mashupsdk.MashupDetailedElement)

Processes the given message and updates the context based on the message.Data, message.Alias, and message.Name

func InitGoogleChat

func InitGoogleChat(authToken string) error

Initializes client of server running in cloud Sets up polling loop for upserting elements to cloud server Processes returned and updated elements

func ProcessAskFlumeController

func ProcessAskFlumeController(tfmContext *flowcore.TrcFlowMachineContext, trcFlowContext *flowcore.TrcFlowContext) error

Initializes the Flume side of AskFlume Called by ProcessFlowController in buildopts/flowopts/flow_tc.go

Types

type FlumeHandler

type FlumeHandler struct {
}

func (*FlumeHandler) GetElements

func (msdk *FlumeHandler) GetElements() (*mashupsdk.MashupDetailedElementBundle, error)

func (*FlumeHandler) GetMashupElements

func (msdk *FlumeHandler) GetMashupElements() (*mashupsdk.MashupDetailedElementBundle, error)

func (*FlumeHandler) OnDisplayChange

func (msdk *FlumeHandler) OnDisplayChange(displayHint *mashupsdk.MashupDisplayHint)

func (*FlumeHandler) OnResize

func (msdk *FlumeHandler) OnResize(displayHint *mashupsdk.MashupDisplayHint)

func (*FlumeHandler) ResetG3NDetailedElementStates

func (msdk *FlumeHandler) ResetG3NDetailedElementStates()

func (*FlumeHandler) ResetStates

func (msdk *FlumeHandler) ResetStates()

func (*FlumeHandler) TweakStates

func (msdk *FlumeHandler) TweakStates(elementStateBundle *mashupsdk.MashupElementStateBundle) (*mashupsdk.MashupElementStateBundle, error)

func (*FlumeHandler) TweakStatesByMotiv

func (msdk *FlumeHandler) TweakStatesByMotiv(mashupsdk.Motiv)

func (*FlumeHandler) UpsertElements

func (msdk *FlumeHandler) UpsertElements(detailedElementBundle *mashupsdk.MashupDetailedElementBundle) (*mashupsdk.MashupDetailedElementBundle, error)

func (*FlumeHandler) UpsertMashupElements

func (msdk *FlumeHandler) UpsertMashupElements(detailedElementBundle *mashupsdk.MashupDetailedElementBundle) (*mashupsdk.MashupDetailedElementBundle, error)

func (*FlumeHandler) UpsertMashupElementsState

func (msdk *FlumeHandler) UpsertMashupElementsState(elementStateBundle *mashupsdk.MashupElementStateBundle) (*mashupsdk.MashupElementStateBundle, error)

type FlumeWorldApp

type FlumeWorldApp struct {
	MashupSdkApiHandler *FlumeHandler
	FlumeWorldContext   *mashupsdk.MashupContext //*FlumeWorldContext

	WClientInitHandler           *WorldClientInitHandler
	DetailedElements             []*mashupsdk.MashupDetailedElement
	MashupDetailedElementLibrary map[int64]*mashupsdk.MashupDetailedElement
	ElementLoaderIndex           map[string]int64 // mashup indexes by Name
	// contains filtered or unexported fields
}

var Flumeworld FlumeWorldApp

func (*FlumeWorldApp) InitServer

func (w *FlumeWorldApp) InitServer(callerCreds string, insecure bool, maxMessageLength int)

type FlumeWorldContext

type FlumeWorldContext struct {
	MashupContext *mashupsdk.MashupContext // Needed for callbacks to other mashups
}

type WorldClientInitHandler

type WorldClientInitHandler struct {
}

func (*WorldClientInitHandler) RegisterContext

func (w *WorldClientInitHandler) RegisterContext(context *mashupsdk.MashupContext)