internal

Documentation

Overview

Package internal provides support for package appengine.

Programs should not use this package directly. Its API is not stable. Use packages appengine and appengine/* instead.

Index

• Variables
• func AppID(c context.Context) string
• func Call(ctx context.Context, service, method string, in, out proto.Message) error
• func ContextForTesting(req *http.Request) context.Context
• func Datacenter(ctx context.Context) string
• func DefaultVersionHostname(ctx context.Context) string
• func FullyQualifiedAppID(ctx context.Context) string
• func IncomingHeaders(ctx context.Context) http.Header
• func InstanceID() string
• func IsAppEngine() bool
• func IsDevAppServer() bool
• func IsFlex() bool
• func IsSecondGen() bool
• func IsStandard() bool
• func Logf(ctx context.Context, level int64, format string, args ...interface{})
• func Main()
• func Middleware(next http.Handler) http.Handler
• func ModuleName(_ context.Context) string
• func NamespaceFromContext(ctx context.Context) string
• func NamespacedContext(ctx context.Context, namespace string) context.Context
• func RegisterErrorCodeMap(service string, m map[int32]string)
• func RegisterTestRequest(req *http.Request, apiURL *url.URL, appID string) *http.Request
• func RegisterTimeoutErrorCode(service string, code int32)
• func RegisterTransactionSetter(f interface{})
• func ReqContext(req *http.Request) context.Context
• func RequestID(ctx context.Context) string
• func RunTransactionOnce(c context.Context, f func(context.Context) error, xg bool, readOnly bool, ...) (*pb.Transaction, error)
• func ServerSoftware() string
• func SetTestEnv() func()
• func VersionID(_ context.Context) string
• func WithAppIDOverride(ctx context.Context, appID string) context.Context
• func WithCallOverride(ctx context.Context, f CallOverrideFunc) context.Context
• func WithContext(parent context.Context, req *http.Request) context.Context
• func WithLogOverride(ctx context.Context, f logOverrideFunc) context.Context
• type APIError
  • func (e *APIError) Error() string
  • func (e *APIError) IsTimeout() bool
• type CallError
  • func (e *CallError) Error() string
  • func (e *CallError) IsTimeout() bool
• type CallOverrideFunc

Variables

var ErrConcurrentTransaction = errors.New("internal: concurrent transaction")

var MainPath string

MainPath stores the file path of the main package.

var NamespaceMods = make(map[string]func(m proto.Message, namespace string))

NamespaceMods is a map from API service to a function that will mutate an RPC request to attach a namespace. The function should be prepared to be called on the same message more than once; it should only modify the RPC request the first time.

Functions

func AppID

func AppID(c context.Context) string

AppID is the implementation of the wrapper function of the same name in ../identity.go. See that file for commentary.

func Call

func Call(ctx context.Context, service, method string, in, out proto.Message) error

func ContextForTesting

func ContextForTesting(req *http.Request) context.Context

func Datacenter

func Datacenter(ctx context.Context) string

func DefaultVersionHostname

func DefaultVersionHostname(ctx context.Context) string

func FullyQualifiedAppID

func FullyQualifiedAppID(ctx context.Context) string

FullyQualifiedAppID returns the fully-qualified application ID. This may contain a partition prefix (e.g. "s~" for High Replication apps), or a domain prefix (e.g. "example.com:").

func IncomingHeaders

func IncomingHeaders(ctx context.Context) http.Header

func InstanceID

func InstanceID() string

func IsAppEngine

func IsAppEngine() bool

IsAppEngine is the implementation of the wrapper function of the same name in ../appengine.go. See that file for commentary.

func IsDevAppServer

func IsDevAppServer() bool

func IsFlex

func IsFlex() bool

IsFlex is the implementation of the wrapper function of the same name in ../appengine.go. See that file for commentary.

func IsSecondGen

func IsSecondGen() bool

IsSecondGen is the implementation of the wrapper function of the same name in ../appengine.go. See that file for commentary.

func IsStandard

func IsStandard() bool

IsStandard is the implementation of the wrapper function of the same name in ../appengine.go. See that file for commentary.

func Logf

func Logf(ctx context.Context, level int64, format string, args ...interface{})

func Main

func Main()

func Middleware

func Middleware(next http.Handler) http.Handler

Middleware wraps an http handler so that it can make GAE API calls

func ModuleName

func ModuleName(_ context.Context) string

func NamespaceFromContext

func NamespaceFromContext(ctx context.Context) string

func NamespacedContext

func NamespacedContext(ctx context.Context, namespace string) context.Context

NamespacedContext wraps a Context to support namespaces.

func RegisterErrorCodeMap

func RegisterErrorCodeMap(service string, m map[int32]string)

RegisterErrorCodeMap is called from API implementations to register their error code map. This should only be called from init functions.

func RegisterTestRequest

func RegisterTestRequest(req *http.Request, apiURL *url.URL, appID string) *http.Request

RegisterTestRequest registers the HTTP request req for testing, such that any API calls are sent to the provided URL. It should only be used by test code or test helpers like aetest.

func RegisterTimeoutErrorCode

func RegisterTimeoutErrorCode(service string, code int32)

func RegisterTransactionSetter

func RegisterTransactionSetter(f interface{})

RegisterTransactionSetter registers a function that sets transaction information in a protocol buffer message. f should be a function with two arguments, the first being a protocol buffer type, and the second being *datastore.Transaction.

func ReqContext

func ReqContext(req *http.Request) context.Context

func RequestID

func RequestID(ctx context.Context) string

func RunTransactionOnce

func RunTransactionOnce(c context.Context, f func(context.Context) error, xg bool, readOnly bool, previousTransaction *pb.Transaction) (*pb.Transaction, error)

func ServerSoftware

func ServerSoftware() string

func SetTestEnv

func SetTestEnv() func()

SetTestEnv sets the env variables for testing background ticket in Flex.

func VersionID

func VersionID(_ context.Context) string

func WithAppIDOverride

func WithAppIDOverride(ctx context.Context, appID string) context.Context

func WithCallOverride

func WithCallOverride(ctx context.Context, f CallOverrideFunc) context.Context

func WithContext

func WithContext(parent context.Context, req *http.Request) context.Context

func WithLogOverride

func WithLogOverride(ctx context.Context, f logOverrideFunc) context.Context

Types

type APIError

type APIError struct {
	Service string
	Detail  string
	Code    int32 // API-specific error code
}

APIError is the type returned by appengine.Context's Call method when an API call fails in an API-specific way. This may be, for instance, a taskqueue API call failing with TaskQueueServiceError::UNKNOWN_QUEUE.

func (*APIError) Error

func (e *APIError) Error() string

func (*APIError) IsTimeout

func (e *APIError) IsTimeout() bool

type CallError

type CallError struct {
	Detail string
	Code   int32
	// TODO: Remove this if we get a distinguishable error code.
	Timeout bool
}

CallError is the type returned by appengine.Context's Call method when an API call fails in a generic way, such as RpcError::CAPABILITY_DISABLED.

func (*CallError) Error

func (e *CallError) Error() string

func (*CallError) IsTimeout

func (e *CallError) IsTimeout() bool

type CallOverrideFunc

type CallOverrideFunc func(ctx context.Context, service, method string, in, out proto.Message) error