communication

package

v1.2.0 Latest Latest Go to latest Published: Jul 14, 2025 License: Apache-2.0 Imports: 11 Imported by: 0

Details

This section is empty.

View Source

var Module = types.Module{
	{CreateFunc: NewCommunication},
	{CreateFunc: Adapter},
	{CreateFunc: NewParams},
	{CreateFunc: model.NewConfig},
}

This section is empty.

type AdapterIn struct {
	dig.In

	Connections   *conns.Conns
	ServersHelper *grpc.ServersHelper
}

type AdapterOut struct {
	dig.Out

	Service types.Runnable `group:"services"`
}

func Adapter(c Communicator) AdapterOut

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

func (c *Communication) SendMessage(typeMessage string, payload []byte) error

func (c *Communication) SetHandlers(hs map[string]model.HandlerFunc) error

func (c *Communication) Start(ctx context.Context) error

func (c *Communication) Stop(ctx context.Context) error

type CommunicationMock struct{}

func NewCommunicationMock() *CommunicationMock

func (*CommunicationMock) SendMessage(_ string, _ []byte) error

func (*CommunicationMock) SetHandlers(_ map[string]model.HandlerFunc) error

func (*CommunicationMock) Start(_ context.Context) error

func (*CommunicationMock) Stop(_ context.Context) error

type Communicator interface {
	SetHandlers(hs map[string]model.HandlerFunc) error
	Transport
}

func NewCommunication(
	cfg *model.Config,
	logger *zap.Logger,
	params *Params,
) (Communicator, error)

type Params struct {
	Connections   *conns.Conns
	ServersHelper *grpc.ServersHelper
}

func NewParams(in AdapterIn) *Params

type Transport interface {
	SendMessage(typeMessage string, payload []byte) error
	types.Runnable
}

type TransportType string