remotepusher

package
v0.1.0 Latest Latest
Warning

This package is not in the latest version of its module.

Go to latest
Published: Feb 28, 2019 License: GPL-3.0 Imports: 9 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func NewHTTPClient

func NewHTTPClient(baseurl string) pt.Pusher

Types

type PusherClient

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

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

type SettingsService

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

func NewSettingsService

func NewSettingsService(pusher pt.SettingsPusher) *SettingsService

func (*SettingsService) PushSettings

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL