gcpfunctions

type API struct {
	Functions functionspb.FunctionServiceServer
	// contains filtered or unexported fields
}

type ConfigProvider interface {
	GetGCPFunctionsSettings() Settings
}

type EventBus interface {
	GetTopic(name string) (*pubsubpb.Topic, error)
	CreateSubscription(in *pubsubpb.Subscription) (*pubsubpb.Subscription, error)
	DeleteSubscription(name string) error
}

type Handler struct {
	Backend *InMemoryBackend

	// Port is the gRPC port; IngressPort the HTTP ingress port. Zero binds an ephemeral port, negative disables ingress.
	Port        int
	IngressPort int
	// contains filtered or unexported fields
}

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

type InvokeRequest struct {
	Header http.Header
	Method string
	Path   string
	Body   []byte
}

type InvokeResult struct {
	Header http.Header
	Body   []byte
	Status int
}

type ObjectReader interface {
	ReadObject(bucket, object string) ([]byte, error)
}

type PortPool = gcpserve.PortPool

type Provider struct{}

type Runner = gcpserve.Runner

type Settings struct {
	Engine string `` //nolint:lll // config struct tags are intentionally verbose
	/* 208-byte string literal not displayed */
	Port int `` //nolint:lll // config struct tags are intentionally verbose
	/* 226-byte string literal not displayed */
	IngressPort int `` //nolint:lll // config struct tags are intentionally verbose
	/* 286-byte string literal not displayed */
	StartupTimeout time.Duration `` //nolint:lll // config struct tags are intentionally verbose
	/* 206-byte string literal not displayed */
}