pkg/clientapi/common/common_client.go

   1 // Code generated by go-swagger; DO NOT EDIT.
   2
   3 package common
   4
   5 // This file was generated by the swagger tool.
   6 // Editing this file might prove futile when you re-run the swagger generate command
   7
   8 import (
   9         "github.com/go-openapi/runtime"
  10
  11         strfmt "github.com/go-openapi/strfmt"
  12 )
  13
  14 // New creates a new common API client.
  15 func New(transport runtime.ClientTransport, formats strfmt.Registry) *Client {
  16         return &Client{transport: transport, formats: formats}
  17 }
  18
  19 /*
  20 Client for common API
  21 */
  22 type Client struct {
  23         transport runtime.ClientTransport
  24         formats   strfmt.Registry
  25 }
  26
  27 /*
  28 Subscribe subscribes a list of x2 a p event triggers to receive messages sent by r a n
  29 */
  30 func (a *Client) Subscribe(params *SubscribeParams) (*SubscribeCreated, error) {
  31         // TODO: Validate the params before sending
  32         if params == nil {
  33                 params = NewSubscribeParams()
  34         }
  35
  36         result, err := a.transport.Submit(&runtime.ClientOperation{
  37                 ID:                 "Subscribe",
  38                 Method:             "POST",
  39                 PathPattern:        "/subscriptions",
  40                 ProducesMediaTypes: []string{"application/json"},
  41                 ConsumesMediaTypes: []string{"application/json"},
  42                 Schemes:            []string{"http"},
  43                 Params:             params,
  44                 Reader:             &SubscribeReader{formats: a.formats},
  45                 Context:            params.Context,
  46                 Client:             params.HTTPClient,
  47         })
  48         if err != nil {
  49                 return nil, err
  50         }
  51         return result.(*SubscribeCreated), nil
  52
  53 }
  54
  55 /*
  56 Unsubscribe unsubscribes x2 a p events from subscription manager
  57 */
  58 func (a *Client) Unsubscribe(params *UnsubscribeParams) (*UnsubscribeNoContent, error) {
  59         // TODO: Validate the params before sending
  60         if params == nil {
  61                 params = NewUnsubscribeParams()
  62         }
  63
  64         result, err := a.transport.Submit(&runtime.ClientOperation{
  65                 ID:                 "Unsubscribe",
  66                 Method:             "DELETE",
  67                 PathPattern:        "/subscriptions/{subscriptionId}",
  68                 ProducesMediaTypes: []string{"application/json"},
  69                 ConsumesMediaTypes: []string{"application/json"},
  70                 Schemes:            []string{"http"},
  71                 Params:             params,
  72                 Reader:             &UnsubscribeReader{formats: a.formats},
  73                 Context:            params.Context,
  74                 Client:             params.HTTPClient,
  75         })
  76         if err != nil {
  77                 return nil, err
  78         }
  79         return result.(*UnsubscribeNoContent), nil
  80
  81 }
  82
  83 /*
  84 GetAllSubscriptions returns list of subscriptions
  85 */
  86 func (a *Client) GetAllSubscriptions(params *GetAllSubscriptionsParams) (*GetAllSubscriptionsOK, error) {
  87         // TODO: Validate the params before sending
  88         if params == nil {
  89                 params = NewGetAllSubscriptionsParams()
  90         }
  91
  92         result, err := a.transport.Submit(&runtime.ClientOperation{
  93                 ID:                 "getAllSubscriptions",
  94                 Method:             "GET",
  95                 PathPattern:        "/subscriptions",
  96                 ProducesMediaTypes: []string{"application/json"},
  97                 ConsumesMediaTypes: []string{""},
  98                 Schemes:            []string{"http"},
  99                 Params:             params,
 100                 Reader:             &GetAllSubscriptionsReader{formats: a.formats},
 101                 Context:            params.Context,
 102                 Client:             params.HTTPClient,
 103         })
 104         if err != nil {
 105                 return nil, err
 106         }
 107         return result.(*GetAllSubscriptionsOK), nil
 108
 109 }
 110
 111 // SetTransport changes the transport on the client
 112 func (a *Client) SetTransport(transport runtime.ClientTransport) {
 113         a.transport = transport
 114 }