devicegroups

type Callback = func(command messages.Command, task messages.CamundaExternalTask) (request *messages.KafkaMessage, event *messages.EventRequest, err error)

type DbInterface interface {
	Get(key string) (*memcache.Item, error)
	Set(item *memcache.Item) error
	Delete(key string) error
}

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

type LastCallInfo struct {
	Caller string    `json:"caller"`
	Time   time.Time `json:"time"`
}

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

type MessageWithState struct {
	Message messages.KafkaMessage
	State   SubTaskState
}

type RequestInfo = messages.RequestInfo

type RequestInfoList = messages.RequestInfoList

type SubResultWrapper struct {
	Failed bool
	Value  interface{}
}

type SubTaskState = messages.SubTaskState