processor

Documentation

Index

• Variables
• type AbstractEvent
  • func (ae *AbstractEvent) GetBody() []byte
  • func (ae *AbstractEvent) GetContentType() string
  • func (ae *AbstractEvent) GetField(key string) interface{}
  • func (ae *AbstractEvent) GetFieldByteSlice(key string) []byte
  • func (ae *AbstractEvent) GetFieldInt(key string) (int, error)
  • func (ae *AbstractEvent) GetFieldString(key string) string
  • func (ae *AbstractEvent) GetFields() map[string]interface{}
  • func (ae *AbstractEvent) GetHeader(key string) interface{}
  • func (ae *AbstractEvent) GetHeaderByteSlice(key string) []byte
  • func (ae *AbstractEvent) GetHeaderString(key string) string
  • func (ae *AbstractEvent) GetHeaders() map[string]interface{}
  • func (ae *AbstractEvent) GetID() nuclio.ID
  • func (ae *AbstractEvent) GetMethod() string
  • func (ae *AbstractEvent) GetPath() string
  • func (ae *AbstractEvent) GetSize() int
  • func (ae *AbstractEvent) GetSource() nuclio.SourceInfoProvider
  • func (ae *AbstractEvent) GetTimestamp() time.Time
  • func (ae *AbstractEvent) GetURL() string
  • func (ae *AbstractEvent) GetVersion() int
  • func (ae *AbstractEvent) SetID(id nuclio.ID)
  • func (ae *AbstractEvent) SetSourceProvider(sourceInfoProvider nuclio.SourceInfoProvider)
• type AbstractSync
  • func (as *AbstractSync) GetHostAddress() string
  • func (as *AbstractSync) GetQuery() map[string]interface{}
  • func (as *AbstractSync) GetRemoteAddress() string
  • func (as *AbstractSync) GetWorkflowStep() string

Variables

var ErrUnsupported = errors.New("Event does not support this interface")

Types

type AbstractEvent

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

func (*AbstractEvent) GetBody

func (ae *AbstractEvent) GetBody() []byte

func (*AbstractEvent) GetContentType

func (ae *AbstractEvent) GetContentType() string

func (*AbstractEvent) GetField

func (ae *AbstractEvent) GetField(key string) interface{}

func (*AbstractEvent) GetFieldByteSlice

func (ae *AbstractEvent) GetFieldByteSlice(key string) []byte

func (*AbstractEvent) GetFieldInt

func (ae *AbstractEvent) GetFieldInt(key string) (int, error)

func (*AbstractEvent) GetFieldString

func (ae *AbstractEvent) GetFieldString(key string) string

func (*AbstractEvent) GetFields

func (ae *AbstractEvent) GetFields() map[string]interface{}

func (*AbstractEvent) GetHeader

func (ae *AbstractEvent) GetHeader(key string) interface{}

func (*AbstractEvent) GetHeaderByteSlice

func (ae *AbstractEvent) GetHeaderByteSlice(key string) []byte

func (*AbstractEvent) GetHeaderString

func (ae *AbstractEvent) GetHeaderString(key string) string

func (*AbstractEvent) GetHeaders

func (ae *AbstractEvent) GetHeaders() map[string]interface{}

func (*AbstractEvent) GetID

func (ae *AbstractEvent) GetID() nuclio.ID

func (*AbstractEvent) GetMethod

func (ae *AbstractEvent) GetMethod() string

func (*AbstractEvent) GetPath

func (ae *AbstractEvent) GetPath() string

func (*AbstractEvent) GetSize

func (ae *AbstractEvent) GetSize() int

func (*AbstractEvent) GetSource

func (ae *AbstractEvent) GetSource() nuclio.SourceInfoProvider

func (*AbstractEvent) GetTimestamp

func (ae *AbstractEvent) GetTimestamp() time.Time

func (*AbstractEvent) GetURL

func (ae *AbstractEvent) GetURL() string

func (*AbstractEvent) GetVersion

func (ae *AbstractEvent) GetVersion() int

func (*AbstractEvent) SetID

func (ae *AbstractEvent) SetID(id nuclio.ID)

func (*AbstractEvent) SetSourceProvider

func (ae *AbstractEvent) SetSourceProvider(sourceInfoProvider nuclio.SourceInfoProvider)

type AbstractSync

type AbstractSync struct {
	AbstractEvent
}

func (*AbstractSync) GetHostAddress

func (as *AbstractSync) GetHostAddress() string

func (*AbstractSync) GetQuery

func (as *AbstractSync) GetQuery() map[string]interface{}

func (*AbstractSync) GetRemoteAddress

func (as *AbstractSync) GetRemoteAddress() string

func (*AbstractSync) GetWorkflowStep

func (as *AbstractSync) GetWorkflowStep() string