Documentation ¶
Index ¶
- func StartGRPCServer(f *FSSReconcileServer, addr string) (*grpc.Server, error)
- type FSSReconcileServer
- func (s *FSSReconcileServer) NewFunctionRuntime(instance api.FunctionInstance) (api.FunctionRuntime, error)
- func (s *FSSReconcileServer) Reconcile(_ *proto.ConnectRequest, stream proto.FSReconcile_ReconcileServer) error
- func (s *FSSReconcileServer) UpdateStatus(_ context.Context, newStatus *proto.FunctionStatus) (*proto.Response, error)
- func (s *FSSReconcileServer) WaitForReady() <-chan struct{}
- type FuncRuntime
- type FunctionServerImpl
- func (f *FunctionServerImpl) GetState(ctx context.Context, req *proto.GetStateRequest) (*proto.GetStateResponse, error)
- func (f *FunctionServerImpl) Output(ctx context.Context, e *proto.Event) (*proto.Response, error)
- func (f *FunctionServerImpl) Process(req *proto.FunctionProcessRequest, stream proto.Function_ProcessServer) error
- func (f *FunctionServerImpl) PutState(ctx context.Context, req *proto.PutStateRequest) (*proto.Response, error)
- type Status
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func StartGRPCServer ¶
func StartGRPCServer(f *FSSReconcileServer, addr string) (*grpc.Server, error)
Types ¶
type FSSReconcileServer ¶
type FSSReconcileServer struct { proto.UnimplementedFSReconcileServer // contains filtered or unexported fields }
FSSReconcileServer is the struct that implements the FSServiceServer interface.
func NewFSReconcile ¶
func NewFSReconcile(ctx context.Context) *FSSReconcileServer
func (*FSSReconcileServer) NewFunctionRuntime ¶
func (s *FSSReconcileServer) NewFunctionRuntime(instance api.FunctionInstance) (api.FunctionRuntime, error)
func (*FSSReconcileServer) Reconcile ¶
func (s *FSSReconcileServer) Reconcile(_ *proto.ConnectRequest, stream proto.FSReconcile_ReconcileServer) error
func (*FSSReconcileServer) UpdateStatus ¶
func (s *FSSReconcileServer) UpdateStatus(_ context.Context, newStatus *proto.FunctionStatus) (*proto.Response, error)
func (*FSSReconcileServer) WaitForReady ¶
func (s *FSSReconcileServer) WaitForReady() <-chan struct{}
type FuncRuntime ¶ added in v0.5.0
type FuncRuntime struct { api.FunctionRuntime Name string // contains filtered or unexported fields }
func (*FuncRuntime) Stop ¶ added in v0.5.0
func (f *FuncRuntime) Stop()
Stop stops the function runtime and remove it It is different from the ctx.Cancel. It will make sure the runtime has been deleted after this method returns.
func (*FuncRuntime) Update ¶ added in v0.5.0
func (f *FuncRuntime) Update(new *proto.FunctionStatus)
func (*FuncRuntime) WaitForReady ¶ added in v0.5.0
func (f *FuncRuntime) WaitForReady() <-chan error
type FunctionServerImpl ¶
type FunctionServerImpl struct { proto.UnimplementedFunctionServer // contains filtered or unexported fields }
func NewFunctionServerImpl ¶
func NewFunctionServerImpl(s *FSSReconcileServer) *FunctionServerImpl
func (*FunctionServerImpl) GetState ¶
func (f *FunctionServerImpl) GetState(ctx context.Context, req *proto.GetStateRequest) (*proto.GetStateResponse, error)
func (*FunctionServerImpl) Process ¶
func (f *FunctionServerImpl) Process(req *proto.FunctionProcessRequest, stream proto.Function_ProcessServer) error
func (*FunctionServerImpl) PutState ¶
func (f *FunctionServerImpl) PutState(ctx context.Context, req *proto.PutStateRequest) (*proto.Response, error)
Click to show internal directories.
Click to hide internal directories.