staticdatasource

Documentation

Index

• Constants
• func ConfigJSON(config Configuration) json.RawMessage
• type Configuration
• type Factory
  • func (f *Factory) Planner() plan.DataSourcePlanner
• type Planner
  • func (p *Planner) ConfigureFetch() plan.FetchConfiguration
  • func (p *Planner) ConfigureSubscription() plan.SubscriptionConfiguration
  • func (p *Planner) Register(visitor *plan.Visitor, customConfiguration json.RawMessage, isNested bool) error
• type Source
  • func (_ Source) Load(ctx context.Context, input []byte, bufPair *resolve.BufPair) (err error)
  • func (_ Source) UniqueIdentifier() []byte

Constants

const (
	UniqueIdentifier = "static"
)

Functions

func ConfigJSON

func ConfigJSON(config Configuration) json.RawMessage

Types

type Configuration

type Configuration struct {
	Data string `json:"data"`
}

type Factory

type Factory struct{}

func (*Factory) Planner

func (f *Factory) Planner() plan.DataSourcePlanner

type Planner

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

func (*Planner) ConfigureFetch

func (p *Planner) ConfigureFetch() plan.FetchConfiguration

func (*Planner) ConfigureSubscription

func (p *Planner) ConfigureSubscription() plan.SubscriptionConfiguration

func (*Planner) Register

func (p *Planner) Register(visitor *plan.Visitor, customConfiguration json.RawMessage, isNested bool) error

type Source

type Source struct{}

func (Source) Load

func (_ Source) Load(ctx context.Context, input []byte, bufPair *resolve.BufPair) (err error)

func (Source) UniqueIdentifier

func (_ Source) UniqueIdentifier() []byte