util

Documentation

Index

• func Couple(in types.Producer, out types.Consumer) error
• type ClosablePool
  • func NewClosablePool() *ClosablePool
  • func (c *ClosablePool) Add(tier int, closable types.Closable)
  • func (c *ClosablePool) Close(timeout time.Duration) error
• type MockInputType
  • func (m MockInputType) CloseAsync()
  • func (m *MockInputType) MessageChan() <-chan types.Message
  • func (m *MockInputType) StartListening(resChan <-chan types.Response) error
  • func (m MockInputType) WaitForClose(time.Duration) error
• type MockOutputType
  • func (m MockOutputType) CloseAsync()
  • func (m *MockOutputType) ResponseChan() <-chan types.Response
  • func (m *MockOutputType) StartReceiving(msgs <-chan types.Message) error
  • func (m MockOutputType) WaitForClose(time.Duration) error

Functions

func Couple

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

Couple connects 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 creates 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 attempts 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

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

MockInputType implements the input.Type interface.

func (MockInputType) CloseAsync

func (m MockInputType) CloseAsync()

CloseAsync does nothing.

func (*MockInputType) MessageChan

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

MessageChan returns the messages channel.

func (*MockInputType) StartListening

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

StartListening sets the channel used for reading responses.

func (MockInputType) WaitForClose

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

WaitForClose does nothing.

type MockOutputType

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

MockOutputType implements the output.Type interface.

func (MockOutputType) CloseAsync

func (m MockOutputType) CloseAsync()

CloseAsync does nothing.

func (*MockOutputType) ResponseChan

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

ResponseChan returns the errors channel.

func (*MockOutputType) StartReceiving

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

StartReceiving sets the read channel. This implementation is NOT thread safe.

func (MockOutputType) WaitForClose

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

WaitForClose does nothing.