channelmock

Documentation

Index

• func IsExists(name string) bool
• type FakeChannel
  • func NewFakeChannel(log log.T, mode channel.Mode, name string) *FakeChannel
  • func (f *FakeChannel) Close()
  • func (f *FakeChannel) Destroy()
  • func (f *FakeChannel) GetMessage() <-chan string
  • func (f *FakeChannel) Send(message string) error
• type MockedChannel
  • func (m *MockedChannel) Close()
  • func (m *MockedChannel) Destroy()
  • func (m *MockedChannel) GetMessage() <-chan string
  • func (m *MockedChannel) Send(msg string) error

Functions

func IsExists

func IsExists(name string) bool

Types

type FakeChannel

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

func NewFakeChannel

func NewFakeChannel(log log.T, mode channel.Mode, name string) *FakeChannel

func (*FakeChannel) Close

func (f *FakeChannel) Close()

close stops the receiving channel

func (*FakeChannel) Destroy

func (f *FakeChannel) Destroy()

func (*FakeChannel) GetMessage

func (f *FakeChannel) GetMessage() <-chan string

func (*FakeChannel) Send

func (f *FakeChannel) Send(message string) error

type MockedChannel

type MockedChannel struct {
	mock.Mock
}

func (*MockedChannel) Close

func (m *MockedChannel) Close()

func (*MockedChannel) Destroy

func (m *MockedChannel) Destroy()

func (*MockedChannel) GetMessage

func (m *MockedChannel) GetMessage() <-chan string

func (*MockedChannel) Send

func (m *MockedChannel) Send(msg string) error