Help us shape the future of Go! Take the 2026 Go Developer Survey

broadcasting

package
v1.20.0-alpha.1 Latest Latest
Warning

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

Go to latest
Published: Oct 29, 2026 License: MIT Imports: 4 Imported by: 0

Documentation

Index

Constants

This section is empty.

Variables

This section is empty.

Functions

This section is empty.

Types

type Broadcast

type Broadcast struct {
	mock.Mock
}

Broadcast is an autogenerated mock type for the Broadcast type

func NewBroadcast

func NewBroadcast(t interface {
	mock.TestingT
	Cleanup(func())
}) *Broadcast

NewBroadcast creates a new instance of Broadcast. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Broadcast) Channel

func (_m *Broadcast) Channel(pattern string, callback broadcasting.ChannelAuthFunc)

Channel provides a mock function with given fields: pattern, callback

func (*Broadcast) Dispatch

func (_m *Broadcast) Dispatch(ctx context.Context, event broadcasting.ShouldBroadcast) error

Dispatch provides a mock function with given fields: ctx, event

func (*Broadcast) EXPECT

func (_m *Broadcast) EXPECT() *Broadcast_Expecter

type Broadcast_Channel_Call

type Broadcast_Channel_Call struct {
	*mock.Call
}

Broadcast_Channel_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Channel'

func (*Broadcast_Channel_Call) Return

func (*Broadcast_Channel_Call) Run

func (*Broadcast_Channel_Call) RunAndReturn

type Broadcast_Dispatch_Call

type Broadcast_Dispatch_Call struct {
	*mock.Call
}

Broadcast_Dispatch_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Dispatch'

func (*Broadcast_Dispatch_Call) Return

func (*Broadcast_Dispatch_Call) Run

func (*Broadcast_Dispatch_Call) RunAndReturn

type Broadcast_Expecter

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

func (*Broadcast_Expecter) Channel

func (_e *Broadcast_Expecter) Channel(pattern interface{}, callback interface{}) *Broadcast_Channel_Call

Channel is a helper method to define mock.On call

  • pattern string
  • callback broadcasting.ChannelAuthFunc

func (*Broadcast_Expecter) Dispatch

func (_e *Broadcast_Expecter) Dispatch(ctx interface{}, event interface{}) *Broadcast_Dispatch_Call

Dispatch is a helper method to define mock.On call

  • ctx context.Context
  • event broadcasting.ShouldBroadcast

type ChannelAuthFunc

type ChannelAuthFunc struct {
	mock.Mock
}

ChannelAuthFunc is an autogenerated mock type for the ChannelAuthFunc type

func NewChannelAuthFunc

func NewChannelAuthFunc(t interface {
	mock.TestingT
	Cleanup(func())
}) *ChannelAuthFunc

NewChannelAuthFunc creates a new instance of ChannelAuthFunc. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ChannelAuthFunc) EXPECT

func (*ChannelAuthFunc) Execute

func (_m *ChannelAuthFunc) Execute(ctx context.Context, userID interface{}, channelName string, params map[string]string) (bool, interface{})

Execute provides a mock function with given fields: ctx, userID, channelName, params

type ChannelAuthFunc_Execute_Call

type ChannelAuthFunc_Execute_Call struct {
	*mock.Call
}

ChannelAuthFunc_Execute_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Execute'

func (*ChannelAuthFunc_Execute_Call) Return

func (_c *ChannelAuthFunc_Execute_Call) Return(_a0 bool, _a1 interface{}) *ChannelAuthFunc_Execute_Call

func (*ChannelAuthFunc_Execute_Call) Run

func (_c *ChannelAuthFunc_Execute_Call) Run(run func(ctx context.Context, userID interface{}, channelName string, params map[string]string)) *ChannelAuthFunc_Execute_Call

func (*ChannelAuthFunc_Execute_Call) RunAndReturn

func (_c *ChannelAuthFunc_Execute_Call) RunAndReturn(run func(context.Context, interface{}, string, map[string]string) (bool, interface{})) *ChannelAuthFunc_Execute_Call

type ChannelAuthFunc_Expecter

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

func (*ChannelAuthFunc_Expecter) Execute

func (_e *ChannelAuthFunc_Expecter) Execute(ctx interface{}, userID interface{}, channelName interface{}, params interface{}) *ChannelAuthFunc_Execute_Call

Execute is a helper method to define mock.On call

  • ctx context.Context
  • userID interface{}
  • channelName string
  • params map[string]string

type Driver

type Driver struct {
	mock.Mock
}

Driver is an autogenerated mock type for the Driver type

func NewDriver

func NewDriver(t interface {
	mock.TestingT
	Cleanup(func())
}) *Driver

NewDriver creates a new instance of Driver. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*Driver) Broadcast

func (_m *Driver) Broadcast(ctx context.Context, channels []string, event string, payload map[string]interface{}) error

Broadcast provides a mock function with given fields: ctx, channels, event, payload

func (*Driver) EXPECT

func (_m *Driver) EXPECT() *Driver_Expecter

type Driver_Broadcast_Call

type Driver_Broadcast_Call struct {
	*mock.Call
}

Driver_Broadcast_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'Broadcast'

func (*Driver_Broadcast_Call) Return

func (*Driver_Broadcast_Call) Run

func (_c *Driver_Broadcast_Call) Run(run func(ctx context.Context, channels []string, event string, payload map[string]interface{})) *Driver_Broadcast_Call

func (*Driver_Broadcast_Call) RunAndReturn

func (_c *Driver_Broadcast_Call) RunAndReturn(run func(context.Context, []string, string, map[string]interface{}) error) *Driver_Broadcast_Call

type Driver_Expecter

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

func (*Driver_Expecter) Broadcast

func (_e *Driver_Expecter) Broadcast(ctx interface{}, channels interface{}, event interface{}, payload interface{}) *Driver_Broadcast_Call

Broadcast is a helper method to define mock.On call

  • ctx context.Context
  • channels []string
  • event string
  • payload map[string]interface{}

type ShouldBroadcast

type ShouldBroadcast struct {
	mock.Mock
}

ShouldBroadcast is an autogenerated mock type for the ShouldBroadcast type

func NewShouldBroadcast

func NewShouldBroadcast(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShouldBroadcast

NewShouldBroadcast creates a new instance of ShouldBroadcast. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShouldBroadcast) BroadcastAs

func (_m *ShouldBroadcast) BroadcastAs() string

BroadcastAs provides a mock function with no fields

func (*ShouldBroadcast) BroadcastOn

func (_m *ShouldBroadcast) BroadcastOn() []string

BroadcastOn provides a mock function with no fields

func (*ShouldBroadcast) BroadcastWhen

func (_m *ShouldBroadcast) BroadcastWhen() bool

BroadcastWhen provides a mock function with no fields

func (*ShouldBroadcast) BroadcastWith

func (_m *ShouldBroadcast) BroadcastWith() map[string]interface{}

BroadcastWith provides a mock function with no fields

func (*ShouldBroadcast) EXPECT

type ShouldBroadcastNow

type ShouldBroadcastNow struct {
	mock.Mock
}

ShouldBroadcastNow is an autogenerated mock type for the ShouldBroadcastNow type

func NewShouldBroadcastNow

func NewShouldBroadcastNow(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShouldBroadcastNow

NewShouldBroadcastNow creates a new instance of ShouldBroadcastNow. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShouldBroadcastNow) BroadcastNow

func (_m *ShouldBroadcastNow) BroadcastNow() bool

BroadcastNow provides a mock function with no fields

func (*ShouldBroadcastNow) EXPECT

type ShouldBroadcastNow_BroadcastNow_Call

type ShouldBroadcastNow_BroadcastNow_Call struct {
	*mock.Call
}

ShouldBroadcastNow_BroadcastNow_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastNow'

func (*ShouldBroadcastNow_BroadcastNow_Call) Return

func (*ShouldBroadcastNow_BroadcastNow_Call) Run

func (*ShouldBroadcastNow_BroadcastNow_Call) RunAndReturn

type ShouldBroadcastNow_Expecter

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

func (*ShouldBroadcastNow_Expecter) BroadcastNow

BroadcastNow is a helper method to define mock.On call

type ShouldBroadcastWithBackoff

type ShouldBroadcastWithBackoff struct {
	mock.Mock
}

ShouldBroadcastWithBackoff is an autogenerated mock type for the ShouldBroadcastWithBackoff type

func NewShouldBroadcastWithBackoff

func NewShouldBroadcastWithBackoff(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShouldBroadcastWithBackoff

NewShouldBroadcastWithBackoff creates a new instance of ShouldBroadcastWithBackoff. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShouldBroadcastWithBackoff) BroadcastBackoff

func (_m *ShouldBroadcastWithBackoff) BroadcastBackoff() []time.Duration

BroadcastBackoff provides a mock function with no fields

func (*ShouldBroadcastWithBackoff) EXPECT

type ShouldBroadcastWithBackoff_BroadcastBackoff_Call

type ShouldBroadcastWithBackoff_BroadcastBackoff_Call struct {
	*mock.Call
}

ShouldBroadcastWithBackoff_BroadcastBackoff_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastBackoff'

func (*ShouldBroadcastWithBackoff_BroadcastBackoff_Call) Return

func (*ShouldBroadcastWithBackoff_BroadcastBackoff_Call) Run

func (*ShouldBroadcastWithBackoff_BroadcastBackoff_Call) RunAndReturn

type ShouldBroadcastWithBackoff_Expecter

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

func (*ShouldBroadcastWithBackoff_Expecter) BroadcastBackoff

BroadcastBackoff is a helper method to define mock.On call

type ShouldBroadcastWithConnections

type ShouldBroadcastWithConnections struct {
	mock.Mock
}

ShouldBroadcastWithConnections is an autogenerated mock type for the ShouldBroadcastWithConnections type

func NewShouldBroadcastWithConnections

func NewShouldBroadcastWithConnections(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShouldBroadcastWithConnections

NewShouldBroadcastWithConnections creates a new instance of ShouldBroadcastWithConnections. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShouldBroadcastWithConnections) BroadcastConnections

func (_m *ShouldBroadcastWithConnections) BroadcastConnections() []string

BroadcastConnections provides a mock function with no fields

func (*ShouldBroadcastWithConnections) EXPECT

type ShouldBroadcastWithConnections_BroadcastConnections_Call

type ShouldBroadcastWithConnections_BroadcastConnections_Call struct {
	*mock.Call
}

ShouldBroadcastWithConnections_BroadcastConnections_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastConnections'

func (*ShouldBroadcastWithConnections_BroadcastConnections_Call) Return

func (*ShouldBroadcastWithConnections_BroadcastConnections_Call) Run

func (*ShouldBroadcastWithConnections_BroadcastConnections_Call) RunAndReturn

type ShouldBroadcastWithConnections_Expecter

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

func (*ShouldBroadcastWithConnections_Expecter) BroadcastConnections

BroadcastConnections is a helper method to define mock.On call

type ShouldBroadcastWithDelay

type ShouldBroadcastWithDelay struct {
	mock.Mock
}

ShouldBroadcastWithDelay is an autogenerated mock type for the ShouldBroadcastWithDelay type

func NewShouldBroadcastWithDelay

func NewShouldBroadcastWithDelay(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShouldBroadcastWithDelay

NewShouldBroadcastWithDelay creates a new instance of ShouldBroadcastWithDelay. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShouldBroadcastWithDelay) BroadcastDelay

func (_m *ShouldBroadcastWithDelay) BroadcastDelay() time.Time

BroadcastDelay provides a mock function with no fields

func (*ShouldBroadcastWithDelay) EXPECT

type ShouldBroadcastWithDelay_BroadcastDelay_Call

type ShouldBroadcastWithDelay_BroadcastDelay_Call struct {
	*mock.Call
}

ShouldBroadcastWithDelay_BroadcastDelay_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastDelay'

func (*ShouldBroadcastWithDelay_BroadcastDelay_Call) Return

func (*ShouldBroadcastWithDelay_BroadcastDelay_Call) Run

func (*ShouldBroadcastWithDelay_BroadcastDelay_Call) RunAndReturn

type ShouldBroadcastWithDelay_Expecter

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

func (*ShouldBroadcastWithDelay_Expecter) BroadcastDelay

BroadcastDelay is a helper method to define mock.On call

type ShouldBroadcastWithQueue

type ShouldBroadcastWithQueue struct {
	mock.Mock
}

ShouldBroadcastWithQueue is an autogenerated mock type for the ShouldBroadcastWithQueue type

func NewShouldBroadcastWithQueue

func NewShouldBroadcastWithQueue(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShouldBroadcastWithQueue

NewShouldBroadcastWithQueue creates a new instance of ShouldBroadcastWithQueue. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShouldBroadcastWithQueue) BroadcastQueue

func (_m *ShouldBroadcastWithQueue) BroadcastQueue() string

BroadcastQueue provides a mock function with no fields

func (*ShouldBroadcastWithQueue) EXPECT

type ShouldBroadcastWithQueueConnection

type ShouldBroadcastWithQueueConnection struct {
	mock.Mock
}

ShouldBroadcastWithQueueConnection is an autogenerated mock type for the ShouldBroadcastWithQueueConnection type

func NewShouldBroadcastWithQueueConnection

func NewShouldBroadcastWithQueueConnection(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShouldBroadcastWithQueueConnection

NewShouldBroadcastWithQueueConnection creates a new instance of ShouldBroadcastWithQueueConnection. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShouldBroadcastWithQueueConnection) BroadcastQueueConnection

func (_m *ShouldBroadcastWithQueueConnection) BroadcastQueueConnection() string

BroadcastQueueConnection provides a mock function with no fields

func (*ShouldBroadcastWithQueueConnection) EXPECT

type ShouldBroadcastWithQueueConnection_BroadcastQueueConnection_Call

type ShouldBroadcastWithQueueConnection_BroadcastQueueConnection_Call struct {
	*mock.Call
}

ShouldBroadcastWithQueueConnection_BroadcastQueueConnection_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastQueueConnection'

func (*ShouldBroadcastWithQueueConnection_BroadcastQueueConnection_Call) Return

func (*ShouldBroadcastWithQueueConnection_BroadcastQueueConnection_Call) Run

func (*ShouldBroadcastWithQueueConnection_BroadcastQueueConnection_Call) RunAndReturn

type ShouldBroadcastWithQueueConnection_Expecter

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

func (*ShouldBroadcastWithQueueConnection_Expecter) BroadcastQueueConnection

BroadcastQueueConnection is a helper method to define mock.On call

type ShouldBroadcastWithQueue_BroadcastQueue_Call

type ShouldBroadcastWithQueue_BroadcastQueue_Call struct {
	*mock.Call
}

ShouldBroadcastWithQueue_BroadcastQueue_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastQueue'

func (*ShouldBroadcastWithQueue_BroadcastQueue_Call) Return

func (*ShouldBroadcastWithQueue_BroadcastQueue_Call) Run

func (*ShouldBroadcastWithQueue_BroadcastQueue_Call) RunAndReturn

type ShouldBroadcastWithQueue_Expecter

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

func (*ShouldBroadcastWithQueue_Expecter) BroadcastQueue

BroadcastQueue is a helper method to define mock.On call

type ShouldBroadcastWithTimeout

type ShouldBroadcastWithTimeout struct {
	mock.Mock
}

ShouldBroadcastWithTimeout is an autogenerated mock type for the ShouldBroadcastWithTimeout type

func NewShouldBroadcastWithTimeout

func NewShouldBroadcastWithTimeout(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShouldBroadcastWithTimeout

NewShouldBroadcastWithTimeout creates a new instance of ShouldBroadcastWithTimeout. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShouldBroadcastWithTimeout) BroadcastTimeout

func (_m *ShouldBroadcastWithTimeout) BroadcastTimeout() time.Duration

BroadcastTimeout provides a mock function with no fields

func (*ShouldBroadcastWithTimeout) EXPECT

type ShouldBroadcastWithTimeout_BroadcastTimeout_Call

type ShouldBroadcastWithTimeout_BroadcastTimeout_Call struct {
	*mock.Call
}

ShouldBroadcastWithTimeout_BroadcastTimeout_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastTimeout'

func (*ShouldBroadcastWithTimeout_BroadcastTimeout_Call) Return

func (*ShouldBroadcastWithTimeout_BroadcastTimeout_Call) Run

func (*ShouldBroadcastWithTimeout_BroadcastTimeout_Call) RunAndReturn

type ShouldBroadcastWithTimeout_Expecter

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

func (*ShouldBroadcastWithTimeout_Expecter) BroadcastTimeout

BroadcastTimeout is a helper method to define mock.On call

type ShouldBroadcastWithTries

type ShouldBroadcastWithTries struct {
	mock.Mock
}

ShouldBroadcastWithTries is an autogenerated mock type for the ShouldBroadcastWithTries type

func NewShouldBroadcastWithTries

func NewShouldBroadcastWithTries(t interface {
	mock.TestingT
	Cleanup(func())
}) *ShouldBroadcastWithTries

NewShouldBroadcastWithTries creates a new instance of ShouldBroadcastWithTries. It also registers a testing interface on the mock and a cleanup function to assert the mocks expectations. The first argument is typically a *testing.T value.

func (*ShouldBroadcastWithTries) BroadcastTries

func (_m *ShouldBroadcastWithTries) BroadcastTries() int

BroadcastTries provides a mock function with no fields

func (*ShouldBroadcastWithTries) EXPECT

type ShouldBroadcastWithTries_BroadcastTries_Call

type ShouldBroadcastWithTries_BroadcastTries_Call struct {
	*mock.Call
}

ShouldBroadcastWithTries_BroadcastTries_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastTries'

func (*ShouldBroadcastWithTries_BroadcastTries_Call) Return

func (*ShouldBroadcastWithTries_BroadcastTries_Call) Run

func (*ShouldBroadcastWithTries_BroadcastTries_Call) RunAndReturn

type ShouldBroadcastWithTries_Expecter

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

func (*ShouldBroadcastWithTries_Expecter) BroadcastTries

BroadcastTries is a helper method to define mock.On call

type ShouldBroadcast_BroadcastAs_Call

type ShouldBroadcast_BroadcastAs_Call struct {
	*mock.Call
}

ShouldBroadcast_BroadcastAs_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastAs'

func (*ShouldBroadcast_BroadcastAs_Call) Return

func (*ShouldBroadcast_BroadcastAs_Call) Run

func (*ShouldBroadcast_BroadcastAs_Call) RunAndReturn

type ShouldBroadcast_BroadcastOn_Call

type ShouldBroadcast_BroadcastOn_Call struct {
	*mock.Call
}

ShouldBroadcast_BroadcastOn_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastOn'

func (*ShouldBroadcast_BroadcastOn_Call) Return

func (*ShouldBroadcast_BroadcastOn_Call) Run

func (*ShouldBroadcast_BroadcastOn_Call) RunAndReturn

type ShouldBroadcast_BroadcastWhen_Call

type ShouldBroadcast_BroadcastWhen_Call struct {
	*mock.Call
}

ShouldBroadcast_BroadcastWhen_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastWhen'

func (*ShouldBroadcast_BroadcastWhen_Call) Return

func (*ShouldBroadcast_BroadcastWhen_Call) Run

func (*ShouldBroadcast_BroadcastWhen_Call) RunAndReturn

type ShouldBroadcast_BroadcastWith_Call

type ShouldBroadcast_BroadcastWith_Call struct {
	*mock.Call
}

ShouldBroadcast_BroadcastWith_Call is a *mock.Call that shadows Run/Return methods with type explicit version for method 'BroadcastWith'

func (*ShouldBroadcast_BroadcastWith_Call) Return

func (*ShouldBroadcast_BroadcastWith_Call) Run

func (*ShouldBroadcast_BroadcastWith_Call) RunAndReturn

func (_c *ShouldBroadcast_BroadcastWith_Call) RunAndReturn(run func() map[string]interface{}) *ShouldBroadcast_BroadcastWith_Call

type ShouldBroadcast_Expecter

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

func (*ShouldBroadcast_Expecter) BroadcastAs

BroadcastAs is a helper method to define mock.On call

func (*ShouldBroadcast_Expecter) BroadcastOn

BroadcastOn is a helper method to define mock.On call

func (*ShouldBroadcast_Expecter) BroadcastWhen

BroadcastWhen is a helper method to define mock.On call

func (*ShouldBroadcast_Expecter) BroadcastWith

BroadcastWith is a helper method to define mock.On call

Jump to

Keyboard shortcuts

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