k8s

type Client interface {
	// client go like
	Get(ctx context.Context, nn types.NamespacedName, obj client.Object) error
	List(ctx context.Context, list client.ObjectList, opts ...client.ListOption) error
	Create(ctx context.Context, obj client.Object) error
	Update(ctx context.Context, obj client.Object) error
	Delete(ctx context.Context, obj client.Object) error

	ListSecrets(ctx context.Context, namespace string, secretType corev1.SecretType) ([]corev1.Secret, error)

	// custom ones
	ValidateObject(ctx context.Context, obj client.Object) error

	ApplyYAML(ctx context.Context, yamls ...[]byte) error
	DeleteYAML(ctx context.Context, yamls ...[]byte) error

	ReadLogs(ctx context.Context, namespace, name string, writer io.WriteCloser, opts *ReadLogsOptions) error
}

type InvalidSchemaError struct {
	// contains filtered or unexported fields
}

type LogLine struct {
	Message       string `json:"message"`
	Timestamp     string `json:"timestamp"`
	PodName       string `json:"podName"`
	ContainerName string `json:"containerName"`
}

type ReadLogsOptions struct {
	ContainerName string
	SinceSeconds  *int64
	TailLines     *int64
}