Documentation
¶
Index ¶
- Constants
- type SubscribeRpcServer
- func (s *SubscribeRpcServer) ConvertDeltaToHtml(ctx context.Context, request *types.ConvertJsonObjectsToHtmlRequest) (*types.ConvertJsonObjectsToHtmlResponse, error)
- func (s *SubscribeRpcServer) HealthCheck(ctx context.Context, request *types.HealthCheckRequest) (*types.HealthCheckResponse, error)
- func (s *SubscribeRpcServer) StartDispatcher()
- func (s *SubscribeRpcServer) Stop()
- func (s *SubscribeRpcServer) SubscribeNotification(requestMsg *types.SubscribeNotificationMsg, ...) error
Constants ¶
View Source
const ( DEFAULT_RETRY_INTERVAL = 5 * time.Second // in second RPC_SERVER_BUFFER_SIZE = 200 )
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type SubscribeRpcServer ¶
type SubscribeRpcServer struct {
// Configs
ServiceConfig *config.Config
// Clients
// DAOs
// Channel
FanInChannel chan *daemon.StreamingMessage
// Services
CleanerService *daemon.Cleaner
ReminderService *daemon.Reminder
InvestmentService *daemon.Investment
services.UnimplementedDaemonServer
// contains filtered or unexported fields
}
func NewServer ¶
func NewServer(ctx context.Context) *SubscribeRpcServer
func (*SubscribeRpcServer) ConvertDeltaToHtml ¶
func (s *SubscribeRpcServer) ConvertDeltaToHtml(ctx context.Context, request *types.ConvertJsonObjectsToHtmlRequest) (*types.ConvertJsonObjectsToHtmlResponse, error)
func (*SubscribeRpcServer) HealthCheck ¶
func (s *SubscribeRpcServer) HealthCheck( ctx context.Context, request *types.HealthCheckRequest, ) (*types.HealthCheckResponse, error)
func (*SubscribeRpcServer) StartDispatcher ¶
func (s *SubscribeRpcServer) StartDispatcher()
Start a go routine to dispatch all incoming messages, each of them is going to be sent via one of registered RPC sessions, we pick next available session in a round robin manner
func (*SubscribeRpcServer) Stop ¶
func (s *SubscribeRpcServer) Stop()
func (*SubscribeRpcServer) SubscribeNotification ¶
func (s *SubscribeRpcServer) SubscribeNotification( requestMsg *types.SubscribeNotificationMsg, stream services.Daemon_SubscribeNotificationServer, ) error
Source Files
Click to show internal directories.
Click to hide internal directories.