CallFunction changes and new fields to Event interface (#14)

event.go

@@ -121,9 +121,15 @@ type Event interface {
 
 	// GetVersion returns the version of the event
 	GetVersion() string
+
+	// GetLastInBatch returns whether the event is the last event in a trigger specific batch
+	GetLastInBatch() bool
+
+	// GetOffset returns the offset of the event
+	GetOffset() int
 }
 
-// AbstractEvent provides a base implemention of an event
+// AbstractEvent provides a base implementation of an event
 type AbstractEvent struct {
 	triggerInfoProvider TriggerInfoProvider
 	id                  ID
@@ -137,7 +143,7 @@ func (ae *AbstractEvent) SetTriggerInfoProvider(triggerInfoProvider TriggerInfoP
 	ae.triggerInfoProvider = triggerInfoProvider
 }
 
-// GetTriggerInfo retruns a trigger info provider
+// GetTriggerInfo returns a trigger info provider
 func (ae *AbstractEvent) GetTriggerInfo() TriggerInfoProvider {
 	return ae.triggerInfoProvider
 }
@@ -276,3 +282,13 @@ func (ae *AbstractEvent) GetTypeVersion() string {
 func (ae *AbstractEvent) GetVersion() string {
 	return ""
 }
+
+// GetLastInBatch returns whether the event is the last event in a trigger specific batch
+func (ae *AbstractEvent) GetLastInBatch() bool {
+	return false
+}
+
+// GetOffset returns the offset of the event
+func (ae *AbstractEvent) GetOffset() int {
+	return 0
+}

memoryevent.go

@@ -13,9 +13,8 @@ func (me *MemoryEvent) GetMethod() string {
 	if me.Method == "" {
 		if len(me.Body) == 0 {
 			return "GET"
-		} else {
-			return "POST"
 		}
+		return "POST"
 	}
 	return me.Method
 }

platform.go

@@ -56,10 +56,15 @@ func (p *Platform) CallFunction(functionName string, event Event) (Response, err
 }
 
 func (p *Platform) getFunctionHost(name string) string {
+	var functionHost string
+
 	if p.kind == "local" {
-		return fmt.Sprintf("%s-%s:8080", p.namespace, name)
+		functionHost = fmt.Sprintf("nuclio-%s-%s", p.namespace, name)
+	} else {
+		functionHost = fmt.Sprintf("nuclio-%s", name)
 	}
-	return fmt.Sprintf("%s:8080", name)
+
+	return fmt.Sprintf("%s:8080", functionHost)
 }
 
 func (p *Platform) createRequest(functionName string, event Event) *fasthttp.Request {