apiclient

Jul 12, 2023

Changes in this version

+ var CaCertPool *x509.CertPool

+ var Cert *tls.Certificate

+ var InsecureSkipVerify = false

+ func CheckResponse(r *http.Response) error

+ type APIKeyTransport struct

+ APIKey string

+ Transport http.RoundTripper

+ URL *url.URL

+ UserAgent string

+ VersionPrefix string

+ func (t *APIKeyTransport) Client() *http.Client

+ func (t *APIKeyTransport) RoundTrip(req *http.Request) (*http.Response, error)

+ type AddOpts struct

+ type AlertsDeleteOpts struct

+ ActiveDecisionEquals *bool

+ Contains *bool

+ IPEquals *string

+ Limit *int

+ OriginEquals *string

+ RangeEquals *string

+ ScenarioEquals *string

+ ScopeEquals *string

+ Since *string

+ SourceEquals *string

+ Until *string

+ ValueEquals *string

+ type AlertsListOpts struct

+ ActiveDecisionEquals *bool

+ Contains *bool

+ IPEquals *string

+ IncludeCAPI *bool

+ IncludeSimulated *bool

+ Limit *int

+ OriginEquals *string

+ RangeEquals *string

+ ScenarioEquals *string

+ ScopeEquals *string

+ Since *string

+ TypeEquals *string

+ Until *string

+ ValueEquals *string

+ type AlertsService service

+ func (s *AlertsService) Add(ctx context.Context, alerts models.AddAlertsRequest) (*models.AddAlertsResponse, *Response, error)

+ func (s *AlertsService) Delete(ctx context.Context, opts AlertsDeleteOpts) (*models.DeleteAlertsResponse, *Response, error)

+ func (s *AlertsService) DeleteOne(ctx context.Context, alert_id string) (*models.DeleteAlertsResponse, *Response, error)

+ func (s *AlertsService) GetByID(ctx context.Context, alertID int) (*models.Alert, *Response, error)

+ func (s *AlertsService) List(ctx context.Context, opts AlertsListOpts) (*models.GetAlertsResponse, *Response, error)

+ type ApiClient struct

+ Alerts *AlertsService

+ Auth *AuthService

+ BaseURL *url.URL

+ DecisionDelete *DecisionDeleteService

+ Decisions *DecisionsService

+ HeartBeat *HeartBeatService

+ Metrics *MetricsService

+ PapiURL *url.URL

+ Signal *SignalService

+ URLPrefix string

+ UserAgent string

+ func NewClient(config *Config) (*ApiClient, error)

+ func NewDefaultClient(URL *url.URL, prefix string, userAgent string, client *http.Client) (*ApiClient, error)

+ func RegisterClient(config *Config, client *http.Client) (*ApiClient, error)

+ func (a *ApiClient) GetClient() *http.Client

+ func (c *ApiClient) Do(ctx context.Context, req *http.Request, v interface{}) (*Response, error)

+ func (c *ApiClient) NewRequest(method, url string, body interface{}) (*http.Request, error)

+ type AuthService service

+ func (s *AuthService) AuthenticateWatcher(ctx context.Context, auth models.WatcherAuthRequest) (models.WatcherAuthResponse, *Response, error)

+ func (s *AuthService) EnrollWatcher(ctx context.Context, enrollKey string, name string, tags []string, ...) (*Response, error)

+ func (s *AuthService) RegisterWatcher(ctx context.Context, registration models.WatcherRegistrationRequest) (*Response, error)

+ func (s *AuthService) UnregisterWatcher(ctx context.Context) (*Response, error)

+ type Config struct

+ MachineID string

+ PapiURL *url.URL

+ Password strfmt.Password

+ Scenarios []string

+ URL *url.URL

+ UpdateScenario func() ([]string, error)

+ UserAgent string

+ VersionPrefix string

+ type DecisionDeleteService service

+ func (d *DecisionDeleteService) Add(ctx context.Context, deletedDecisions *models.DecisionsDeleteRequest) (interface{}, *Response, error)

+ type DecisionsDeleteOpts struct

+ Contains *bool

+ IPEquals *string

+ OriginEquals *string

+ RangeEquals *string

+ ScenarioEquals *string

+ ScopeEquals *string

+ TypeEquals *string

+ ValueEquals *string

+ type DecisionsListOpts struct

+ Contains *bool

+ IPEquals *string

+ RangeEquals *string

+ ScopeEquals *string

+ TypeEquals *string

+ ValueEquals *string

+ type DecisionsService service

+ func (s *DecisionsService) Delete(ctx context.Context, opts DecisionsDeleteOpts) (*models.DeleteDecisionResponse, *Response, error)

+ func (s *DecisionsService) DeleteOne(ctx context.Context, decision_id string) (*models.DeleteDecisionResponse, *Response, error)

+ func (s *DecisionsService) FetchV2Decisions(ctx context.Context, url string) (*models.DecisionsStreamResponse, *Response, error)

+ func (s *DecisionsService) FetchV3Decisions(ctx context.Context, url string) (*models.DecisionsStreamResponse, *Response, error)

+ func (s *DecisionsService) GetDecisionsFromBlocklist(ctx context.Context, blocklist *modelscapi.BlocklistLink, ...) ([]*models.Decision, bool, error)

+ func (s *DecisionsService) GetDecisionsFromGroups(decisionsGroups []*modelscapi.GetDecisionsStreamResponseNewItem) []*models.Decision

+ func (s *DecisionsService) GetStream(ctx context.Context, opts DecisionsStreamOpts) (*models.DecisionsStreamResponse, *Response, error)

+ func (s *DecisionsService) GetStreamV3(ctx context.Context, opts DecisionsStreamOpts) (*modelscapi.GetDecisionsStreamResponse, *Response, error)

+ func (s *DecisionsService) List(ctx context.Context, opts DecisionsListOpts) (*models.GetDecisionsResponse, *Response, error)

+ func (s *DecisionsService) StopStream(ctx context.Context) (*Response, error)

+ func (s *DecisionsService) StreamDecisions(ctx context.Context, opts DecisionsStreamOpts) (*models.DecisionsStreamResponse, *Response, error)

+ type DecisionsStreamOpts struct

+ Origins string

+ ScenariosContaining string

+ ScenariosNotContaining string

+ Scopes string

+ Startup bool

+ type DeleteOpts struct

+ type ErrorResponse struct

+ func (e *ErrorResponse) Error() string

+ type HeartBeatService service

+ func (h *HeartBeatService) Ping(ctx context.Context) (bool, *Response, error)

+ func (h *HeartBeatService) StartHeartBeat(ctx context.Context, t *tomb.Tomb)

+ type JWTTransport struct

+ Expiration time.Time

+ MachineID *string

+ Password *strfmt.Password

+ Scenarios []string

+ Token string

+ Transport http.RoundTripper

+ URL *url.URL

+ UpdateScenario func() ([]string, error)

+ UserAgent string

+ VersionPrefix string

+ func (t *JWTTransport) Client() *http.Client

+ func (t *JWTTransport) ResetToken()

+ func (t *JWTTransport) RoundTrip(req *http.Request) (*http.Response, error)

+ type ListOpts struct

+ type MetricsService service

+ func (s *MetricsService) Add(ctx context.Context, metrics *models.Metrics) (interface{}, *Response, error)

+ type Response struct

+ Response *http.Response

+ type SignalService service

+ func (s *SignalService) Add(ctx context.Context, signals *models.AddSignalsRequest) (interface{}, *Response, error)