remotepusher

Documentation

Index

• func NewHTTPClient(baseurl string) pt.Pusher
• type PusherClient
  • func NewClient(txns pusherpb.PusherServiceInterface, ...) *PusherClient
  • func NewDBPusher(baseurl string) *PusherClient
  • func (c *PusherClient) Push(ctx context.Context, txns []pt.Txn) error
  • func (c *PusherClient) PushSettings(ctx context.Context, sett *pt.Settings) error
• type RoutedPusher
  • func NewRoutedPusher(router pt.Router) *RoutedPusher
  • func (r *RoutedPusher) Push(ctx context.Context, txns []pt.Txn) error
• type Service
  • func NewService(pusher pt.Pusher) *Service
  • func (s *Service) Push(ctx context.Context, req *pusherpb.PushRequest) (*pusherpb.PushResponse, error)
• type SettingsService
  • func NewSettingsService(pusher pt.SettingsPusher) *SettingsService
  • func (s *SettingsService) PushSettings(ctx context.Context, req *pusherpb.PushSettingsRequest) (*pusherpb.PushSettingsResponse, error)

Functions

func NewHTTPClient

func NewHTTPClient(baseurl string) pt.Pusher

Types

type PusherClient

type PusherClient struct {
	// contains filtered or unexported fields
}

func NewClient

func NewClient(txns pusherpb.PusherServiceInterface, settings pusherpb.SettingsPusherServiceInterface) *PusherClient

func NewDBPusher

func NewDBPusher(baseurl string) *PusherClient

func (*PusherClient) Push

func (c *PusherClient) Push(ctx context.Context, txns []pt.Txn) error

func (*PusherClient) PushSettings

func (c *PusherClient) PushSettings(ctx context.Context, sett *pt.Settings) error

type RoutedPusher

type RoutedPusher struct {
	// contains filtered or unexported fields
}

func NewRoutedPusher

func NewRoutedPusher(router pt.Router) *RoutedPusher

TODO(outself): add SetClient

func (*RoutedPusher) Push

func (r *RoutedPusher) Push(ctx context.Context, txns []pt.Txn) error

type Service

type Service struct {
	// contains filtered or unexported fields
}

func NewService

func NewService(pusher pt.Pusher) *Service

func (*Service) Push

func (s *Service) Push(ctx context.Context, req *pusherpb.PushRequest) (*pusherpb.PushResponse, error)

type SettingsService

type SettingsService struct {
	// contains filtered or unexported fields
}

func NewSettingsService

func NewSettingsService(pusher pt.SettingsPusher) *SettingsService

func (*SettingsService) PushSettings

func (s *SettingsService) PushSettings(ctx context.Context, req *pusherpb.PushSettingsRequest) (*pusherpb.PushSettingsResponse, error)