k8s

Documentation

Index

• Variables
• type CommonSetup
• type CommonSetupFn
  • func (f CommonSetupFn) Generate(svcs apis.ServiceGraph) ([]runtime.Object, []byte, error)
• type Formatters
  • func SimpleFormatters(baseName string) Formatters
• type Generator
  • func NewGenerator(opts ...Option) (Generator, error)
  • func (e Generator) Apply(writer io.Writer, svc apis.ServiceGraph) error
• type Option
  • func AsStatefulSet() Option
  • func WithConfigMapGenerator(fn func(f Formatters, svc apis.Service) (string, error)) Option
  • func WithFormatters(f Formatters) Option
  • func WithImage(image string) Option
  • func WithNamespace(name string) Option
  • func WithPodTemplateSpecMutator(fn func(f Formatters, svc apis.Service, template *v1.PodTemplateSpec) error) Option
  • func WithPort(p int) Option
• type OptionFn
  • func (f OptionFn) Apply(g *generator) error
• type ServiceGeneratorError
  • func (s *ServiceGeneratorError) Error() string
  • func (s *ServiceGeneratorError) Is(target error) bool
  • func (s *ServiceGeneratorError) Unwrap() error
• type WorkloadGenerator
• type WorkloadGeneratorFn
  • func (f WorkloadGeneratorFn) Apply(svc apis.Service) ([]runtime.Object, []byte, error)

Variables

var DefaultSerializer = json.NewSerializerWithOptions(json.DefaultMetaFactory, nil, nil, json.SerializerOptions{Yaml: true, Pretty: true, Strict: true})

Types

type CommonSetup

type CommonSetup interface {
	Generate(svcs apis.ServiceGraph) ([]runtime.Object, []byte, error)
}

type CommonSetupFn

type CommonSetupFn func(svcs apis.ServiceGraph) ([]runtime.Object, []byte, error)

func (CommonSetupFn) Generate

func (f CommonSetupFn) Generate(svcs apis.ServiceGraph) ([]runtime.Object, []byte, error)

type Formatters

type Formatters struct {
	BaseName string
	Name     func(idx int) string
	Url      func(idx int, port int) string
}

func SimpleFormatters

func SimpleFormatters(baseName string) Formatters

type Generator

type Generator struct {
	CommonSetup       CommonSetup
	WorkloadGenerator WorkloadGenerator
	Serializer        *json.Serializer
}

func NewGenerator

func NewGenerator(opts ...Option) (Generator, error)

func (Generator) Apply

func (e Generator) Apply(writer io.Writer, svc apis.ServiceGraph) error

type Option

type Option interface {
	Apply(g *generator) error
}

func AsStatefulSet

func AsStatefulSet() Option

func WithConfigMapGenerator

func WithConfigMapGenerator(fn func(f Formatters, svc apis.Service) (string, error)) Option

func WithFormatters

func WithFormatters(f Formatters) Option

func WithImage

func WithImage(image string) Option

func WithNamespace

func WithNamespace(name string) Option

func WithPodTemplateSpecMutator

func WithPodTemplateSpecMutator(fn func(f Formatters, svc apis.Service, template *v1.PodTemplateSpec) error) Option

func WithPort

func WithPort(p int) Option

type OptionFn

type OptionFn func(g *generator) error

func (OptionFn) Apply

func (f OptionFn) Apply(g *generator) error

type ServiceGeneratorError

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

func (*ServiceGeneratorError) Error

func (s *ServiceGeneratorError) Error() string

func (*ServiceGeneratorError) Is

func (s *ServiceGeneratorError) Is(target error) bool

func (*ServiceGeneratorError) Unwrap

func (s *ServiceGeneratorError) Unwrap() error

type WorkloadGenerator

type WorkloadGenerator interface {
	Apply(svc apis.Service) ([]runtime.Object, []byte, error)
}

type WorkloadGeneratorFn

type WorkloadGeneratorFn func(svc apis.Service) ([]runtime.Object, []byte, error)

func (WorkloadGeneratorFn) Apply

func (f WorkloadGeneratorFn) Apply(svc apis.Service) ([]runtime.Object, []byte, error)