Documentation
¶
Index ¶
- Variables
- func Contains(s []string, e string) bool
- func DeleteAnalyticsFlowEngineUser(token Token, conf configuration.Config) error
- func DeleteAnalyticsFlowRepoUser(token Token, conf configuration.Config) error
- func DeleteAnalyticsOperatorRepoUser(token Token, conf configuration.Config) error
- func DeleteBrokerExportsUser(token Token, conf configuration.Config) error
- func DeleteDashboardUser(token Token, conf configuration.Config) error
- func DeleteDatabaseExportsUser(token Token, conf configuration.Config) error
- func DeleteExportDatabasesUser(token Token, conf configuration.Config) error
- func DeleteImportsUser(token Token, conf configuration.Config) error
- func DeleteKeycloakUser(id string, conf configuration.Config) (err error)
- func DeleteNotificationUser(token Token, conf configuration.Config) error
- func DeleteProcessSchedulerUser(token Token, conf configuration.Config) error
- func DeleteUser(userId string, conf configuration.Config) (err error)
- func DeleteWaitingRoomUser(token Token, conf configuration.Config) error
- type BrokerList
- type EventHandler
- type ExportDatabase
- type ExportDatabaseRequest
- type ExportIdWrapper
- type ExportListIdWrapper
- type Flow
- type FlowList
- type Group
- type IdWrapper
- type JwtImpersonate
- func (this JwtImpersonate) Delete(url string, body interface{}) (resp *http.Response, err error)
- func (this JwtImpersonate) DeleteWithBody(url string, body interface{}) (resp *http.Response, err error)
- func (this JwtImpersonate) Get(url string) (resp *http.Response, err error)
- func (this JwtImpersonate) GetJSON(url string, result interface{}) (err error)
- func (this JwtImpersonate) Post(url string, contentType string, body io.Reader) (resp *http.Response, err error)
- func (this JwtImpersonate) PostJSON(url string, body interface{}, result interface{}) (err error)
- func (this JwtImpersonate) Put(url string, contentType string, body io.Reader) (resp *http.Response, err error)
- func (this JwtImpersonate) PutJSON(url string, body interface{}, result interface{}) (err error)
- type KeycloakClaims
- type NotificationList
- type OpenidToken
- type Operator
- type OperatorList
- type RealmAccess
- type Role
- type Token
- type UnderscoreIdWrapper
- type User
- type UserCommandMsg
- type WaitingRoomIdWrapper
- type WaitingRoomListIdWrapper
Constants ¶
This section is empty.
Variables ¶
View Source
var BatchSize = 100
Functions ¶
func DeleteAnalyticsFlowEngineUser ¶
func DeleteAnalyticsFlowEngineUser(token Token, conf configuration.Config) error
func DeleteAnalyticsFlowRepoUser ¶
func DeleteAnalyticsFlowRepoUser(token Token, conf configuration.Config) error
func DeleteAnalyticsOperatorRepoUser ¶
func DeleteAnalyticsOperatorRepoUser(token Token, conf configuration.Config) error
func DeleteBrokerExportsUser ¶
func DeleteBrokerExportsUser(token Token, conf configuration.Config) error
func DeleteDashboardUser ¶
func DeleteDashboardUser(token Token, conf configuration.Config) error
func DeleteDatabaseExportsUser ¶
func DeleteDatabaseExportsUser(token Token, conf configuration.Config) error
func DeleteExportDatabasesUser ¶
func DeleteExportDatabasesUser(token Token, conf configuration.Config) error
func DeleteImportsUser ¶
func DeleteImportsUser(token Token, conf configuration.Config) error
func DeleteKeycloakUser ¶
func DeleteKeycloakUser(id string, conf configuration.Config) (err error)
func DeleteNotificationUser ¶
func DeleteNotificationUser(token Token, conf configuration.Config) error
func DeleteProcessSchedulerUser ¶
func DeleteProcessSchedulerUser(token Token, conf configuration.Config) error
func DeleteUser ¶
func DeleteUser(userId string, conf configuration.Config) (err error)
func DeleteWaitingRoomUser ¶
func DeleteWaitingRoomUser(token Token, conf configuration.Config) error
Types ¶
type BrokerList ¶
type BrokerList struct {
Brokers []IdWrapper `json:"brokers"`
}
type EventHandler ¶
type EventHandler struct {
// contains filtered or unexported fields
}
func InitEventConn ¶
func InitEventConn(ctx context.Context, wg *sync.WaitGroup, conf configuration.Config) (handler *EventHandler, err error)
func (*EventHandler) DeleteUser ¶
func (handler *EventHandler) DeleteUser(id string) error
type ExportDatabase ¶
type ExportDatabase struct { ID string `gorm:"primary_key;type:varchar(255);column:id"` Name string `gorm:"type:varchar(255)"` Description string `gorm:"type:varchar(255)"` Type string `gorm:"type:varchar(255)"` Deployment string `gorm:"type:varchar(255)"` Url string `gorm:"type:varchar(255)"` EwFilterTopic string `gorm:"type:varchar(255)"` UserId string `gorm:"type:varchar(255)"` Public bool `gorm:"type:bool;DEFAULT:false"` }
type ExportDatabaseRequest ¶
type ExportDatabaseRequest struct { Name string `json:"Name" validate:"required"` Description string `json:"Description"` Type string `json:"Type" validate:"required"` Deployment string `json:"deployment" validate:"required"` Url string `json:"Url" validate:"required"` EwFilterTopic string `json:"EwFilterTopic" validate:"required"` Public bool `json:"Public"` }
type ExportIdWrapper ¶
type ExportIdWrapper struct {
Id string `json:"ID"`
}
type ExportListIdWrapper ¶
type ExportListIdWrapper struct {
Instances []ExportIdWrapper `json:"instances"`
}
type Flow ¶
type Flow struct { UnderscoreIdWrapper UserId string `json:"userId"` }
type Group ¶ added in v0.0.5
func GetUsersGroups ¶ added in v0.0.5
func GetUsersGroups(id string, conf configuration.Config) ([]Group, error)
type JwtImpersonate ¶
func EnsureAccess ¶
func EnsureAccess(conf configuration.Config) (token JwtImpersonate, err error)
func (JwtImpersonate) Delete ¶
func (this JwtImpersonate) Delete(url string, body interface{}) (resp *http.Response, err error)
func (JwtImpersonate) DeleteWithBody ¶
func (this JwtImpersonate) DeleteWithBody(url string, body interface{}) (resp *http.Response, err error)
func (JwtImpersonate) Get ¶
func (this JwtImpersonate) Get(url string) (resp *http.Response, err error)
func (JwtImpersonate) GetJSON ¶
func (this JwtImpersonate) GetJSON(url string, result interface{}) (err error)
func (JwtImpersonate) PostJSON ¶
func (this JwtImpersonate) PostJSON(url string, body interface{}, result interface{}) (err error)
func (JwtImpersonate) PutJSON ¶
func (this JwtImpersonate) PutJSON(url string, body interface{}, result interface{}) (err error)
type KeycloakClaims ¶
type KeycloakClaims struct { RealmAccess RealmAccess `json:"realm_access"` jwt.StandardClaims }
type NotificationList ¶
type NotificationList struct {
Notifications []UnderscoreIdWrapper `json:"notifications"`
}
type OpenidToken ¶
type Operator ¶
type Operator struct { UnderscoreIdWrapper Public bool `json:"pub"` UserId string `json:"userId"` }
type OperatorList ¶
type OperatorList struct {
Operators []Operator `json:"operators"`
}
type RealmAccess ¶
type RealmAccess struct {
Roles []string `json:"roles"`
}
type Token ¶
type Token struct { Token string `json:"-"` Sub string `json:"sub,omitempty"` RealmAccess RealmAccess `json:"realm_access,omitempty"` }
func CreateTokenWithRoles ¶
func (*Token) Impersonate ¶
func (this *Token) Impersonate() JwtImpersonate
type UnderscoreIdWrapper ¶
type UnderscoreIdWrapper struct {
Id string `json:"_id"`
}
type User ¶
type User struct { Id string `json:"id"` Name string `json:"username"` Attributes map[string]interface{} `json:"attributes"` }
func GetGroupMembersCombined ¶ added in v0.0.5
func GetUserById ¶
func GetUserById(id string, conf configuration.Config) (user User, err error)
type UserCommandMsg ¶
type WaitingRoomIdWrapper ¶
type WaitingRoomIdWrapper struct {
Id string `json:"local_id"`
}
type WaitingRoomListIdWrapper ¶
type WaitingRoomListIdWrapper struct {
Result []WaitingRoomIdWrapper `json:"result"`
}
Click to show internal directories.
Click to hide internal directories.