message

package
v1.1.1 Latest Latest
Warning

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

 Go to latest Published: Feb 18, 2026 License: MIT Imports: 30 Imported by: 0

Documentation

Overview

Package message implements the replication API service.

Index

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,
) (*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) SubscribeEnvelopes 

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

type ValidatedBytesWithTopic added in v1.0.0 

type ValidatedBytesWithTopic struct {
	EnvelopeBytes []byte
	TopicBytes    []byte
	RetentionDays uint32
}

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.