Documentation
¶
Index ¶
- type AddTeamMemberParams
- type AddTeamSourceParams
- type ApiToken
- type CountAdminUsersParams
- type CountUserSessionsParams
- type CreateAPITokenParams
- type CreateSessionParams
- type CreateSourceParams
- type CreateTeamParams
- type CreateTeamSourceQueryParams
- type CreateUserParams
- type DBTX
- type DeleteAPITokenParams
- type DeleteTeamSourceQueryParams
- type GetSourceByNameParams
- type GetTeamMemberParams
- type GetTeamSourceQueryParams
- type ListQueriesByTeamAndSourceParams
- type ListTeamMembersWithDetailsRow
- type ListTeamsForUserRow
- type ListTeamsRow
- type Querier
- type Queries
- func (q *Queries) AddTeamMember(ctx context.Context, arg AddTeamMemberParams) error
- func (q *Queries) AddTeamSource(ctx context.Context, arg AddTeamSourceParams) error
- func (q *Queries) Close() error
- func (q *Queries) CountAdminUsers(ctx context.Context, arg CountAdminUsersParams) (int64, error)
- func (q *Queries) CountUserSessions(ctx context.Context, arg CountUserSessionsParams) (int64, error)
- func (q *Queries) CreateAPIToken(ctx context.Context, arg CreateAPITokenParams) (int64, error)
- func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) error
- func (q *Queries) CreateSource(ctx context.Context, arg CreateSourceParams) (int64, error)
- func (q *Queries) CreateTeam(ctx context.Context, arg CreateTeamParams) (int64, error)
- func (q *Queries) CreateTeamSourceQuery(ctx context.Context, arg CreateTeamSourceQueryParams) (int64, error)
- func (q *Queries) CreateUser(ctx context.Context, arg CreateUserParams) (int64, error)
- func (q *Queries) DeleteAPIToken(ctx context.Context, arg DeleteAPITokenParams) error
- func (q *Queries) DeleteExpiredAPITokens(ctx context.Context) error
- func (q *Queries) DeleteSession(ctx context.Context, id string) error
- func (q *Queries) DeleteSource(ctx context.Context, id int64) error
- func (q *Queries) DeleteTeam(ctx context.Context, id int64) error
- func (q *Queries) DeleteTeamSourceQuery(ctx context.Context, arg DeleteTeamSourceQueryParams) error
- func (q *Queries) DeleteUser(ctx context.Context, id int64) error
- func (q *Queries) DeleteUserSessions(ctx context.Context, userID int64) error
- func (q *Queries) GetAPIToken(ctx context.Context, id int64) (ApiToken, error)
- func (q *Queries) GetAPITokenByHash(ctx context.Context, tokenHash string) (ApiToken, error)
- func (q *Queries) GetSession(ctx context.Context, id string) (Session, error)
- func (q *Queries) GetSource(ctx context.Context, id int64) (Source, error)
- func (q *Queries) GetSourceByName(ctx context.Context, arg GetSourceByNameParams) (Source, error)
- func (q *Queries) GetTeam(ctx context.Context, id int64) (Team, error)
- func (q *Queries) GetTeamByName(ctx context.Context, name string) (Team, error)
- func (q *Queries) GetTeamMember(ctx context.Context, arg GetTeamMemberParams) (TeamMember, error)
- func (q *Queries) GetTeamSourceQuery(ctx context.Context, arg GetTeamSourceQueryParams) (TeamQuery, error)
- func (q *Queries) GetUser(ctx context.Context, id int64) (User, error)
- func (q *Queries) GetUserByEmail(ctx context.Context, email string) (User, error)
- func (q *Queries) ListAPITokensForUser(ctx context.Context, userID int64) ([]ApiToken, error)
- func (q *Queries) ListQueriesByTeamAndSource(ctx context.Context, arg ListQueriesByTeamAndSourceParams) ([]TeamQuery, error)
- func (q *Queries) ListSourceTeams(ctx context.Context, sourceID int64) ([]Team, error)
- func (q *Queries) ListSources(ctx context.Context) ([]Source, error)
- func (q *Queries) ListSourcesForUser(ctx context.Context, userID int64) ([]Source, error)
- func (q *Queries) ListTeamMembers(ctx context.Context, teamID int64) ([]TeamMember, error)
- func (q *Queries) ListTeamMembersWithDetails(ctx context.Context, teamID int64) ([]ListTeamMembersWithDetailsRow, error)
- func (q *Queries) ListTeamSources(ctx context.Context, teamID int64) ([]Source, error)
- func (q *Queries) ListTeams(ctx context.Context) ([]ListTeamsRow, error)
- func (q *Queries) ListTeamsForUser(ctx context.Context, userID int64) ([]ListTeamsForUserRow, error)
- func (q *Queries) ListUserTeams(ctx context.Context, userID int64) ([]Team, error)
- func (q *Queries) ListUsers(ctx context.Context) ([]User, error)
- func (q *Queries) RemoveTeamMember(ctx context.Context, arg RemoveTeamMemberParams) error
- func (q *Queries) RemoveTeamSource(ctx context.Context, arg RemoveTeamSourceParams) error
- func (q *Queries) TeamHasSource(ctx context.Context, arg TeamHasSourceParams) (int64, error)
- func (q *Queries) UpdateAPITokenLastUsed(ctx context.Context, id int64) error
- func (q *Queries) UpdateSource(ctx context.Context, arg UpdateSourceParams) error
- func (q *Queries) UpdateTeam(ctx context.Context, arg UpdateTeamParams) error
- func (q *Queries) UpdateTeamMemberRole(ctx context.Context, arg UpdateTeamMemberRoleParams) error
- func (q *Queries) UpdateTeamSourceQuery(ctx context.Context, arg UpdateTeamSourceQueryParams) error
- func (q *Queries) UpdateUser(ctx context.Context, arg UpdateUserParams) error
- func (q *Queries) UserHasSourceAccess(ctx context.Context, arg UserHasSourceAccessParams) (int64, error)
- func (q *Queries) WithTx(tx *sql.Tx) *Queries
- type RemoveTeamMemberParams
- type RemoveTeamSourceParams
- type Session
- type Source
- type Team
- type TeamHasSourceParams
- type TeamMember
- type TeamQuery
- type TeamSource
- type UpdateSourceParams
- type UpdateTeamMemberRoleParams
- type UpdateTeamParams
- type UpdateTeamSourceQueryParams
- type UpdateUserParams
- type User
- type UserHasSourceAccessParams
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type AddTeamMemberParams ¶
type AddTeamSourceParams ¶
type ApiToken ¶ added in v0.2.2
type ApiToken struct {
ID int64 `json:"id"`
UserID int64 `json:"user_id"`
Name string `json:"name"`
TokenHash string `json:"token_hash"`
Prefix string `json:"prefix"`
LastUsedAt sql.NullTime `json:"last_used_at"`
ExpiresAt sql.NullTime `json:"expires_at"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type CountAdminUsersParams ¶
type CountUserSessionsParams ¶
type CreateAPITokenParams ¶ added in v0.2.2
type CreateSessionParams ¶
type CreateSourceParams ¶
type CreateSourceParams struct {
Name string `json:"name"`
MetaIsAutoCreated int64 `json:"_meta_is_auto_created"`
MetaTsField string `json:"_meta_ts_field"`
MetaSeverityField sql.NullString `json:"_meta_severity_field"`
Host string `json:"host"`
Username string `json:"username"`
Password string `json:"password"`
Database string `json:"database"`
TableName string `json:"table_name"`
Description sql.NullString `json:"description"`
TtlDays int64 `json:"ttl_days"`
}
type CreateTeamParams ¶
type CreateTeamParams struct {
Name string `json:"name"`
Description sql.NullString `json:"description"`
}
type CreateUserParams ¶
type DeleteAPITokenParams ¶ added in v0.2.2
type GetSourceByNameParams ¶
type GetTeamMemberParams ¶
type ListTeamsForUserRow ¶ added in v0.2.2
type ListTeamsRow ¶
type Querier ¶
type Querier interface {
// Team Members
// Add a member to a team
AddTeamMember(ctx context.Context, arg AddTeamMemberParams) error
// Team Sources
// Add a data source to a team
AddTeamSource(ctx context.Context, arg AddTeamSourceParams) error
// Count active admin users
CountAdminUsers(ctx context.Context, arg CountAdminUsersParams) (int64, error)
// Count active sessions for a user
CountUserSessions(ctx context.Context, arg CountUserSessionsParams) (int64, error)
// API Tokens
// Create a new API token
CreateAPIToken(ctx context.Context, arg CreateAPITokenParams) (int64, error)
// Sessions
// Create a new session
CreateSession(ctx context.Context, arg CreateSessionParams) error
// Sources
// Create a new source entry
CreateSource(ctx context.Context, arg CreateSourceParams) (int64, error)
// Teams
// Create a new team
CreateTeam(ctx context.Context, arg CreateTeamParams) (int64, error)
// Team Queries
// Create a new query for a team and source
CreateTeamSourceQuery(ctx context.Context, arg CreateTeamSourceQueryParams) (int64, error)
// Users
// Create a new user
CreateUser(ctx context.Context, arg CreateUserParams) (int64, error)
// Delete an API token by ID and user ID (ensure user owns the token)
DeleteAPIToken(ctx context.Context, arg DeleteAPITokenParams) error
// Delete all expired API tokens
DeleteExpiredAPITokens(ctx context.Context) error
// Delete a session by ID
DeleteSession(ctx context.Context, id string) error
// Delete a source by ID
DeleteSource(ctx context.Context, id int64) error
// Delete a team by ID
DeleteTeam(ctx context.Context, id int64) error
// Delete a query by ID for a specific team and source
DeleteTeamSourceQuery(ctx context.Context, arg DeleteTeamSourceQueryParams) error
// Delete a user by ID
DeleteUser(ctx context.Context, id int64) error
// Delete all sessions for a user
DeleteUserSessions(ctx context.Context, userID int64) error
// Get an API token by ID
GetAPIToken(ctx context.Context, id int64) (ApiToken, error)
// Get an API token by its hash (for authentication)
GetAPITokenByHash(ctx context.Context, tokenHash string) (ApiToken, error)
// Get a session by ID
GetSession(ctx context.Context, id string) (Session, error)
// Get a single source by ID
GetSource(ctx context.Context, id int64) (Source, error)
// Get a single source by table name and database
GetSourceByName(ctx context.Context, arg GetSourceByNameParams) (Source, error)
// Get a team by ID
GetTeam(ctx context.Context, id int64) (Team, error)
// Get a team by its name
GetTeamByName(ctx context.Context, name string) (Team, error)
// Get a team member
GetTeamMember(ctx context.Context, arg GetTeamMemberParams) (TeamMember, error)
// Get a query by ID for a specific team and source
GetTeamSourceQuery(ctx context.Context, arg GetTeamSourceQueryParams) (TeamQuery, error)
// Get a user by ID
GetUser(ctx context.Context, id int64) (User, error)
// Get a user by email
GetUserByEmail(ctx context.Context, email string) (User, error)
// List all API tokens for a user
ListAPITokensForUser(ctx context.Context, userID int64) ([]ApiToken, error)
// List all queries for a specific team and source
ListQueriesByTeamAndSource(ctx context.Context, arg ListQueriesByTeamAndSourceParams) ([]TeamQuery, error)
// List all teams a data source is a member of
ListSourceTeams(ctx context.Context, sourceID int64) ([]Team, error)
// Get all sources ordered by creation date
ListSources(ctx context.Context) ([]Source, error)
// List all sources a user has access to
ListSourcesForUser(ctx context.Context, userID int64) ([]Source, error)
// List all members of a team
ListTeamMembers(ctx context.Context, teamID int64) ([]TeamMember, error)
// List all members of a team with user details
ListTeamMembersWithDetails(ctx context.Context, teamID int64) ([]ListTeamMembersWithDetailsRow, error)
// List all data sources in a team
ListTeamSources(ctx context.Context, teamID int64) ([]Source, error)
// List all teams
ListTeams(ctx context.Context) ([]ListTeamsRow, error)
// List all teams a user is a member of
ListTeamsForUser(ctx context.Context, userID int64) ([]ListTeamsForUserRow, error)
// List all teams a user is a member of
ListUserTeams(ctx context.Context, userID int64) ([]Team, error)
// List all users
ListUsers(ctx context.Context) ([]User, error)
// Remove a member from a team
RemoveTeamMember(ctx context.Context, arg RemoveTeamMemberParams) error
// Remove a data source from a team
RemoveTeamSource(ctx context.Context, arg RemoveTeamSourceParams) error
// Additional queries for user-source and team-source access
// Check if a team has access to a source
TeamHasSource(ctx context.Context, arg TeamHasSourceParams) (int64, error)
// Update the last used timestamp for an API token
UpdateAPITokenLastUsed(ctx context.Context, id int64) error
// Update an existing source
UpdateSource(ctx context.Context, arg UpdateSourceParams) error
// Update a team
UpdateTeam(ctx context.Context, arg UpdateTeamParams) error
// Update a team member's role
UpdateTeamMemberRole(ctx context.Context, arg UpdateTeamMemberRoleParams) error
// Update a query for a team and source
UpdateTeamSourceQuery(ctx context.Context, arg UpdateTeamSourceQueryParams) error
// Update a user
UpdateUser(ctx context.Context, arg UpdateUserParams) error
// Check if a user has access to a source through any team
UserHasSourceAccess(ctx context.Context, arg UserHasSourceAccessParams) (int64, error)
}
type Queries ¶
type Queries struct {
// contains filtered or unexported fields
}
func (*Queries) AddTeamMember ¶
func (q *Queries) AddTeamMember(ctx context.Context, arg AddTeamMemberParams) error
Team Members Add a member to a team
func (*Queries) AddTeamSource ¶
func (q *Queries) AddTeamSource(ctx context.Context, arg AddTeamSourceParams) error
Team Sources Add a data source to a team
func (*Queries) CountAdminUsers ¶
Count active admin users
func (*Queries) CountUserSessions ¶
func (q *Queries) CountUserSessions(ctx context.Context, arg CountUserSessionsParams) (int64, error)
Count active sessions for a user
func (*Queries) CreateAPIToken ¶ added in v0.2.2
API Tokens Create a new API token
func (*Queries) CreateSession ¶
func (q *Queries) CreateSession(ctx context.Context, arg CreateSessionParams) error
Sessions Create a new session
func (*Queries) CreateSource ¶
Sources Create a new source entry
func (*Queries) CreateTeam ¶
Teams Create a new team
func (*Queries) CreateTeamSourceQuery ¶
func (q *Queries) CreateTeamSourceQuery(ctx context.Context, arg CreateTeamSourceQueryParams) (int64, error)
Team Queries Create a new query for a team and source
func (*Queries) CreateUser ¶
Users Create a new user
func (*Queries) DeleteAPIToken ¶ added in v0.2.2
func (q *Queries) DeleteAPIToken(ctx context.Context, arg DeleteAPITokenParams) error
Delete an API token by ID and user ID (ensure user owns the token)
func (*Queries) DeleteExpiredAPITokens ¶ added in v0.2.2
Delete all expired API tokens
func (*Queries) DeleteSession ¶
Delete a session by ID
func (*Queries) DeleteSource ¶
Delete a source by ID
func (*Queries) DeleteTeam ¶
Delete a team by ID
func (*Queries) DeleteTeamSourceQuery ¶
func (q *Queries) DeleteTeamSourceQuery(ctx context.Context, arg DeleteTeamSourceQueryParams) error
Delete a query by ID for a specific team and source
func (*Queries) DeleteUser ¶
Delete a user by ID
func (*Queries) DeleteUserSessions ¶
Delete all sessions for a user
func (*Queries) GetAPIToken ¶ added in v0.2.2
Get an API token by ID
func (*Queries) GetAPITokenByHash ¶ added in v0.2.2
Get an API token by its hash (for authentication)
func (*Queries) GetSession ¶
Get a session by ID
func (*Queries) GetSourceByName ¶
Get a single source by table name and database
func (*Queries) GetTeamByName ¶
Get a team by its name
func (*Queries) GetTeamMember ¶
func (q *Queries) GetTeamMember(ctx context.Context, arg GetTeamMemberParams) (TeamMember, error)
Get a team member
func (*Queries) GetTeamSourceQuery ¶
func (q *Queries) GetTeamSourceQuery(ctx context.Context, arg GetTeamSourceQueryParams) (TeamQuery, error)
Get a query by ID for a specific team and source
func (*Queries) GetUserByEmail ¶
Get a user by email
func (*Queries) ListAPITokensForUser ¶ added in v0.2.2
List all API tokens for a user
func (*Queries) ListQueriesByTeamAndSource ¶
func (q *Queries) ListQueriesByTeamAndSource(ctx context.Context, arg ListQueriesByTeamAndSourceParams) ([]TeamQuery, error)
List all queries for a specific team and source
func (*Queries) ListSourceTeams ¶
List all teams a data source is a member of
func (*Queries) ListSources ¶
Get all sources ordered by creation date
func (*Queries) ListSourcesForUser ¶
List all sources a user has access to
func (*Queries) ListTeamMembers ¶
List all members of a team
func (*Queries) ListTeamMembersWithDetails ¶
func (q *Queries) ListTeamMembersWithDetails(ctx context.Context, teamID int64) ([]ListTeamMembersWithDetailsRow, error)
List all members of a team with user details
func (*Queries) ListTeamSources ¶
List all data sources in a team
func (*Queries) ListTeams ¶
func (q *Queries) ListTeams(ctx context.Context) ([]ListTeamsRow, error)
List all teams
func (*Queries) ListTeamsForUser ¶
func (q *Queries) ListTeamsForUser(ctx context.Context, userID int64) ([]ListTeamsForUserRow, error)
List all teams a user is a member of
func (*Queries) ListUserTeams ¶
List all teams a user is a member of
func (*Queries) RemoveTeamMember ¶
func (q *Queries) RemoveTeamMember(ctx context.Context, arg RemoveTeamMemberParams) error
Remove a member from a team
func (*Queries) RemoveTeamSource ¶
func (q *Queries) RemoveTeamSource(ctx context.Context, arg RemoveTeamSourceParams) error
Remove a data source from a team
func (*Queries) TeamHasSource ¶
Additional queries for user-source and team-source access Check if a team has access to a source
func (*Queries) UpdateAPITokenLastUsed ¶ added in v0.2.2
Update the last used timestamp for an API token
func (*Queries) UpdateSource ¶
func (q *Queries) UpdateSource(ctx context.Context, arg UpdateSourceParams) error
Update an existing source
func (*Queries) UpdateTeam ¶
func (q *Queries) UpdateTeam(ctx context.Context, arg UpdateTeamParams) error
Update a team
func (*Queries) UpdateTeamMemberRole ¶
func (q *Queries) UpdateTeamMemberRole(ctx context.Context, arg UpdateTeamMemberRoleParams) error
Update a team member's role
func (*Queries) UpdateTeamSourceQuery ¶
func (q *Queries) UpdateTeamSourceQuery(ctx context.Context, arg UpdateTeamSourceQueryParams) error
Update a query for a team and source
func (*Queries) UpdateUser ¶
func (q *Queries) UpdateUser(ctx context.Context, arg UpdateUserParams) error
Update a user
func (*Queries) UserHasSourceAccess ¶
func (q *Queries) UserHasSourceAccess(ctx context.Context, arg UserHasSourceAccessParams) (int64, error)
Check if a user has access to a source through any team
type RemoveTeamMemberParams ¶
type RemoveTeamSourceParams ¶
type Source ¶
type Source struct {
ID int64 `json:"id"`
Name string `json:"name"`
MetaIsAutoCreated int64 `json:"_meta_is_auto_created"`
MetaTsField string `json:"_meta_ts_field"`
MetaSeverityField sql.NullString `json:"_meta_severity_field"`
Host string `json:"host"`
Username string `json:"username"`
Password string `json:"password"`
Database string `json:"database"`
TableName string `json:"table_name"`
Description sql.NullString `json:"description"`
TtlDays int64 `json:"ttl_days"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type TeamHasSourceParams ¶
type TeamMember ¶
type TeamQuery ¶
type TeamQuery struct {
ID int64 `json:"id"`
TeamID int64 `json:"team_id"`
SourceID int64 `json:"source_id"`
Name string `json:"name"`
Description sql.NullString `json:"description"`
QueryType string `json:"query_type"`
QueryContent string `json:"query_content"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}
type TeamSource ¶
type UpdateSourceParams ¶
type UpdateSourceParams struct {
Name string `json:"name"`
MetaIsAutoCreated int64 `json:"_meta_is_auto_created"`
MetaTsField string `json:"_meta_ts_field"`
MetaSeverityField sql.NullString `json:"_meta_severity_field"`
Host string `json:"host"`
Username string `json:"username"`
Password string `json:"password"`
Database string `json:"database"`
TableName string `json:"table_name"`
Description sql.NullString `json:"description"`
TtlDays int64 `json:"ttl_days"`
ID int64 `json:"id"`
}
type UpdateTeamParams ¶
type UpdateUserParams ¶
type UpdateUserParams struct {
Email string `json:"email"`
FullName string `json:"full_name"`
Role string `json:"role"`
Status string `json:"status"`
LastLoginAt sql.NullTime `json:"last_login_at"`
LastActiveAt sql.NullTime `json:"last_active_at"`
UpdatedAt time.Time `json:"updated_at"`
ID int64 `json:"id"`
}
type User ¶
type User struct {
ID int64 `json:"id"`
Email string `json:"email"`
FullName string `json:"full_name"`
Role string `json:"role"`
Status string `json:"status"`
LastLoginAt sql.NullTime `json:"last_login_at"`
LastActiveAt sql.NullTime `json:"last_active_at"`
CreatedAt time.Time `json:"created_at"`
UpdatedAt time.Time `json:"updated_at"`
}