handlers

package

v0.1.3 Latest Latest Go to latest Published: Oct 15, 2018 License: Apache-2.0 Imports: 21 Imported by: 0

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/containerum/events-api

Links

Open Source Insights

Documentation ¶

Overview ¶

Package router Events-API

Events-API is service for storing Kubernetes and Containerum events in MongoDB.

 Version: 0.0.1
	Consumes:
	- application/json

	Produces:
	- application/json

swagger:meta

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type EventAggregator ¶ added in v0.0.15

type EventAggregator struct {
	CTX                context.Context
	Params             model.FuncParams
	EventSource        model.EventsFunc
	EventDrain         chan<- kubeModel.Event
	ErrChan            chan<- error
	Control            *gocontrol.Guard
	DBPeriod           time.Duration
	FirstTimeWaitGroup *sync.WaitGroup
}

func (EventAggregator) Run ¶ added in v0.0.15

func (aggregate EventAggregator) Run()

type EventBatcher ¶ added in v0.0.13

type EventBatcher struct {
	Ctx                context.Context
	ErrChan            chan error
	Quant              time.Duration
	EventSource        <-chan kubeModel.Event
	BatchDrain         chan<- []kubeModel.Event
	Control            *gocontrol.Guard
	PreallocBatchSize  int
	FirstTimeWaitGroup *sync.WaitGroup
}

func (EventBatcher) Run ¶ added in v0.0.13

func (batcher EventBatcher) Run()

type EventsHandlers ¶

type EventsHandlers struct {
	server.EventsActions
	*m.TranslateValidate
	DBPeriod time.Duration
}

func (*EventsHandlers) AddSystemEventHandler ¶ added in v0.0.4

func (h *EventsHandlers) AddSystemEventHandler(ctx *gin.Context)

swagger:operation POST /events/containerum/system Events AddSystemEvent Add system event.

--- x-method-visibility: public parameters:

$ref: '#/parameters/UserRoleHeader'
$ref: '#/parameters/UserIDHeader'
name: body in: body schema: $ref: '#/definitions/Event'

responses:

'202':
  description: event added
default:
  $ref: '#/responses/error'

func (*EventsHandlers) AddUserEventHandler ¶ added in v0.0.4

func (h *EventsHandlers) AddUserEventHandler(ctx *gin.Context)

swagger:operation POST /events/containerum/users Events AddUserEvent Add user event.

--- x-method-visibility: public parameters:

$ref: '#/parameters/UserRoleHeader'
$ref: '#/parameters/UserIDHeader'
name: body in: body schema: $ref: '#/definitions/Event'

responses:

'202':
  description: event added
default:
  $ref: '#/responses/error'

func (*EventsHandlers) AllNamespaceResourcesChangesEventsHandler ¶ added in v0.0.15

func (h *EventsHandlers) AllNamespaceResourcesChangesEventsHandler(ctx *gin.Context)

swagger:operation GET /namespaces/{namespace}/all AllEvents AllNamespaceResourcesChangesEvents Get all events in namespace.

--- x-method-visibility: public parameters:

$ref: '#/parameters/UserRoleHeader'
$ref: '#/parameters/UserIDHeader'
name: namespace in: path type: string required: true
name: ws in: query type: string required: false
name: limit in: query type: string required: false
name: time in: query type: string required: false

responses:

'101':
  description: websocket response
  schema:
    $ref: '#/definitions/EventsList'
default:
  $ref: '#/responses/error'

func (*EventsHandlers) AllResourcesChangesEventsHandler ¶ added in v0.0.13

func (h *EventsHandlers) AllResourcesChangesEventsHandler(ctx *gin.Context)

swagger:operation GET /all AllEvents AllResourcesChangesEvents Get all events.

--- x-method-visibility: public parameters:

$ref: '#/parameters/UserRoleHeader'
$ref: '#/parameters/UserIDHeader'
name: ws in: query type: string required: false
name: limit in: query type: string required: false
name: time in: query type: string required: false

responses:

'101':
  description: websocket response
  schema:
    $ref: '#/definitions/EventsList'
default:
  $ref: '#/responses/error'

func (*EventsHandlers) GetNodesEventsListHandler ¶ added in v0.0.21

func (h *EventsHandlers) GetNodesEventsListHandler(ctx *gin.Context)

swagger:operation GET /events/nodes Events GetNodesEventsLis Get nodes events.

--- x-method-visibility: public parameters:

$ref: '#/parameters/UserRoleHeader'
$ref: '#/parameters/UserIDHeader'
name: ws in: query type: string required: false
name: limit in: query type: string required: false
name: time in: query type: string required: false

responses:

'200':
  description: events list
  schema:
    $ref: '#/definitions/EventsList'
'101':
  description: websocket response
  schema:
    $ref: '#/definitions/EventsList'
default:
  $ref: '#/responses/error'

func (*EventsHandlers) GetSystemEventsListHandler ¶ added in v0.0.4

func (h *EventsHandlers) GetSystemEventsListHandler(ctx *gin.Context)

swagger:operation GET /events/containerum/system Events GetSystemEventsList Get system events.

--- x-method-visibility: public parameters:

$ref: '#/parameters/UserRoleHeader'
$ref: '#/parameters/UserIDHeader'
name: ws in: query type: string required: false
name: limit in: query type: string required: false
name: time in: query type: string required: false

responses:

'200':
  description: events list
  schema:
    $ref: '#/definitions/EventsList'
'101':
  description: websocket response
  schema:
    $ref: '#/definitions/EventsList'
default:
  $ref: '#/responses/error'

func (*EventsHandlers) GetUsersEventsListHandler ¶ added in v0.0.4

func (h *EventsHandlers) GetUsersEventsListHandler(ctx *gin.Context)

swagger:operation GET /events/containerum/users Events GetUsersEventsList Get users events.

--- x-method-visibility: public parameters:

$ref: '#/parameters/UserRoleHeader'
$ref: '#/parameters/UserIDHeader'
name: ws in: query type: string required: false
name: limit in: query type: string required: false
name: time in: query type: string required: false

responses:

'200':
  description: events list
  schema:
    $ref: '#/definitions/EventsList'
'101':
  description: websocket response
  schema:
    $ref: '#/definitions/EventsList'
default:
  $ref: '#/responses/error'

func (*EventsHandlers) SelectedNamespaceResourcesChangesEventsHandler ¶ added in v0.0.15

func (h *EventsHandlers) SelectedNamespaceResourcesChangesEventsHandler(ctx *gin.Context)

swagger:operation GET /namespaces/{namespace}/selected AllEvents SelectedNamespaceResourcesChangesEvents Get selected events in namespace.

--- x-method-visibility: public parameters:

$ref: '#/parameters/UserRoleHeader'
$ref: '#/parameters/UserIDHeader'
name: namespace in: path type: string required: true
name: ws in: query type: string required: false
name: limit in: query type: string required: false
name: res in: query type: string required: false
name: time in: query type: string required: false

responses:

'101':
  description: websocket response
  schema:
    $ref: '#/definitions/EventsList'
default:
  $ref: '#/responses/error'

func (*EventsHandlers) SelectedResourcesChangesEventsHandler ¶ added in v0.0.14

func (h *EventsHandlers) SelectedResourcesChangesEventsHandler(ctx *gin.Context)

swagger:operation GET /selected AllEvents SelectedResourcesChangesEvents Get selected events.

--- x-method-visibility: public parameters:

$ref: '#/parameters/UserRoleHeader'
$ref: '#/parameters/UserIDHeader'
name: ws in: query type: string required: false
name: limit in: query type: string required: false
name: res in: query type: string required: false
name: time in: query type: string required: false

responses:

'101':
  description: websocket response
  schema:
    $ref: '#/definitions/EventsList'
default:
  $ref: '#/responses/error'

Source Files ¶

View all Source files

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL