subscribe_server

Documentation

Index

• Constants
• type SubscribeRpcServer
  • func NewServer(ctx context.Context) *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

const (
	DEFAULT_RETRY_INTERVAL = 5 * time.Second // in second
	RPC_SERVER_BUFFER_SIZE = 200
)

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