grpc

Feb 26, 2025

Changes in this version

type Server

+ func (s *Server) AddTopicEventSubscriber(sub *common.Subscription, subscriber common.TopicEventSubscriber) error

Aug 14, 2024

Changes in this version

type Server

+ func (s *Server) AddJobEventHandler(name string, fn common.JobEventHandler) error

+ func (s *Server) OnBulkTopicEventAlpha1(ctx context.Context, in *runtimev1pb.TopicEventBulkRequest) (*runtimev1pb.TopicEventBulkResponse, error)

+ func (s *Server) OnJobEventAlpha1(ctx context.Context, in *runtimepb.JobEventRequest) (*runtimepb.JobEventResponse, error)

Jun 6, 2023

Changes in this version

+ func NewServiceWithGrpcServer(lis net.Listener, server *grpc.Server) common.Service

type Server

+ func (s *Server) RegisterActorImplFactoryContext(f actor.FactoryContext, opts ...config.Option)

Oct 4, 2022

Changes in this version

type Server

+ func (s *Server) AddHealthCheckHandler(_ string, fn common.HealthCheckHandler) error

+ func (s *Server) GrpcServer() *grpc.Server

+ func (s *Server) HealthCheck(ctx context.Context, _ *emptypb.Empty) (*pb.HealthCheckResponse, error)

Apr 6, 2022

Changes in this version

type Server

+ func (s *Server) GracefulStop() error

Nov 2, 2021

Changes in this version

type Server

+ func (s *Server) RegisterActorImplFactory(f actor.Factory, opts ...config.Option)

Aug 18, 2020

Changes in this version

+ func NewService(address string) (s common.Service, err error)

+ func NewServiceWithListener(lis net.Listener) common.Service

+ type Server struct

+ func (s *Server) AddBindingInvocationHandler(name string, ...) error

+ func (s *Server) AddServiceInvocationHandler(method string, ...) error

+ func (s *Server) AddTopicEventHandler(sub *common.Subscription, ...) error

+ func (s *Server) ListInputBindings(ctx context.Context, in *empty.Empty) (*pb.ListInputBindingsResponse, error)

+ func (s *Server) ListTopicSubscriptions(ctx context.Context, in *empty.Empty) (*pb.ListTopicSubscriptionsResponse, error)

+ func (s *Server) OnBindingEvent(ctx context.Context, in *pb.BindingEventRequest) (*pb.BindingEventResponse, error)

+ func (s *Server) OnInvoke(ctx context.Context, in *cpb.InvokeRequest) (*cpb.InvokeResponse, error)

+ func (s *Server) OnTopicEvent(ctx context.Context, in *pb.TopicEventRequest) (*pb.TopicEventResponse, error)

+ func (s *Server) Start() error

+ func (s *Server) Stop() error