replicalog

Sep 30, 2025

Changes in this version

+ var ErrJobFailed = errors.New("job has failed")

+ func New[T Item](output io.Writer, getReplicas GetReplicasFunc[T], getLogs GetLogFunc[T], ...) *streamingReplicas[T]

+ type ComponentItem struct

+ Component string

+ Replica string

+ func (c ComponentItem) Created() time.Time

+ func (c ComponentItem) Identifier() string

+ type GetLogFunc func(ctx context.Context, item T, since time.Time, callback consumer.EventCallback) error

+ func GetComponentLog(apiClient *radixapi.Radixapi, appName string, previous bool) GetLogFunc[ComponentItem]

+ func GetLogsForJob(apiClient *radixapi.Radixapi, appName, jobName string) GetLogFunc[JobStep]

+ type GetReplicasFunc func() ([]T, bool, error)

+ 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 interface

+ Created func() time.Time

+ Identifier func() string

+ type JobStep struct

+ func (c JobStep) Created() time.Time

+ func (j JobStep) Identifier() string