Documentation ¶
Index ¶
- type Channel
- func (g *Channel) GetAppConfig() (*config.ApplicationConfig, error)
- func (g *Channel) HealthProbe(ctx context.Context) (bool, error)
- func (g *Channel) InvokeMethod(ctx context.Context, req *invokev1.InvokeMethodRequest) (*invokev1.InvokeMethodResponse, error)
- func (g *Channel) SetAppHealth(ah *apphealth.AppHealth)
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) *Channel
CreateLocalChannel creates a gRPC connection with user code.
func (*Channel) GetAppConfig ¶ added in v1.2.0
func (g *Channel) GetAppConfig() (*config.ApplicationConfig, error)
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) (*invokev1.InvokeMethodResponse, error)
InvokeMethod invokes user code via gRPC.
func (*Channel) SetAppHealth ¶ added in v1.9.0
SetAppHealth sets the apphealth.AppHealth object.
Click to show internal directories.
Click to hide internal directories.