content

Documentation

Index

• type ApiSpecGetter
• type AsyncApiSpecGetter
• type Config
• type Container
  • func New(cfg Config) (*Container, error)
• type ContentGetter
• type Resolver
  • func (r Resolver) ContentQuery(ctx context.Context, contentType, id string) (*gqlschema.JSON, error)
  • func (r Resolver) TopicsQuery(ctx context.Context, topics []gqlschema.InputTopic, internal *bool) ([]gqlschema.TopicEntry, error)
  • func (r *Resolver) WaitForCacheSync(stopCh <-chan struct{})

Types

type ApiSpecGetter

type ApiSpecGetter interface {
	Find(kind, id string) (*storage.ApiSpec, error)
}

type AsyncApiSpecGetter

type AsyncApiSpecGetter interface {
	Find(kind, id string) (*storage.AsyncApiSpec, error)
}

type Config

type Config struct {
	Address         string `envconfig:"default=minio.kyma.local"`
	Port            int    `envconfig:"default=443"`
	AccessKey       string
	SecretKey       string
	Bucket          string `envconfig:"default=content"`
	Secure          bool   `envconfig:"default=true"`
	ExternalAddress string `envconfig:"optional"`
	AssetsFolder    string `envconfig:"default=assets"`
	VerifySSL       bool   `envconfig:"default=true"`
}

type Container

type Container struct {
	Resolver           *Resolver
	ApiSpecGetter      ApiSpecGetter
	AsyncApiSpecGetter AsyncApiSpecGetter
	ContentGetter      ContentGetter
}

func New

func New(cfg Config) (*Container, error)

type ContentGetter

type ContentGetter interface {
	Find(kind, id string) (*storage.Content, error)
}

type Resolver

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

func (Resolver) ContentQuery

func (r Resolver) ContentQuery(ctx context.Context, contentType, id string) (*gqlschema.JSON, error)

func (Resolver) TopicsQuery

func (r Resolver) TopicsQuery(ctx context.Context, topics []gqlschema.InputTopic, internal *bool) ([]gqlschema.TopicEntry, error)

func (*Resolver) WaitForCacheSync

func (r *Resolver) WaitForCacheSync(stopCh <-chan struct{})