stream

Documentation

Index

• type TopologyStreamWriteConfig
• type TopologyStreamWriter
  • func (t *TopologyStreamWriter) Initialize(conf TopologyStreamWriteConfig)
  • func (t *TopologyStreamWriter) Push(_ context.Context, payload *stream.Payload) (*emptypb.Empty, error)
  • func (t *TopologyStreamWriter) SyncTopology(_ context.Context, _ *stream.Payload) (*emptypb.Empty, error)

Types

type TopologyStreamWriteConfig

type TopologyStreamWriteConfig struct {
	Logger *slog.Logger
	Nc     *nats.Conn
}

type TopologyStreamWriter

type TopologyStreamWriter struct {
	stream.UnsafeRemoteTopologyServer
	TopologyStreamWriteConfig

	util.Initializer
	// contains filtered or unexported fields
}

func (*TopologyStreamWriter) Initialize

func (t *TopologyStreamWriter) Initialize(conf TopologyStreamWriteConfig)

func (*TopologyStreamWriter) Push

func (t *TopologyStreamWriter) Push(_ context.Context, payload *stream.Payload) (*emptypb.Empty, error)

func (*TopologyStreamWriter) SyncTopology

func (t *TopologyStreamWriter) SyncTopology(_ context.Context, _ *stream.Payload) (*emptypb.Empty, error)