driver

Documentation

Index

• func EndpointName(p string) string
• type Driver
  • func (d *Driver) Authorize(in driver.AuthorizeInput) driver.AuthorizeOutput
  • func (d *Driver) FieldResolve(in driver.FieldResolveInput) driver.FieldResolveOutput
  • func (d *Driver) InterfaceResolveType(in driver.InterfaceResolveTypeInput) driver.InterfaceResolveTypeOutput
  • func (d *Driver) ScalarParse(in driver.ScalarParseInput) driver.ScalarParseOutput
  • func (d *Driver) ScalarSerialize(in driver.ScalarSerializeInput) driver.ScalarSerializeOutput
  • func (d *Driver) SetSecrets(in driver.SetSecretsInput) driver.SetSecretsOutput
  • func (d *Driver) Stream(in driver.StreamInput) driver.StreamOutput
  • func (d *Driver) SubscriptionConnection(in driver.SubscriptionConnectionInput) driver.SubscriptionConnectionOutput
  • func (d *Driver) SubscriptionListen(in driver.SubscriptionListenInput) driver.SubscriptionListenOutput
  • func (d *Driver) UnionResolveType(in driver.UnionResolveTypeInput) driver.UnionResolveTypeOutput
• type HTTPClient
• type ProtobufClient
  • func (p ProtobufClient) New(u, f string) driver.Driver
  • func (p ProtobufClient) Post(url, contentType string, body io.Reader) (resp *http.Response, err error)
• type WorkerClient

Functions

func EndpointName

func EndpointName(p string) string

EndpointName create endpoint name from string

Types

type Driver

type Driver struct {
	BaseURL     string
	FunctionURL map[string]string
	WorkerClient
}

Driver implements stucco driver interface calling protobuf workers over http with configurable workers base url

func (*Driver) Authorize

func (d *Driver) Authorize(in driver.AuthorizeInput) driver.AuthorizeOutput

Authorize implements driver.Driver

func (*Driver) FieldResolve

func (d *Driver) FieldResolve(in driver.FieldResolveInput) driver.FieldResolveOutput

FieldResolve implements driver.Driver

func (*Driver) InterfaceResolveType

func (d *Driver) InterfaceResolveType(in driver.InterfaceResolveTypeInput) driver.InterfaceResolveTypeOutput

InterfaceResolveType implements driver.Driver

func (*Driver) ScalarParse

func (d *Driver) ScalarParse(in driver.ScalarParseInput) driver.ScalarParseOutput

ScalarParse implements driver.Driver

func (*Driver) ScalarSerialize

func (d *Driver) ScalarSerialize(in driver.ScalarSerializeInput) driver.ScalarSerializeOutput

ScalarSerialize implements driver.Driver

func (*Driver) SetSecrets

func (d *Driver) SetSecrets(in driver.SetSecretsInput) driver.SetSecretsOutput

SetSecrets implements driver.Driver

func (*Driver) Stream

func (d *Driver) Stream(in driver.StreamInput) driver.StreamOutput

Stream implements driver.Driver

func (*Driver) SubscriptionConnection

func (d *Driver) SubscriptionConnection(in driver.SubscriptionConnectionInput) driver.SubscriptionConnectionOutput

SubscriptionConnection implements driver.Driver

func (*Driver) SubscriptionListen

func (d *Driver) SubscriptionListen(in driver.SubscriptionListenInput) driver.SubscriptionListenOutput

SubscriptionListen implements driver.Driver

func (*Driver) UnionResolveType

func (d *Driver) UnionResolveType(in driver.UnionResolveTypeInput) driver.UnionResolveTypeOutput

UnionResolveType implements driver.Driver

type HTTPClient

type HTTPClient interface {
	Do(req *http.Request) (*http.Response, error)
}

HTTPClient used by azure client

type ProtobufClient

type ProtobufClient struct {
	HTTPClient
	FunctionName string
}

ProtobufClient is a worker client using protobuf protocol

func (ProtobufClient) New

func (p ProtobufClient) New(u, f string) driver.Driver

New returns new driver using protobuf protocol

func (ProtobufClient) Post

func (p ProtobufClient) Post(url, contentType string, body io.Reader) (resp *http.Response, err error)

Post implemention for azure worker protobuf communication

type WorkerClient

type WorkerClient interface {
	New(url, fname string) driver.Driver
}

WorkerClient creates new protobuf for communication with workers