MCPcopy Create free account
hub / github.com/GetStream/stream-go2 / QueryAuditLogs

Method QueryAuditLogs

audit_logs.go:41–70  ·  view source on GitHub ↗
(ctx context.Context, filters QueryAuditLogsFilters, pager QueryAuditLogsPager)

Source from the content-addressed store, hash-verified

39}
40
41func (c *AuditLogsClient) QueryAuditLogs(ctx context.Context, filters QueryAuditLogsFilters, pager QueryAuditLogsPager) (*QueryAuditLogsResponse, error) {
42 endpoint := c.client.makeEndpoint("audit_logs/")
43 if filters.EntityType != "" && filters.EntityID != "" {
44 endpoint.addQueryParam(makeRequestOption("entity_type", filters.EntityType))
45 endpoint.addQueryParam(makeRequestOption("entity_id", filters.EntityID))
46 }
47 if filters.UserID != "" {
48 endpoint.addQueryParam(makeRequestOption("user_id", filters.UserID))
49 }
50 if pager.Next != "" {
51 endpoint.addQueryParam(makeRequestOption("next", pager.Next))
52 }
53 if pager.Prev != "" {
54 endpoint.addQueryParam(makeRequestOption("prev", pager.Prev))
55 }
56 if pager.Limit > 0 {
57 endpoint.addQueryParam(makeRequestOption("limit", pager.Limit))
58 }
59 body, err := c.client.get(ctx, endpoint, nil, c.client.authenticator.auditLogsAuth)
60 if err != nil {
61 return nil, err
62 }
63
64 var resp QueryAuditLogsResponse
65 if err := json.Unmarshal(body, &resp); err != nil {
66 return nil, err
67 }
68
69 return &resp, nil
70}

Callers 2

TestQueryAuditLogsFunction · 0.80

Calls 4

makeRequestOptionFunction · 0.85
makeEndpointMethod · 0.80
addQueryParamMethod · 0.80
getMethod · 0.80

Tested by 2

TestQueryAuditLogsFunction · 0.64