message

Documentation

Index

• Constants
• type Service
  • func NewReplicationApiService(ctx context.Context, log *zap.Logger, registrant *registrant.Registrant, ...) (*Service, error)
  • func (s *Service) Close()
  • func (s *Service) GetInboxIds(ctx context.Context, req *message_api.GetInboxIdsRequest) (*message_api.GetInboxIdsResponse, error)
  • func (s *Service) PublishPayerEnvelopes(ctx context.Context, req *message_api.PublishPayerEnvelopesRequest) (*message_api.PublishPayerEnvelopesResponse, error)
  • func (s *Service) QueryEnvelopes(ctx context.Context, req *message_api.QueryEnvelopesRequest) (*message_api.QueryEnvelopesResponse, error)
  • func (s *Service) SubscribeEnvelopes(req *message_api.SubscribeEnvelopesRequest, ...) error

Constants

const (
	SubscribeWorkerPollTime = 100 * time.Millisecond
)

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,

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