message

package
v0.3.0 Latest Latest
Warning

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

 Go to latest Published: Apr 9, 2025 License: MIT Imports: 25 Imported by: 0

Documentation

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_api.UnimplementedReplicationApiServer
	// contains filtered or unexported fields
}

func NewReplicationApiService 

func NewReplicationApiService(
	ctx context.Context,
	log *zap.Logger,
	registrant *registrant.Registrant,
	store *sql.DB,
	validationService mlsvalidate.MLSValidationService,
	updater metadata.CursorUpdater,
	rateFetcher fees.IRatesFetcher,
	options config.ReplicationOptions,
) (*Service, error)

func (*Service) Close 

func (s *Service) Close()

func (*Service) GetInboxIds 

func (s *Service) GetInboxIds(
	ctx context.Context,
	req *message_api.GetInboxIdsRequest,
) (*message_api.GetInboxIdsResponse, error)

func (*Service) PublishPayerEnvelopes 

func (s *Service) PublishPayerEnvelopes(
	ctx context.Context,
	req *message_api.PublishPayerEnvelopesRequest,
) (*message_api.PublishPayerEnvelopesResponse, error)

func (*Service) QueryEnvelopes 

func (s *Service) QueryEnvelopes(
	ctx context.Context,
	req *message_api.QueryEnvelopesRequest,
) (*message_api.QueryEnvelopesResponse, error)

func (*Service) SubscribeEnvelopes 

func (s *Service) SubscribeEnvelopes(
	req *message_api.SubscribeEnvelopesRequest,
	stream message_api.ReplicationApi_SubscribeEnvelopesServer,
) error

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.