k8s

Documentation

Index

• func AddEndpointToJob(j *batchv1.Job, endpoint string)
• func AddUIDToJob(j *batchv1.Job, uid uuid.UUID)
• func DeleteJob(ctx context.Context, cl JobDeleter, uid uuid.UUID) error
• func GetEndpointFromJob(j *batchv1.Job) (string, error)
• func GetUIDFromJob(j *batchv1.Job) (uuid.UUID, error)
• func NewClient(inCluster bool) (*kubernetes.Clientset, error)
• func NewJob(uid uuid.UUID, endpoint string, numPods, numRequests, numConcurrent uint, ...) *batchv1.Job
• type ConfigType
• type JobDeleter
• type JobLister

Functions

func AddEndpointToJob

func AddEndpointToJob(j *batchv1.Job, endpoint string)

func AddUIDToJob

func AddUIDToJob(j *batchv1.Job, uid uuid.UUID)

func DeleteJob

func DeleteJob(
	ctx context.Context,
	cl JobDeleter,
	uid uuid.UUID,
) error

func GetEndpointFromJob

func GetEndpointFromJob(j *batchv1.Job) (string, error)

func GetUIDFromJob

func GetUIDFromJob(j *batchv1.Job) (uuid.UUID, error)

func NewClient

func NewClient(inCluster bool) (*kubernetes.Clientset, error)

func NewJob

func NewJob(
	uid uuid.UUID,
	endpoint string,
	numPods,
	numRequests,
	numConcurrent uint,
	headers []string,
) *batchv1.Job

Types

type ConfigType

type ConfigType string

const (
	ConfigTypeInCluster ConfigType = "in-cluster"
	ConfigTypeLocalhost ConfigType = "localhost"
)

type JobDeleter

type JobDeleter interface {
	Delete(ctx context.Context, name string, opts metav1.DeleteOptions) error
}

type JobLister

type JobLister interface {
	List(ctx context.Context, opts metav1.ListOptions) (*batchv1.JobList, error)
}