Documentation
¶
Index ¶
- Variables
- func New[T Item](output io.Writer, getReplicas GetReplicasFunc[T], getLogs GetLogFunc[T], ...) *streamingReplicas[T]
- type ComponentItem
- type GetLogFunc
- func GetComponentLog(apiClient *radixapi.Radixapi, appName string, previous bool) GetLogFunc[ComponentItem]
- func GetLogsForJob(apiClient *radixapi.Radixapi, appName, jobName string) GetLogFunc[JobStep]
- func GetOAuth2ComponentLog(apiClient *radixapi.Radixapi, appName string, previous bool) GetLogFunc[OAuth2ComponentItem]
- type GetReplicasFunc
- func GetComponentReplicasForEnvironment(apiClient *radixapi.Radixapi, appName, environmentName string, ...) GetReplicasFunc[ComponentItem]
- func GetReplicasForComponent(apiClient *radixapi.Radixapi, appName, environmentName, componentName string, ...) GetReplicasFunc[ComponentItem]
- func GetReplicasForComponentOAuth2(apiClient *radixapi.Radixapi, ...) GetReplicasFunc[OAuth2ComponentItem]
- func GetReplicasForJob(apiClient *radixapi.Radixapi, appName, jobName string) GetReplicasFunc[JobStep]
- type Item
- type JobStep
- type OAuth2ComponentItem
Constants ¶
This section is empty.
Variables ¶
View Source
var ErrJobFailed = errors.New("job has failed")
Functions ¶
func New ¶
func New[T Item](output io.Writer, getReplicas GetReplicasFunc[T], getLogs GetLogFunc[T], since *time.Duration) *streamingReplicas[T]
Types ¶
type ComponentItem ¶
type ComponentItem struct {
Component string
Replica string
// contains filtered or unexported fields
}
func (ComponentItem) Created ¶
func (c ComponentItem) Created() time.Time
func (ComponentItem) Identifier ¶
func (c ComponentItem) Identifier() string
type GetLogFunc ¶
type GetLogFunc[T Item] func(ctx context.Context, item T, since time.Time, callback consumer.EventCallback) error
func GetComponentLog ¶
func GetComponentLog(apiClient *radixapi.Radixapi, appName string, previous bool) GetLogFunc[ComponentItem]
func GetLogsForJob ¶
func GetLogsForJob(apiClient *radixapi.Radixapi, appName, jobName string) GetLogFunc[JobStep]
func GetOAuth2ComponentLog ¶ added in v1.39.0
func GetOAuth2ComponentLog(apiClient *radixapi.Radixapi, appName string, previous bool) GetLogFunc[OAuth2ComponentItem]
type GetReplicasFunc ¶
GetReplicasFunc is a function type that returns a list of items (replicas) to stream logs from, a boolean indicating if we are finished, and an error if any occurred.
func GetComponentReplicasForEnvironment ¶
func GetComponentReplicasForEnvironment(apiClient *radixapi.Radixapi, appName, environmentName string, previousLog bool) GetReplicasFunc[ComponentItem]
getComponentReplicasForEnvironment returns all replicas for all components in an environment, if previousLog is true, only return replicas once
func GetReplicasForComponent ¶
func GetReplicasForComponent(apiClient *radixapi.Radixapi, appName, environmentName, componentName string, previousLog bool) GetReplicasFunc[ComponentItem]
func GetReplicasForComponentOAuth2 ¶ added in v1.39.0
func GetReplicasForComponentOAuth2(apiClient *radixapi.Radixapi, appName, environmentName, componentName, auxType string, previousLog bool) GetReplicasFunc[OAuth2ComponentItem]
func GetReplicasForJob ¶
func GetReplicasForJob(apiClient *radixapi.Radixapi, appName, jobName string) GetReplicasFunc[JobStep]
type JobStep ¶
type JobStep struct {
// contains filtered or unexported fields
}
func (JobStep) Identifier ¶
type OAuth2ComponentItem ¶ added in v1.39.0
type OAuth2ComponentItem struct {
Component string
Env string
Replica string
AuxType string
// contains filtered or unexported fields
}
func (OAuth2ComponentItem) Created ¶ added in v1.39.0
func (c OAuth2ComponentItem) Created() time.Time
func (OAuth2ComponentItem) Identifier ¶ added in v1.39.0
func (c OAuth2ComponentItem) Identifier() string
Source Files
Click to show internal directories.
Click to hide internal directories.