handler

Documentation

Index

• Variables
• type BlobEventContext
  • func BlobEventDummy(ctx *BlobEventContext) (*BlobEventContext, error)
  • func NewBlobEventContext(msg *storage.ServerMessage) *BlobEventContext
  • func (c *BlobEventContext) ToClientMessage() *storage.ClientMessage
  • func (c *BlobEventContext) WithError(err error)
• type BlobEventHandler
• type BlobEventMiddleware
  • func ComposeBlobEventMiddleware(funcs ...BlobEventMiddleware) BlobEventMiddleware
• type BlobEventRequest
• type BlobEventResponse
• type BlobEventType
• type FileEventContext
• type FileEventHandler
• type FileEventMiddleware
  • func ComposeFileEventMiddleware(funcs ...FileEventMiddleware) FileEventMiddleware
• type FileEventRequest
• type FileEventResponse
• type HttpContext
  • func HttpDummy(ctx *HttpContext) (*HttpContext, error)
  • func NewHttpContext(msg *http.ServerMessage) *HttpContext
  • func (c *HttpContext) ToClientMessage() *http.ClientMessage
  • func (c *HttpContext) WithError(err error)
• type HttpHandler
• type HttpMiddleware
  • func ComposeHttpMiddleware(funcs ...HttpMiddleware) HttpMiddleware
• type HttpRequest
• type HttpResponse
• type IntervalContext
  • func IntervalDummy(ctx *IntervalContext) (*IntervalContext, error)
  • func NewIntervalContext(msg *schedules.ServerMessage) *IntervalContext
  • func (c *IntervalContext) ToClientMessage() *schedules.ClientMessage
  • func (c *IntervalContext) WithError(err error)
• type IntervalHandler
• type IntervalMiddleware
  • func ComposeIntervalMiddleware(funcs ...IntervalMiddleware) IntervalMiddleware
• type IntervalRequest
• type IntervalResponse
• type MessageContext
  • func MessageDummy(ctx *MessageContext) (*MessageContext, error)
  • func NewMessageContext(msg *topics.ServerMessage) *MessageContext
  • func (c *MessageContext) ToClientMessage() *topics.ClientMessage
  • func (c *MessageContext) WithError(err error)
• type MessageHandler
• type MessageMiddleware
  • func ComposeMessageMiddleware(funcs ...MessageMiddleware) MessageMiddleware
• type MessageRequest
• type MessageResponse
• type WebsocketContext
  • func NewWebsocketContext(msg *websockets.ServerMessage) *WebsocketContext
  • func WebsocketDummy(ctx *WebsocketContext) (*WebsocketContext, error)
  • func (c *WebsocketContext) ToClientMessage() *websockets.ClientMessage
  • func (c *WebsocketContext) WithError(err error)
• type WebsocketEventType
• type WebsocketHandler
• type WebsocketMiddleware
  • func ComposeWebsocketMiddleware(funcs ...WebsocketMiddleware) WebsocketMiddleware
• type WebsocketRequest
• type WebsocketResponse

Variables

var BlobEventTypes = []BlobEventType{WriteNotification, DeleteNotification}

var WebsocketEventTypes = []WebsocketEventType{WebsocketConnect, WebsocketDisconnect, WebsocketMessage}

Types

type BlobEventContext

type BlobEventContext struct {
	Request  BlobEventRequest
	Response *BlobEventResponse
	Extras   map[string]interface{}
	// contains filtered or unexported fields
}

func BlobEventDummy

func BlobEventDummy(ctx *BlobEventContext) (*BlobEventContext, error)

func NewBlobEventContext

func NewBlobEventContext(msg *storage.ServerMessage) *BlobEventContext

func (*BlobEventContext) ToClientMessage

func (c *BlobEventContext) ToClientMessage() *storage.ClientMessage

func (*BlobEventContext) WithError

func (c *BlobEventContext) WithError(err error)

type BlobEventHandler

type BlobEventHandler = func(*BlobEventContext) (*BlobEventContext, error)

type BlobEventMiddleware

type BlobEventMiddleware = func(*BlobEventContext, BlobEventHandler) (*BlobEventContext, error)

func ComposeBlobEventMiddleware

func ComposeBlobEventMiddleware(funcs ...BlobEventMiddleware) BlobEventMiddleware

ComposeEventMiddleware - Composes an array of middleware into a single middleware

type BlobEventRequest

type BlobEventRequest interface {
	Key() string
	NotificationType() BlobEventType
}

type BlobEventResponse

type BlobEventResponse struct {
	Success bool
}

type BlobEventType

type BlobEventType string

const (
	WriteNotification  BlobEventType = "write"
	DeleteNotification BlobEventType = "delete"
)

type FileEventContext

type FileEventContext struct {
	Request  FileEventRequest
	Response *FileEventResponse
	Extras   map[string]interface{}
}

type FileEventHandler

type FileEventHandler = func(*FileEventContext) (*FileEventContext, error)

type FileEventMiddleware

type FileEventMiddleware = func(*FileEventContext, FileEventHandler) (*FileEventContext, error)

func ComposeFileEventMiddleware

func ComposeFileEventMiddleware(funcs ...FileEventMiddleware) FileEventMiddleware

ComposeEventMiddleware - Composes an array of middleware into a single middleware

type FileEventRequest

type FileEventRequest interface {
	Bucket() *storage.Bucket
	NotificationType() BlobEventType
}

type FileEventResponse

type FileEventResponse struct {
	Success bool
}

type HttpContext

type HttpContext struct {
	Request  HttpRequest
	Response *HttpResponse
	Extras   map[string]interface{}
	// contains filtered or unexported fields
}

func HttpDummy

func HttpDummy(ctx *HttpContext) (*HttpContext, error)

func NewHttpContext

func NewHttpContext(msg *http.ServerMessage) *HttpContext

func (*HttpContext) ToClientMessage

func (c *HttpContext) ToClientMessage() *http.ClientMessage

func (*HttpContext) WithError

func (c *HttpContext) WithError(err error)

type HttpHandler

type HttpHandler = func(*HttpContext) (*HttpContext, error)

type HttpMiddleware

type HttpMiddleware = func(*HttpContext, HttpHandler) (*HttpContext, error)

func ComposeHttpMiddleware

func ComposeHttpMiddleware(funcs ...HttpMiddleware) HttpMiddleware

ComposeHttpMiddleware - Composes an array of middleware into a single middleware

type HttpRequest

type HttpRequest interface {
	Method() string
	Path() string
	Data() []byte
	Query() map[string][]string
	Headers() map[string][]string
	PathParams() map[string]string
}

type HttpResponse

type HttpResponse struct {
	Status  int
	Headers map[string][]string
	Body    []byte
}

type IntervalContext

type IntervalContext struct {
	Request  IntervalRequest
	Response *IntervalResponse
	Extras   map[string]interface{}
	// contains filtered or unexported fields
}

func IntervalDummy

func IntervalDummy(ctx *IntervalContext) (*IntervalContext, error)

func NewIntervalContext

func NewIntervalContext(msg *schedules.ServerMessage) *IntervalContext

func (*IntervalContext) ToClientMessage

func (c *IntervalContext) ToClientMessage() *schedules.ClientMessage

func (*IntervalContext) WithError

func (c *IntervalContext) WithError(err error)

type IntervalHandler

type IntervalHandler = func(*IntervalContext) (*IntervalContext, error)

type IntervalMiddleware

type IntervalMiddleware = func(*IntervalContext, IntervalHandler) (*IntervalContext, error)

func ComposeIntervalMiddleware

func ComposeIntervalMiddleware(funcs ...IntervalMiddleware) IntervalMiddleware

ComposeIntervalMiddleware - Composes an array of middleware into a single middleware

type IntervalRequest

type IntervalRequest interface {
	ScheduleName() string
}

type IntervalResponse

type IntervalResponse struct {
	Success bool
}

type MessageContext

type MessageContext struct {
	Request  MessageRequest
	Response *MessageResponse
	Extras   map[string]interface{}
	// contains filtered or unexported fields
}

func MessageDummy

func MessageDummy(ctx *MessageContext) (*MessageContext, error)

func NewMessageContext

func NewMessageContext(msg *topics.ServerMessage) *MessageContext

func (*MessageContext) ToClientMessage

func (c *MessageContext) ToClientMessage() *topics.ClientMessage

func (*MessageContext) WithError

func (c *MessageContext) WithError(err error)

type MessageHandler

type MessageHandler = func(*MessageContext) (*MessageContext, error)

type MessageMiddleware

type MessageMiddleware = func(*MessageContext, MessageHandler) (*MessageContext, error)

func ComposeMessageMiddleware

func ComposeMessageMiddleware(funcs ...MessageMiddleware) MessageMiddleware

ComposeMessageMiddleware - Composes an array of middleware into a single middleware

type MessageRequest

type MessageRequest interface {
	TopicName() string
	Message() map[string]interface{}
}

type MessageResponse

type MessageResponse struct {
	Success bool
}

type WebsocketContext

type WebsocketContext struct {
	Request  WebsocketRequest
	Response *WebsocketResponse
	Extras   map[string]interface{}
	// contains filtered or unexported fields
}

func NewWebsocketContext

func NewWebsocketContext(msg *websockets.ServerMessage) *WebsocketContext

func WebsocketDummy

func WebsocketDummy(ctx *WebsocketContext) (*WebsocketContext, error)

func (*WebsocketContext) ToClientMessage

func (c *WebsocketContext) ToClientMessage() *websockets.ClientMessage

func (*WebsocketContext) WithError

func (c *WebsocketContext) WithError(err error)

type WebsocketEventType

type WebsocketEventType string

const (
	WebsocketConnect    WebsocketEventType = "connect"
	WebsocketDisconnect WebsocketEventType = "disconnect"
	WebsocketMessage    WebsocketEventType = "message"
)

type WebsocketHandler

type WebsocketHandler = func(*WebsocketContext) (*WebsocketContext, error)

type WebsocketMiddleware

type WebsocketMiddleware = func(*WebsocketContext, WebsocketHandler) (*WebsocketContext, error)

func ComposeWebsocketMiddleware

func ComposeWebsocketMiddleware(funcs ...WebsocketMiddleware) WebsocketMiddleware

ComposeWebsocketMiddleware - Composes an array of middleware into a single middleware

type WebsocketRequest

type WebsocketRequest interface {
	SocketName() string
	EventType() WebsocketEventType
	ConnectionID() string
	QueryParams() map[string][]string
	Message() string
}

type WebsocketResponse

type WebsocketResponse struct {
	Reject bool
}