configmap

Documentation

Index

• type Source
  • func New(options ...source.Option) (*Source, error)
  • func (s *Source) GetExtend() source.Scheme
  • func (s *Source) Open(_ string) (fs.File, error)
  • func (s *Source) ReadFile(name string) (rb []byte, err error)
  • func (s *Source) Watch(c source.Entity, unm func([]byte, any) error) error

Types

type Source

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

Source is a k8s configmap source

func New

func New(options ...source.Option) (*Source, error)

func (*Source) GetExtend

func (s *Source) GetExtend() source.Scheme

func (*Source) Open

func (s *Source) Open(_ string) (fs.File, error)

Open a file for reading

func (*Source) ReadFile

func (s *Source) ReadFile(name string) (rb []byte, err error)

ReadFile read file

func (*Source) Watch

func (s *Source) Watch(c source.Entity, unm func([]byte, any) error) error

Watch configmap