message

package

v1.3.0 Latest Latest Go to latest Published: Mar 26, 2026 License: MIT Imports: 39 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/xmtp/xmtpd

Links

Open Source Insights

Documentation ¶

Overview ¶

Package message implements the replication API service.

Index ¶

Constants
type Service
- func NewReplicationAPIService(ctx context.Context, logger *zap.Logger, registrant *registrant.Registrant, ...) (*Service, error)
type ValidatedBytesWithTopic

Constants ¶

View Source

const (
	SubscribeWorkerPollTime = 100 * time.Millisecond
)

Variables ¶

This section is empty.

Functions ¶

This section is empty.

Types ¶

type Service ¶

type Service struct {
	message_apiconnect.UnimplementedReplicationApiHandler
	// contains filtered or unexported fields
}

func NewReplicationAPIService ¶ added in v0.5.1

func NewReplicationAPIService(
	ctx context.Context,
	logger *zap.Logger,
	registrant *registrant.Registrant,
	registry registry.NodeRegistry,
	db *db.Handler,
	validationService mlsvalidate.MLSValidationService,
	updater metadata.CursorUpdater,
	feeCalculator fees.IFeeCalculator,
	options config.APIOptions,
	migrationEnabled bool,
	sleepOnFailureTime time.Duration,
	originatorList db.OriginatorLister,
	ledger ledger.ILedger,
) (*Service, error)

func (*Service) Close ¶

func (s *Service) Close()

func (*Service) GetInboxIds ¶

func (s *Service) GetInboxIds(
	ctx context.Context,
	req *connect.Request[message_api.GetInboxIdsRequest],
) (*connect.Response[message_api.GetInboxIdsResponse], error)

func (*Service) GetNewestEnvelope ¶ added in v0.4.0

func (s *Service) GetNewestEnvelope(
	ctx context.Context,
	req *connect.Request[message_api.GetNewestEnvelopeRequest],
) (*connect.Response[message_api.GetNewestEnvelopeResponse], error)

func (*Service) PublishPayerEnvelopes ¶

func (s *Service) PublishPayerEnvelopes(
	ctx context.Context,
	req *connect.Request[message_api.PublishPayerEnvelopesRequest],
) (*connect.Response[message_api.PublishPayerEnvelopesResponse], error)

func (*Service) QueryEnvelopes ¶

func (s *Service) QueryEnvelopes(
	ctx context.Context,
	req *connect.Request[message_api.QueryEnvelopesRequest],
) (*connect.Response[message_api.QueryEnvelopesResponse], error)

func (*Service) SubscribeAllEnvelopes ¶ added in v1.3.0

func (s *Service) SubscribeAllEnvelopes(
	ctx context.Context,
	req *connect.Request[message_api.SubscribeAllEnvelopesRequest],
	stream *connect.ServerStream[message_api.SubscribeEnvelopesResponse],
) error

func (*Service) SubscribeEnvelopes ¶

func (s *Service) SubscribeEnvelopes(
	ctx context.Context,
	req *connect.Request[message_api.SubscribeEnvelopesRequest],
	stream *connect.ServerStream[message_api.SubscribeEnvelopesResponse],
) error

func (*Service) SubscribeTopics ¶ added in v1.2.0

func (s *Service) SubscribeTopics(
	ctx context.Context,
	req *connect.Request[message_api.SubscribeTopicsRequest],
	stream *connect.ServerStream[message_api.SubscribeTopicsResponse],
) error

SubscribeTopics implements the per-topic cursor subscribe API.

type ValidatedBytesWithTopic ¶ added in v1.0.0

type ValidatedBytesWithTopic struct {
	EnvelopeBytes []byte
	TopicBytes    []byte
	RetentionDays uint32
	PayerAddress  common.Address
	BaseFee       currency.PicoDollar
	CongestionFee currency.PicoDollar
}

Source Files ¶

View all Source files

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