Documentation
¶
Index ¶
- type Channel
- func (g *Channel) AddAppTokenToContext(ctx context.Context) context.Context
- func (g *Channel) GetAppConfig(_ context.Context, appID string) (*config.ApplicationConfig, error)
- func (g *Channel) HealthProbe(ctx context.Context) (*apphealth.Status, error)
- func (g *Channel) InvokeMethod(ctx context.Context, req *invokev1.InvokeMethodRequest, _ string) (*invokev1.InvokeMethodResponse, error)
- func (g *Channel) SetAppHealth(ah *apphealth.AppHealth)
- func (g *Channel) TriggerJob(ctx context.Context, name string, data *anypb.Any) (*invokev1.InvokeMethodResponse, error)
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type Channel ¶
type Channel struct {
// contains filtered or unexported fields
}
Channel is a concrete AppChannel implementation for interacting with gRPC based user code.
func CreateLocalChannel ¶
func CreateLocalChannel(port, maxConcurrency int, conn *grpc.ClientConn, spec config.TracingSpec, maxRequestBodySize int, readBufferSize int, baseAddress string, appAPIToken string) *Channel
CreateLocalChannel creates a gRPC connection with user code.
func (*Channel) AddAppTokenToContext ¶ added in v1.15.13
AddAppTokenToContext adds the app API token to the outgoing gRPC context using the token captured at channel creation time
func (*Channel) GetAppConfig ¶ added in v1.2.0
GetAppConfig gets application config from user application.
func (*Channel) HealthProbe ¶ added in v1.9.0
HealthProbe performs a health probe.
func (*Channel) InvokeMethod ¶
func (g *Channel) InvokeMethod(ctx context.Context, req *invokev1.InvokeMethodRequest, _ string) (*invokev1.InvokeMethodResponse, error)
InvokeMethod invokes user code via gRPC.
func (*Channel) SetAppHealth ¶ added in v1.9.0
SetAppHealth sets the apphealth.AppHealth object.
Source Files
Click to show internal directories.
Click to hide internal directories.