Documentation
¶
Index ¶
- type KafkaAdmin
- type KeycloakService
- func (k *KeycloakService) GetAccessToken() string
- func (k *KeycloakService) GetImpersonateToken(userId string) (token string, err error)
- func (k *KeycloakService) GetUserByID(id string) (user *gocloak.User, err error)
- func (k *KeycloakService) GetUserInfo() (*gocloak.UserInfo, error)
- func (k *KeycloakService) Login()
- func (k *KeycloakService) Logout()
- type PipelineService
- func (p PipelineService) CreatePipeline(instance *lib.PipelineRequest, userId string, userToken string) error
- func (p PipelineService) DeletePipeline(id string, accessToken string) (err error)
- func (p PipelineService) GetPipelines(userId string, accessToken string) (pipes []pipeModels.Pipeline, err error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type KafkaAdmin ¶
type KafkaAdmin struct {
// contains filtered or unexported fields
}
func NewKafkaAdmin ¶
func NewKafkaAdmin(kafkaBootstrap string) (*KafkaAdmin, error)
func (*KafkaAdmin) Close ¶
func (k *KafkaAdmin) Close() (err error)
func (*KafkaAdmin) DeleteTopic ¶
func (k *KafkaAdmin) DeleteTopic(name string) (err error)
func (*KafkaAdmin) GetTopics ¶
func (k *KafkaAdmin) GetTopics() (topics []string, err error)
type KeycloakService ¶
type KeycloakService struct {
// contains filtered or unexported fields
}
func NewKeycloakService ¶
func (*KeycloakService) GetAccessToken ¶
func (k *KeycloakService) GetAccessToken() string
func (*KeycloakService) GetImpersonateToken ¶
func (k *KeycloakService) GetImpersonateToken(userId string) (token string, err error)
func (*KeycloakService) GetUserByID ¶
func (k *KeycloakService) GetUserByID(id string) (user *gocloak.User, err error)
func (*KeycloakService) GetUserInfo ¶
func (k *KeycloakService) GetUserInfo() (*gocloak.UserInfo, error)
func (*KeycloakService) Login ¶
func (k *KeycloakService) Login()
func (*KeycloakService) Logout ¶
func (k *KeycloakService) Logout()
type PipelineService ¶
type PipelineService struct {
// contains filtered or unexported fields
}
func NewPipelineService ¶
func NewPipelineService(pipelineUrl string, engineUrl string) *PipelineService
func (PipelineService) CreatePipeline ¶
func (p PipelineService) CreatePipeline(instance *lib.PipelineRequest, userId string, userToken string) error
func (PipelineService) DeletePipeline ¶
func (p PipelineService) DeletePipeline(id string, accessToken string) (err error)
func (PipelineService) GetPipelines ¶
func (p PipelineService) GetPipelines(userId string, accessToken string) (pipes []pipeModels.Pipeline, err error)
Source Files
Directories
Click to show internal directories.
Click to hide internal directories.