push

package

v1.0.6-1 Latest Latest Go to latest Published: Jan 13, 2020 License: Apache-2.0 Imports: 11 Imported by: 1

Details

Valid go.mod file

The Go module system was introduced in Go 1.11 and is the official dependency management solution for Go.
Redistributable license

Redistributable licenses place minimal restrictions on how software can be used, modified, and redistributed.
Tagged version

Modules with tagged versions give importers more predictable builds.
Stable version

When a project reaches major version v1 it is considered stable.
Learn more about best practices

Repository

github.com/ARGOeu/argo-messaging

Documentation ¶

Index ¶

func LinearActivity(p *Pusher, brk brokers.Broker, store stores.Store) error
type HTTPSender
- func NewHTTPSender(timeoutSec int) *HTTPSender
- func (hs *HTTPSender) Send(msg string, endpoint string) error
type Manager
- func NewManager(brk brokers.Broker, str stores.Store, sndr Sender) *Manager
type MockSender
- func NewMockSender(fail bool) *MockSender
- func (ms *MockSender) Send(msg string, endpoint string) error
type Pusher
type Sender

Constants ¶

This section is empty.

Variables ¶

This section is empty.

Functions ¶

func LinearActivity ¶

func LinearActivity(p *Pusher, brk brokers.Broker, store stores.Store) error

LinearActivity implements a linear retry push

Types ¶

type HTTPSender ¶

type HTTPSender struct {
	Client http.Client
}

HTTPSender sends msgs through http

func NewHTTPSender ¶

func NewHTTPSender(timeoutSec int) *HTTPSender

NewHTTPSender creates a new HTTPSender. Specify timeout in seconds

func (*HTTPSender) Send ¶

func (hs *HTTPSender) Send(msg string, endpoint string) error

Send sends a message through HTTP

type Manager ¶

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

Manager manages all pusher routines

func NewManager ¶

func NewManager(brk brokers.Broker, str stores.Store, sndr Sender) *Manager

NewManager creates a new manager object for managing push routines

func (*Manager) Add ¶

func (mgr *Manager) Add(projectUUID string, subName string) error

Add a new push subscription

func (*Manager) Get ¶

func (mgr *Manager) Get(psub string) (*Pusher, error)

Get returns a pusher

func (*Manager) Launch ¶

func (mgr *Manager) Launch(project string, sub string) error

Launch Launches a new puhser

func (*Manager) LoadPushSubs ¶

func (mgr *Manager) LoadPushSubs()

LoadPushSubs is called during API initialization to retrieve available push configured subs and activate them

func (*Manager) PrintAll ¶

func (mgr *Manager) PrintAll()

PrintAll prints manager stats

func (*Manager) Refresh ¶

func (mgr *Manager) Refresh(projectUUID string, sub string) error

Refresh updates the subscription information from the database

func (*Manager) Remove ¶

func (mgr *Manager) Remove(project string, sub string) error

Remove a push subscription

func (*Manager) RemoveProjectAll ¶

func (mgr *Manager) RemoveProjectAll(projectUUID string) error

RemoveProjectAll stops and removes all pushers related to a project

func (*Manager) Restart ¶

func (mgr *Manager) Restart(project string, sub string) error

Restart a push subscription

func (*Manager) StartAll ¶

func (mgr *Manager) StartAll()

StartAll enables all pushsers

func (*Manager) Stop ¶

func (mgr *Manager) Stop(project string, sub string) error

Stop stops a push subscription

func (*Manager) StopAll ¶

func (mgr *Manager) StopAll() error

StopAll stops Activity on all pushers

type MockSender ¶

type MockSender struct {
	ClientFail   bool
	LastMsg      string
	LastEndpoint string
}

MockSender mocks sending messages to remote endpoints

func NewMockSender ¶

func NewMockSender(fail bool) *MockSender

NewMockSender creates a new Mock sender

func (*MockSender) Send ¶

func (ms *MockSender) Send(msg string, endpoint string) error

Send sends a message through HTTP

type Pusher ¶

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

Pusher holds information for the pusher routine and subscription

type Sender ¶

type Sender interface {
	Send(msg string, endpoint string) error
}

Sender is inteface for sending messages to remote endpoints

Source Files ¶

View all Source files

Directories ¶

Path	Synopsis
grpc
client
proto

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