rest

Documentation

Overview

Package rest exposes a Rest service for querying activities feed

Index

• type ActivityHandler
  • func NewActivityHandler() *ActivityHandler
  • func (a *ActivityHandler) Filter() func(string) string
  • func (a *ActivityHandler) FilterActivity(ctx context.Context, workspaces map[string]*idm.Workspace, ac *activity.Object) bool
  • func (a *ActivityHandler) SearchSubscriptions(req *restful.Request, rsp *restful.Response)
  • func (a *ActivityHandler) Stream(req *restful.Request, rsp *restful.Response)
  • func (a *ActivityHandler) Subscribe(req *restful.Request, rsp *restful.Response)
  • func (a *ActivityHandler) SwaggerTags() []string

Types

type ActivityHandler

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

ActivityHandler responds to activity REST requests

func NewActivityHandler

func NewActivityHandler() *ActivityHandler

func (*ActivityHandler) Filter

func (a *ActivityHandler) Filter() func(string) string

Filter returns a function to filter the swagger path

func (*ActivityHandler) FilterActivity

func (a *ActivityHandler) FilterActivity(ctx context.Context, workspaces map[string]*idm.Workspace, ac *activity.Object) bool

FilterActivity is used internally to show only authorized events depending on the context

func (*ActivityHandler) SearchSubscriptions

func (a *ActivityHandler) SearchSubscriptions(req *restful.Request, rsp *restful.Response)

SearchSubscriptions loads existing subscription for a given object

func (*ActivityHandler) Stream

func (a *ActivityHandler) Stream(req *restful.Request, rsp *restful.Response)

Stream returns a collection of activities

func (*ActivityHandler) Subscribe

func (a *ActivityHandler) Subscribe(req *restful.Request, rsp *restful.Response)

Subscribe hooks a given object to another one activity streams

func (*ActivityHandler) SwaggerTags

func (a *ActivityHandler) SwaggerTags() []string

SwaggerTags list the names of the service tags declared in the swagger json implemented by this service