grpc

Documentation

Index

• type Channel
  • func CreateLocalChannel(port, maxConcurrency int, conn *grpc.ClientConn, spec config.TracingSpec, ...) *Channel
  • func (g *Channel) GetAppConfig(_ context.Context, appID string) (*config.ApplicationConfig, error)
  • func (g *Channel) HealthProbe(ctx context.Context) (bool, 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)

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) *Channel

CreateLocalChannel creates a gRPC connection with user code.

func (*Channel) GetAppConfig

func (g *Channel) GetAppConfig(_ context.Context, appID string) (*config.ApplicationConfig, error)

GetAppConfig gets application config from user application.

func (*Channel) HealthProbe

func (g *Channel) HealthProbe(ctx context.Context) (bool, error)

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

func (g *Channel) SetAppHealth(ah *apphealth.AppHealth)

SetAppHealth sets the apphealth.AppHealth object.

func (*Channel) TriggerJob

func (g *Channel) TriggerJob(ctx context.Context, name string, data *anypb.Any) (*invokev1.InvokeMethodResponse, error)

TriggerJob sends the triggered job to the app via gRPC.