util

package
v0.2.6 Latest Latest
Warning

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

Go to latest
Published: Sep 22, 2017 License: MIT Imports: 3 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

func Couple

func Couple(in types.Producer, out types.Consumer) error

Couple - Connect a producer to a consumer.

Types

type ClosablePool

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

ClosablePool - Keeps a reference to a pool of closable types and closes them in tiers.

func NewClosablePool

func NewClosablePool() *ClosablePool

NewClosablePool - Create a fresh pool of closable types.

func (*ClosablePool) Add

func (c *ClosablePool) Add(tier int, closable types.Closable)

Add - Adds a closable type to the pool, tiers are used to partition and order the closing of types (starting at the lowest tier and working upwards). Closable types in a single tier are closed in the order that they are added.

func (*ClosablePool) Close

func (c *ClosablePool) Close(timeout time.Duration) error

Close - Attempt to close and clean up all stored closables in the determined order. If the timeout is met whilst working through the pool there is no indication of how far the pool has been progressed, thus this timeout should only be used for preventing severe blocking of a service.

type MockInputType added in v0.1.1

type MockInputType struct {
	MsgChan chan types.Message
	ResChan <-chan types.Response
}

MockInputType - Implements the input.Type interface.

func (MockInputType) CloseAsync added in v0.1.1

func (m MockInputType) CloseAsync()

CloseAsync - Does nothing.

func (*MockInputType) MessageChan added in v0.1.1

func (m *MockInputType) MessageChan() <-chan types.Message

MessageChan - Returns the messages channel.

func (*MockInputType) StartListening added in v0.1.1

func (m *MockInputType) StartListening(resChan <-chan types.Response) error

StartListening - Sets the channel used for reading responses.

func (MockInputType) WaitForClose added in v0.1.1

func (m MockInputType) WaitForClose(time.Duration) error

WaitForClose - Does nothing.

type MockOutputType added in v0.1.1

type MockOutputType struct {
	ResChan chan types.Response
	MsgChan <-chan types.Message
}

MockOutputType - Implements the output.Type interface.

func (MockOutputType) CloseAsync added in v0.1.1

func (m MockOutputType) CloseAsync()

CloseAsync - Does nothing.

func (*MockOutputType) ResponseChan added in v0.1.1

func (m *MockOutputType) ResponseChan() <-chan types.Response

ResponseChan - Returns the errors channel.

func (*MockOutputType) StartReceiving added in v0.1.1

func (m *MockOutputType) StartReceiving(msgs <-chan types.Message) error

StartReceiving - Sets the read channel. This implementation is NOT thread safe.

func (MockOutputType) WaitForClose added in v0.1.1

func (m MockOutputType) WaitForClose(time.Duration) error

WaitForClose - Does nothing.

Directories

Path Synopsis
Package disk - Cross platform disk statistics.
Package disk - Cross platform disk statistics.
Package test - Helpers for setting up test utilties.
Package test - Helpers for setting up test utilties.

Jump to

Keyboard shortcuts

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