MicroServiceLib

type MsCfgType struct {
	ServerId string `json:"Sid"`      //
	Name     string `json:"QName"`    //	// Name of the Q to send stuff to //
	ReplyTTL uint64 `json:"ReplyTTL"` // how long will a reply last if not picked up.

	RedisConnectHost string     `json:"RedisConnectHost"` // Connection infor for Redis Database
	RedisConnectPort string     `json:"RedisConnectPort"` //
	RedisConnectAuth string     `json:"RedisConnectAuth"` //
	ReplyListenQ     string     `json:"ReplyListenQ"`     // Receives Wakie Wakie on Return
	RedisPool        *pool.Pool `json:"-"`                // Pooled Redis Client connectioninformation
	Err              error      `json:"-"`                // Error Holding Pen

	ReplyFx             map[string]*ReplyFxType             `json:"-"` //	Set of call/respond that we are waiting for answers on.
	DebugTimeoutMessage bool                                `json:"-"` // turn on/off the timeout 1ce a second message
	TickInMilliseconds  int                                 `json:"-"` // # of miliseconds for 1 tick
	ReplyFunc           func(replyMessage *MsMessageToSend) // function that will get when reply occures
	// contains filtered or unexported fields
}

type MsMessageParams struct {
	Name  string
	Value string
}

type MsMessageToSend struct {
	Id            string            `json:"Id"`                 // Unique id UUID for this message
	ActionId      string            `json:"ActionId,omitempty"` // Activity Hash ID -- unique to this activity
	GroupId       string            `json:"GroupId,omitempty"`  // Group of id's together ID -- unique to group
	CallId        string            `json:"CallId,omitempty"`   // Unique id for this call - if empty - generated and return
	SendBackTo    string            `json:"SendBackTo"`         // -- send message to -- WakieWakie
	ReplyTTL      uint64            `json:"ReplyTTL"`           // how long will a reply last if not picked up.
	To            string            `json:"-"`                  // Desitnation work Q - a name -
	ClientTimeout uint64            `json:"-"`                  // How long are you giving client to perform task
	Params        []MsMessageParams `json:"Params"`             // Set of params for client
	IsTimeout     bool              `json:"-"`                  // set on reply
}

type ReplyFxType struct {
	Key        string                                                        // translated ID for reply
	IsTimedOut bool                                                          // Flag indicating timeout occured and fx called with that.
	IsDead     bool                                                          // Flag indicating timeout occured and fx called with that.
	TickCount  int                                                           // Number of time ticks encounted
	TickMax    int                                                           // Max before timeout is set
	Fx         func(data *MsMessageToSend, rx *ReplyFxType, isTimedOut bool) //function that will get called when Key is found
}

type WorkFuncType func(arb map[string]interface{})