serialize

Documentation

Index

• func MetadataFromKey(key string) (*schedulerv1pb.JobMetadata, error)
• func PrefixesFromNamespace(namespace string) []string
• type Job
  • func (j *Job) Metadata() *anypb.Any
  • func (j *Job) Name() string
• type Options
• type Request
• type Serializer
  • func New(opts Options) *Serializer
  • func (s *Serializer) FromRequest(ctx context.Context, req Request) (*Job, error)
  • func (s *Serializer) FromWatch(stream schedulerv1pb.Scheduler_WatchJobsServer) (*schedulerv1pb.WatchJobsRequestInitial, error)
  • func (s *Serializer) PrefixFromList(ctx context.Context, req *schedulerv1pb.JobMetadata) (string, error)

Functions

func MetadataFromKey

func MetadataFromKey(key string) (*schedulerv1pb.JobMetadata, error)

MetadataFromKey returns the JobMetadata based on a raw job key.

func PrefixesFromNamespace

func PrefixesFromNamespace(namespace string) []string

PrefixesFromNamespace returns key prefixes for all jobs types for a given namespace.

Types

type Job

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

func (*Job) Metadata

func (j *Job) Metadata() *anypb.Any

func (*Job) Name

func (j *Job) Name() string

type Options

type Options struct {
	Security security.Handler
}

type Request

type Request interface {
	GetName() string
	GetMetadata() *schedulerv1pb.JobMetadata
}

type Serializer

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

func New

func New(opts Options) *Serializer

func (*Serializer) FromRequest

func (s *Serializer) FromRequest(ctx context.Context, req Request) (*Job, error)

func (*Serializer) FromWatch

func (s *Serializer) FromWatch(stream schedulerv1pb.Scheduler_WatchJobsServer) (*schedulerv1pb.WatchJobsRequestInitial, error)

func (*Serializer) PrefixFromList

func (s *Serializer) PrefixFromList(ctx context.Context, req *schedulerv1pb.JobMetadata) (string, error)