Documentation
¶
Index ¶
- Variables
- func New[T Item](output io.Writer, getReplicas GetReplicasFunc[T], getLogs GetLogFunc[T], ...) *streamingReplicas[T]
- type ComponentItem
- type GetLogFunc
- type GetReplicasFunc
- func GetComponentReplicasForEnvironment(apiClient *radixapi.Radixapi, appName, environmentName string, ...) GetReplicasFunc[ComponentItem]
- func GetReplicasForComponent(apiClient *radixapi.Radixapi, appName, environmentName, componentName string, ...) GetReplicasFunc[ComponentItem]
- func GetReplicasForJob(apiClient *radixapi.Radixapi, appName, jobName string) GetReplicasFunc[JobStep]
- type Item
- type JobStep
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]
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 GetReplicasForJob ¶
func GetReplicasForJob(apiClient *radixapi.Radixapi, appName, jobName string) GetReplicasFunc[JobStep]
Source Files
Click to show internal directories.
Click to hide internal directories.