Documentation
¶
Index ¶
- Variables
- func ExecuteSignalAccountKeys(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.AccountKeysOutput], error)
- func ExecuteSignalBackupAuthPrepare(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
- func ExecuteSignalBackupManifestVerify(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
- func ExecuteSignalBlobDecrypt(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.BlobDecryptOutput], error)
- func ExecuteSignalBlobEncrypt(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.BlobEncryptOutput], error)
- func ExecuteSignalCustodyAttest(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.CustodyAttestOutput], error)
- func ExecuteSignalCustodyCreate(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.CustodyCreateOutput], error)
- func ExecuteSignalCustodyExportRequest(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.CustodyExportRequestOutput], error)
- func ExecuteSignalCustodyInspect(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.CustodyInspectOutput], error)
- func ExecuteSignalCustodyRestore(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.CustodyRestoreOutput], error)
- func ExecuteSignalCustodyRevoke(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.CustodyRevokeOutput], error)
- func ExecuteSignalCustodyRotate(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.CustodyRotateOutput], error)
- func ExecuteSignalDecrypt(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.SignalDecryptOutput], error)
- func ExecuteSignalDeviceFanoutPrepare(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.DeviceFanoutPrepareOutput], error)
- func ExecuteSignalDeviceList(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.DeviceListOutput], error)
- func ExecuteSignalDevicePublish(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.DevicePublishOutput], error)
- func ExecuteSignalDeviceRevoke(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.DeviceRevokeOutput], error)
- func ExecuteSignalEncrypt(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.SignalEncryptOutput], error)
- func ExecuteSignalEnvelopePurge(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.EnvelopePurgeOutput], error)
- func ExecuteSignalEnvelopeStatus(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.EnvelopeStatusOutput], error)
- func ExecuteSignalFingerprint(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.SignalFingerprintOutput], error)
- func ExecuteSignalFingerprintAssert(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.SignalFingerprintAssertOutput], error)
- func ExecuteSignalInboxAck(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxAckOutput], error)
- func ExecuteSignalInboxAckBatch(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxAckBatchOutput], error)
- func ExecuteSignalInboxClaim(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxClaimOutput], error)
- func ExecuteSignalInboxClaimBatch(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxClaimBatchOutput], error)
- func ExecuteSignalInboxClaimNext(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxClaimNextOutput], error)
- func ExecuteSignalInboxDeadLetter(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxDeadLetterOutput], error)
- func ExecuteSignalInboxDeadLetterBatch(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxDeadLetterBatchOutput], error)
- func ExecuteSignalInboxDecrypt(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxDecryptOutput], error)
- func ExecuteSignalInboxReceive(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxReceiveOutput], error)
- func ExecuteSignalInboxReclaimStale(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxReclaimStaleOutput], error)
- func ExecuteSignalInboxRelease(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxReleaseOutput], error)
- func ExecuteSignalInboxReleaseBatch(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxReleaseBatchOutput], error)
- func ExecuteSignalInboxRequeue(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.InboxRequeueOutput], error)
- func ExecuteSignalOutboxAck(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxAckOutput], error)
- func ExecuteSignalOutboxAckBatch(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxAckBatchOutput], error)
- func ExecuteSignalOutboxClaim(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxClaimOutput], error)
- func ExecuteSignalOutboxClaimBatch(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxClaimBatchOutput], error)
- func ExecuteSignalOutboxClaimNext(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxClaimNextOutput], error)
- func ExecuteSignalOutboxDeadLetter(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxDeadLetterOutput], error)
- func ExecuteSignalOutboxEnqueue(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxEnqueueOutput], error)
- func ExecuteSignalOutboxEnqueueBatch(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxEnqueueBatchOutput], error)
- func ExecuteSignalOutboxHandoff(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxHandoffOutput], error)
- func ExecuteSignalOutboxHandoffBatch(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxHandoffBatchOutput], error)
- func ExecuteSignalOutboxRelease(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxReleaseOutput], error)
- func ExecuteSignalOutboxReleaseBatch(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxReleaseBatchOutput], error)
- func ExecuteSignalOutboxRequeue(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.OutboxRequeueOutput], error)
- func ExecuteSignalPublicPreKeyPublish(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.PublicPreKeyPublishOutput], error)
- func ExecuteSignalPublicPreKeyResolve(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.PublicPreKeyResolveOutput], error)
- func ExecuteSignalSenderCertificateIssue(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.SenderCertificateIssueOutput], error)
- func ExecuteSignalSenderSeal(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.SenderSealOutput], error)
- func ExecuteSignalSenderSealFanout(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.SenderSealFanoutOutput], error)
- func ExecuteSignalSenderUnseal(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.SenderUnsealOutput], error)
- func ExecuteSignalServiceApprovalValidate(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceApprovalValidateOutput], error)
- func ExecuteSignalServiceChallengeRespond(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
- func ExecuteSignalServiceComplianceCheck(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceComplianceCheckOutput], error)
- func ExecuteSignalServiceContractCheck(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceContractCheckOutput], error)
- func ExecuteSignalServiceLinkPrepare(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
- func ExecuteSignalServiceLiveSubmit(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceSubmitOutput], error)
- func ExecuteSignalServicePolicyCheck(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServicePolicyCheckOutput], error)
- func ExecuteSignalServiceReceiveAdmit(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
- func ExecuteSignalServiceRegisterPrepare(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
- func ExecuteSignalServiceSendPrepare(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
- func ExecuteSignalServiceTestBackupDownload(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
- func ExecuteSignalServiceTestBackupUpload(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
- func ExecuteSignalServiceTestLinkDevice(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
- func ExecuteSignalServiceTestReceive(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
- func ExecuteSignalServiceTestRegister(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
- func ExecuteSignalServiceTestSend(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
- func ExecuteSignalServiceTestUsernameReserve(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
- func ExecuteSignalSessionPrepare(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.SessionPrepareOutput], error)
- func ExecuteSignalTransportAdmit(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.TransportAdmitOutput], error)
- func ExecuteSignalTransportAdmitBatch(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.TransportAdmitBatchOutput], error)
- func ExecuteSignalTransportReceiptIssue(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.TransportReceiptIssueOutput], error)
- func ExecuteSignalTransportReceiptVerify(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.TransportReceiptVerifyOutput], error)
- func ExecuteSignalTransportReceiptVerifyBatch(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.TransportReceiptVerifyBatchOutput], error)
- func ExecuteSignalTrustHistory(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.SignalTrustHistoryOutput], error)
- func ExecuteSignalTrustObserve(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.SignalTrustObserveOutput], error)
- func ExecuteSignalTrustPolicyCheck(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.SignalTrustPolicyCheckOutput], error)
- func ExecuteSignalTrustPolicyCheckBatch(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.SignalTrustPolicyCheckBatchOutput], error)
- func ExecuteSignalTrustReset(ctx context.Context, ...) (*sdk.TypedStepResult[*contracts.SignalTrustResetOutput], error)
- func ExecuteSignalUsernameArtifactPrepare(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.UsernameArtifactPrepareOutput], error)
- func ExecuteSignalUsernameLinkCreate(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.UsernameLinkCreateOutput], error)
- func ExecuteSignalUsernameLinkDecrypt(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.UsernameLinkDecryptOutput], error)
- func ExecuteSignalUsernameProofPrepare(_ context.Context, ...) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
- type SignalProvider
- func (p *SignalProvider) ContractRegistry() *pb.ContractRegistry
- func (p *SignalProvider) CreateTypedModule(typeName, name string, config *anypb.Any) (sdk.ModuleInstance, error)
- func (p *SignalProvider) CreateTypedStep(typeName, name string, config *anypb.Any) (sdk.StepInstance, error)
- func (p *SignalProvider) Manifest() sdk.PluginManifest
- func (p *SignalProvider) TypedModuleTypes() []string
- func (p *SignalProvider) TypedStepTypes() []string
Constants ¶
This section is empty.
Variables ¶
var Version = "dev"
Version is injected by the release build so runtime manifests report the tag.
Functions ¶
func ExecuteSignalAccountKeys ¶ added in v0.3.0
func ExecuteSignalAccountKeys( _ context.Context, req sdk.TypedStepRequest[*contracts.AccountKeysConfig, *contracts.AccountKeysInput], ) (*sdk.TypedStepResult[*contracts.AccountKeysOutput], error)
ExecuteSignalAccountKeys derives Signal account keys from an entropy pool.
func ExecuteSignalBackupAuthPrepare ¶ added in v0.9.0
func ExecuteSignalBackupAuthPrepare( _ context.Context, req sdk.TypedStepRequest[*contracts.BackupAuthPrepareConfig, *contracts.BackupAuthPrepareInput], ) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
func ExecuteSignalBackupManifestVerify ¶ added in v0.9.0
func ExecuteSignalBackupManifestVerify( _ context.Context, req sdk.TypedStepRequest[*contracts.BackupManifestVerifyConfig, *contracts.BackupManifestVerifyInput], ) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
func ExecuteSignalBlobDecrypt ¶ added in v0.13.0
func ExecuteSignalBlobDecrypt( ctx context.Context, req sdk.TypedStepRequest[*contracts.BlobDecryptConfig, *contracts.BlobDecryptInput], ) (*sdk.TypedStepResult[*contracts.BlobDecryptOutput], error)
func ExecuteSignalBlobEncrypt ¶ added in v0.13.0
func ExecuteSignalBlobEncrypt( ctx context.Context, req sdk.TypedStepRequest[*contracts.BlobEncryptConfig, *contracts.BlobEncryptInput], ) (*sdk.TypedStepResult[*contracts.BlobEncryptOutput], error)
func ExecuteSignalCustodyAttest ¶ added in v0.12.0
func ExecuteSignalCustodyAttest( _ context.Context, req sdk.TypedStepRequest[*contracts.CustodyAttestConfig, *contracts.CustodyAttestInput], ) (*sdk.TypedStepResult[*contracts.CustodyAttestOutput], error)
func ExecuteSignalCustodyCreate ¶ added in v0.8.0
func ExecuteSignalCustodyCreate( _ context.Context, req sdk.TypedStepRequest[*contracts.CustodyCreateConfig, *contracts.CustodyCreateInput], ) (*sdk.TypedStepResult[*contracts.CustodyCreateOutput], error)
func ExecuteSignalCustodyExportRequest ¶ added in v0.12.0
func ExecuteSignalCustodyExportRequest( _ context.Context, req sdk.TypedStepRequest[*contracts.CustodyExportRequestConfig, *contracts.CustodyExportRequestInput], ) (*sdk.TypedStepResult[*contracts.CustodyExportRequestOutput], error)
func ExecuteSignalCustodyInspect ¶ added in v0.8.0
func ExecuteSignalCustodyInspect( _ context.Context, req sdk.TypedStepRequest[*contracts.CustodyInspectConfig, *contracts.CustodyInspectInput], ) (*sdk.TypedStepResult[*contracts.CustodyInspectOutput], error)
func ExecuteSignalCustodyRestore ¶ added in v0.8.0
func ExecuteSignalCustodyRestore( _ context.Context, req sdk.TypedStepRequest[*contracts.CustodyRestoreConfig, *contracts.CustodyRestoreInput], ) (*sdk.TypedStepResult[*contracts.CustodyRestoreOutput], error)
func ExecuteSignalCustodyRevoke ¶ added in v0.8.0
func ExecuteSignalCustodyRevoke( _ context.Context, req sdk.TypedStepRequest[*contracts.CustodyRevokeConfig, *contracts.CustodyRevokeInput], ) (*sdk.TypedStepResult[*contracts.CustodyRevokeOutput], error)
func ExecuteSignalCustodyRotate ¶ added in v0.8.0
func ExecuteSignalCustodyRotate( _ context.Context, req sdk.TypedStepRequest[*contracts.CustodyRotateConfig, *contracts.CustodyRotateInput], ) (*sdk.TypedStepResult[*contracts.CustodyRotateOutput], error)
func ExecuteSignalDecrypt ¶ added in v0.2.0
func ExecuteSignalDecrypt( ctx context.Context, req sdk.TypedStepRequest[*contracts.SignalDecryptConfig, *contracts.SignalDecryptInput], ) (*sdk.TypedStepResult[*contracts.SignalDecryptOutput], error)
func ExecuteSignalDeviceFanoutPrepare ¶ added in v0.36.0
func ExecuteSignalDeviceFanoutPrepare(_ context.Context, req sdk.TypedStepRequest[*contracts.DeviceFanoutPrepareConfig, *contracts.DeviceFanoutPrepareInput]) (*sdk.TypedStepResult[*contracts.DeviceFanoutPrepareOutput], error)
func ExecuteSignalDeviceList ¶ added in v0.36.0
func ExecuteSignalDeviceList(_ context.Context, req sdk.TypedStepRequest[*contracts.DeviceListConfig, *contracts.DeviceListInput]) (*sdk.TypedStepResult[*contracts.DeviceListOutput], error)
func ExecuteSignalDevicePublish ¶ added in v0.36.0
func ExecuteSignalDevicePublish(_ context.Context, req sdk.TypedStepRequest[*contracts.DevicePublishConfig, *contracts.DevicePublishInput]) (*sdk.TypedStepResult[*contracts.DevicePublishOutput], error)
func ExecuteSignalDeviceRevoke ¶ added in v0.36.0
func ExecuteSignalDeviceRevoke(_ context.Context, req sdk.TypedStepRequest[*contracts.DeviceRevokeConfig, *contracts.DeviceRevokeInput]) (*sdk.TypedStepResult[*contracts.DeviceRevokeOutput], error)
func ExecuteSignalEncrypt ¶ added in v0.2.0
func ExecuteSignalEncrypt( ctx context.Context, req sdk.TypedStepRequest[*contracts.SignalEncryptConfig, *contracts.SignalEncryptInput], ) (*sdk.TypedStepResult[*contracts.SignalEncryptOutput], error)
func ExecuteSignalEnvelopePurge ¶ added in v0.34.0
func ExecuteSignalEnvelopePurge( _ context.Context, req sdk.TypedStepRequest[*contracts.EnvelopePurgeConfig, *contracts.EnvelopePurgeInput], ) (*sdk.TypedStepResult[*contracts.EnvelopePurgeOutput], error)
func ExecuteSignalEnvelopeStatus ¶ added in v0.33.0
func ExecuteSignalEnvelopeStatus( _ context.Context, req sdk.TypedStepRequest[*contracts.EnvelopeStatusConfig, *contracts.EnvelopeStatusInput], ) (*sdk.TypedStepResult[*contracts.EnvelopeStatusOutput], error)
func ExecuteSignalFingerprint ¶
func ExecuteSignalFingerprint( ctx context.Context, req sdk.TypedStepRequest[*contracts.SignalFingerprintConfig, *contracts.SignalFingerprintInput], ) (*sdk.TypedStepResult[*contracts.SignalFingerprintOutput], error)
ExecuteSignalFingerprint computes a Signal safety number and scannable fingerprint from serialized identity public keys.
func ExecuteSignalFingerprintAssert ¶ added in v0.21.0
func ExecuteSignalFingerprintAssert( ctx context.Context, req sdk.TypedStepRequest[*contracts.SignalFingerprintAssertConfig, *contracts.SignalFingerprintAssertInput], ) (*sdk.TypedStepResult[*contracts.SignalFingerprintAssertOutput], error)
ExecuteSignalFingerprintAssert computes a Signal fingerprint and fails closed unless the caller-provided expected safety-number evidence matches.
func ExecuteSignalInboxAck ¶ added in v0.35.0
func ExecuteSignalInboxAck( _ context.Context, req sdk.TypedStepRequest[*contracts.InboxAckConfig, *contracts.InboxAckInput], ) (*sdk.TypedStepResult[*contracts.InboxAckOutput], error)
func ExecuteSignalInboxAckBatch ¶ added in v0.36.0
func ExecuteSignalInboxAckBatch(ctx context.Context, req sdk.TypedStepRequest[*contracts.InboxAckBatchConfig, *contracts.InboxAckBatchInput]) (*sdk.TypedStepResult[*contracts.InboxAckBatchOutput], error)
func ExecuteSignalInboxClaim ¶ added in v0.35.0
func ExecuteSignalInboxClaim( _ context.Context, req sdk.TypedStepRequest[*contracts.InboxClaimConfig, *contracts.InboxClaimInput], ) (*sdk.TypedStepResult[*contracts.InboxClaimOutput], error)
func ExecuteSignalInboxClaimBatch ¶ added in v0.36.0
func ExecuteSignalInboxClaimBatch( _ context.Context, req sdk.TypedStepRequest[*contracts.InboxClaimBatchConfig, *contracts.InboxClaimBatchInput], ) (*sdk.TypedStepResult[*contracts.InboxClaimBatchOutput], error)
func ExecuteSignalInboxClaimNext ¶ added in v0.36.0
func ExecuteSignalInboxClaimNext( _ context.Context, req sdk.TypedStepRequest[*contracts.InboxClaimNextConfig, *contracts.InboxClaimNextInput], ) (*sdk.TypedStepResult[*contracts.InboxClaimNextOutput], error)
func ExecuteSignalInboxDeadLetter ¶ added in v0.35.0
func ExecuteSignalInboxDeadLetter( _ context.Context, req sdk.TypedStepRequest[*contracts.InboxDeadLetterConfig, *contracts.InboxDeadLetterInput], ) (*sdk.TypedStepResult[*contracts.InboxDeadLetterOutput], error)
func ExecuteSignalInboxDeadLetterBatch ¶ added in v0.36.0
func ExecuteSignalInboxDeadLetterBatch(ctx context.Context, req sdk.TypedStepRequest[*contracts.InboxDeadLetterBatchConfig, *contracts.InboxDeadLetterBatchInput]) (*sdk.TypedStepResult[*contracts.InboxDeadLetterBatchOutput], error)
func ExecuteSignalInboxDecrypt ¶ added in v0.12.0
func ExecuteSignalInboxDecrypt( ctx context.Context, req sdk.TypedStepRequest[*contracts.InboxDecryptConfig, *contracts.InboxDecryptInput], ) (*sdk.TypedStepResult[*contracts.InboxDecryptOutput], error)
func ExecuteSignalInboxReceive ¶ added in v0.12.0
func ExecuteSignalInboxReceive( _ context.Context, req sdk.TypedStepRequest[*contracts.InboxReceiveConfig, *contracts.InboxReceiveInput], ) (*sdk.TypedStepResult[*contracts.InboxReceiveOutput], error)
func ExecuteSignalInboxReclaimStale ¶ added in v0.35.0
func ExecuteSignalInboxReclaimStale( _ context.Context, req sdk.TypedStepRequest[*contracts.InboxReclaimStaleConfig, *contracts.InboxReclaimStaleInput], ) (*sdk.TypedStepResult[*contracts.InboxReclaimStaleOutput], error)
func ExecuteSignalInboxRelease ¶ added in v0.35.0
func ExecuteSignalInboxRelease( _ context.Context, req sdk.TypedStepRequest[*contracts.InboxReleaseConfig, *contracts.InboxReleaseInput], ) (*sdk.TypedStepResult[*contracts.InboxReleaseOutput], error)
func ExecuteSignalInboxReleaseBatch ¶ added in v0.36.0
func ExecuteSignalInboxReleaseBatch(ctx context.Context, req sdk.TypedStepRequest[*contracts.InboxReleaseBatchConfig, *contracts.InboxReleaseBatchInput]) (*sdk.TypedStepResult[*contracts.InboxReleaseBatchOutput], error)
func ExecuteSignalInboxRequeue ¶ added in v0.35.0
func ExecuteSignalInboxRequeue( _ context.Context, req sdk.TypedStepRequest[*contracts.InboxRequeueConfig, *contracts.InboxRequeueInput], ) (*sdk.TypedStepResult[*contracts.InboxRequeueOutput], error)
func ExecuteSignalOutboxAck ¶ added in v0.29.0
func ExecuteSignalOutboxAck( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxAckConfig, *contracts.OutboxAckInput], ) (*sdk.TypedStepResult[*contracts.OutboxAckOutput], error)
func ExecuteSignalOutboxAckBatch ¶ added in v0.36.0
func ExecuteSignalOutboxAckBatch(ctx context.Context, req sdk.TypedStepRequest[*contracts.OutboxAckBatchConfig, *contracts.OutboxAckBatchInput]) (*sdk.TypedStepResult[*contracts.OutboxAckBatchOutput], error)
func ExecuteSignalOutboxClaim ¶ added in v0.12.0
func ExecuteSignalOutboxClaim( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxClaimConfig, *contracts.OutboxClaimInput], ) (*sdk.TypedStepResult[*contracts.OutboxClaimOutput], error)
func ExecuteSignalOutboxClaimBatch ¶ added in v0.36.0
func ExecuteSignalOutboxClaimBatch( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxClaimBatchConfig, *contracts.OutboxClaimBatchInput], ) (*sdk.TypedStepResult[*contracts.OutboxClaimBatchOutput], error)
func ExecuteSignalOutboxClaimNext ¶ added in v0.36.0
func ExecuteSignalOutboxClaimNext( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxClaimNextConfig, *contracts.OutboxClaimNextInput], ) (*sdk.TypedStepResult[*contracts.OutboxClaimNextOutput], error)
func ExecuteSignalOutboxDeadLetter ¶ added in v0.33.0
func ExecuteSignalOutboxDeadLetter( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxDeadLetterConfig, *contracts.OutboxDeadLetterInput], ) (*sdk.TypedStepResult[*contracts.OutboxDeadLetterOutput], error)
func ExecuteSignalOutboxEnqueue ¶ added in v0.12.0
func ExecuteSignalOutboxEnqueue( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxEnqueueConfig, *contracts.OutboxEnqueueInput], ) (*sdk.TypedStepResult[*contracts.OutboxEnqueueOutput], error)
func ExecuteSignalOutboxEnqueueBatch ¶ added in v0.35.0
func ExecuteSignalOutboxEnqueueBatch( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxEnqueueBatchConfig, *contracts.OutboxEnqueueBatchInput], ) (*sdk.TypedStepResult[*contracts.OutboxEnqueueBatchOutput], error)
func ExecuteSignalOutboxHandoff ¶ added in v0.31.0
func ExecuteSignalOutboxHandoff( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxHandoffConfig, *contracts.OutboxHandoffInput], ) (*sdk.TypedStepResult[*contracts.OutboxHandoffOutput], error)
func ExecuteSignalOutboxHandoffBatch ¶ added in v0.36.0
func ExecuteSignalOutboxHandoffBatch(_ context.Context, req sdk.TypedStepRequest[*contracts.OutboxHandoffBatchConfig, *contracts.OutboxHandoffBatchInput]) (*sdk.TypedStepResult[*contracts.OutboxHandoffBatchOutput], error)
func ExecuteSignalOutboxRelease ¶ added in v0.29.0
func ExecuteSignalOutboxRelease( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxReleaseConfig, *contracts.OutboxReleaseInput], ) (*sdk.TypedStepResult[*contracts.OutboxReleaseOutput], error)
func ExecuteSignalOutboxReleaseBatch ¶ added in v0.36.0
func ExecuteSignalOutboxReleaseBatch(ctx context.Context, req sdk.TypedStepRequest[*contracts.OutboxReleaseBatchConfig, *contracts.OutboxReleaseBatchInput]) (*sdk.TypedStepResult[*contracts.OutboxReleaseBatchOutput], error)
func ExecuteSignalOutboxRequeue ¶ added in v0.34.0
func ExecuteSignalOutboxRequeue( _ context.Context, req sdk.TypedStepRequest[*contracts.OutboxRequeueConfig, *contracts.OutboxRequeueInput], ) (*sdk.TypedStepResult[*contracts.OutboxRequeueOutput], error)
func ExecuteSignalPublicPreKeyPublish ¶ added in v0.15.0
func ExecuteSignalPublicPreKeyPublish( ctx context.Context, req sdk.TypedStepRequest[*contracts.PublicPreKeyPublishConfig, *contracts.PublicPreKeyPublishInput], ) (*sdk.TypedStepResult[*contracts.PublicPreKeyPublishOutput], error)
func ExecuteSignalPublicPreKeyResolve ¶ added in v0.15.0
func ExecuteSignalPublicPreKeyResolve( ctx context.Context, req sdk.TypedStepRequest[*contracts.PublicPreKeyResolveConfig, *contracts.PublicPreKeyResolveInput], ) (*sdk.TypedStepResult[*contracts.PublicPreKeyResolveOutput], error)
func ExecuteSignalSenderCertificateIssue ¶ added in v0.19.0
func ExecuteSignalSenderCertificateIssue( _ context.Context, req sdk.TypedStepRequest[*contracts.SenderCertificateIssueConfig, *contracts.SenderCertificateIssueInput], ) (*sdk.TypedStepResult[*contracts.SenderCertificateIssueOutput], error)
func ExecuteSignalSenderSeal ¶ added in v0.19.0
func ExecuteSignalSenderSeal( _ context.Context, req sdk.TypedStepRequest[*contracts.SenderSealConfig, *contracts.SenderSealInput], ) (*sdk.TypedStepResult[*contracts.SenderSealOutput], error)
func ExecuteSignalSenderSealFanout ¶ added in v0.20.0
func ExecuteSignalSenderSealFanout( _ context.Context, req sdk.TypedStepRequest[*contracts.SenderSealFanoutConfig, *contracts.SenderSealFanoutInput], ) (*sdk.TypedStepResult[*contracts.SenderSealFanoutOutput], error)
func ExecuteSignalSenderUnseal ¶ added in v0.19.0
func ExecuteSignalSenderUnseal( _ context.Context, req sdk.TypedStepRequest[*contracts.SenderUnsealConfig, *contracts.SenderUnsealInput], ) (*sdk.TypedStepResult[*contracts.SenderUnsealOutput], error)
func ExecuteSignalServiceApprovalValidate ¶ added in v0.7.0
func ExecuteSignalServiceApprovalValidate( _ context.Context, req sdk.TypedStepRequest[*contracts.ServiceApprovalValidateConfig, *contracts.ServiceApprovalValidateInput], ) (*sdk.TypedStepResult[*contracts.ServiceApprovalValidateOutput], error)
func ExecuteSignalServiceChallengeRespond ¶ added in v0.9.0
func ExecuteSignalServiceChallengeRespond( _ context.Context, req sdk.TypedStepRequest[*contracts.ServiceChallengeRespondConfig, *contracts.ServiceChallengeRespondInput], ) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
func ExecuteSignalServiceComplianceCheck ¶ added in v0.5.0
func ExecuteSignalServiceComplianceCheck( _ context.Context, req sdk.TypedStepRequest[*contracts.ServiceComplianceCheckConfig, *contracts.ServiceComplianceCheckInput], ) (*sdk.TypedStepResult[*contracts.ServiceComplianceCheckOutput], error)
func ExecuteSignalServiceContractCheck ¶ added in v0.4.0
func ExecuteSignalServiceContractCheck( _ context.Context, req sdk.TypedStepRequest[*contracts.ServiceContractCheckConfig, *contracts.ServiceContractCheckInput], ) (*sdk.TypedStepResult[*contracts.ServiceContractCheckOutput], error)
func ExecuteSignalServiceLinkPrepare ¶ added in v0.9.0
func ExecuteSignalServiceLinkPrepare( _ context.Context, req sdk.TypedStepRequest[*contracts.ServiceLinkPrepareConfig, *contracts.ServiceLinkPrepareInput], ) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
func ExecuteSignalServiceLiveSubmit ¶ added in v0.7.0
func ExecuteSignalServiceLiveSubmit( ctx context.Context, req sdk.TypedStepRequest[*contracts.ServiceLiveSubmitConfig, *contracts.ServiceLiveSubmitInput], ) (*sdk.TypedStepResult[*contracts.ServiceSubmitOutput], error)
func ExecuteSignalServicePolicyCheck ¶ added in v0.6.0
func ExecuteSignalServicePolicyCheck( _ context.Context, req sdk.TypedStepRequest[*contracts.ServicePolicyCheckConfig, *contracts.ServicePolicyCheckInput], ) (*sdk.TypedStepResult[*contracts.ServicePolicyCheckOutput], error)
func ExecuteSignalServiceReceiveAdmit ¶ added in v0.9.0
func ExecuteSignalServiceReceiveAdmit( _ context.Context, req sdk.TypedStepRequest[*contracts.ServiceReceiveAdmitConfig, *contracts.ServiceReceiveAdmitInput], ) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
func ExecuteSignalServiceRegisterPrepare ¶ added in v0.9.0
func ExecuteSignalServiceRegisterPrepare( _ context.Context, req sdk.TypedStepRequest[*contracts.ServiceRegisterPrepareConfig, *contracts.ServiceRegisterPrepareInput], ) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
func ExecuteSignalServiceSendPrepare ¶ added in v0.9.0
func ExecuteSignalServiceSendPrepare( _ context.Context, req sdk.TypedStepRequest[*contracts.ServiceSendPrepareConfig, *contracts.ServiceSendPrepareInput], ) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
func ExecuteSignalServiceTestBackupDownload ¶ added in v0.10.0
func ExecuteSignalServiceTestBackupDownload( ctx context.Context, req sdk.TypedStepRequest[*contracts.ServiceTestBackupDownloadConfig, *contracts.ServiceTestBackupDownloadInput], ) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
func ExecuteSignalServiceTestBackupUpload ¶ added in v0.10.0
func ExecuteSignalServiceTestBackupUpload( ctx context.Context, req sdk.TypedStepRequest[*contracts.ServiceTestBackupUploadConfig, *contracts.ServiceTestBackupUploadInput], ) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
func ExecuteSignalServiceTestLinkDevice ¶ added in v0.6.0
func ExecuteSignalServiceTestLinkDevice( ctx context.Context, req sdk.TypedStepRequest[*contracts.ServiceTestLinkDeviceConfig, *contracts.ServiceTestLinkDeviceInput], ) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
func ExecuteSignalServiceTestReceive ¶ added in v0.6.0
func ExecuteSignalServiceTestReceive( ctx context.Context, req sdk.TypedStepRequest[*contracts.ServiceTestReceiveConfig, *contracts.ServiceTestReceiveInput], ) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
func ExecuteSignalServiceTestRegister ¶ added in v0.6.0
func ExecuteSignalServiceTestRegister( ctx context.Context, req sdk.TypedStepRequest[*contracts.ServiceTestRegisterConfig, *contracts.ServiceTestRegisterInput], ) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
func ExecuteSignalServiceTestSend ¶ added in v0.6.0
func ExecuteSignalServiceTestSend( ctx context.Context, req sdk.TypedStepRequest[*contracts.ServiceTestSendConfig, *contracts.ServiceTestSendInput], ) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
func ExecuteSignalServiceTestUsernameReserve ¶ added in v0.10.0
func ExecuteSignalServiceTestUsernameReserve( ctx context.Context, req sdk.TypedStepRequest[*contracts.ServiceTestUsernameReserveConfig, *contracts.ServiceTestUsernameReserveInput], ) (*sdk.TypedStepResult[*contracts.ServiceTestOutput], error)
func ExecuteSignalSessionPrepare ¶ added in v0.2.0
func ExecuteSignalSessionPrepare( _ context.Context, req sdk.TypedStepRequest[*contracts.SessionPrepareConfig, *contracts.SessionPrepareInput], ) (*sdk.TypedStepResult[*contracts.SessionPrepareOutput], error)
func ExecuteSignalTransportAdmit ¶ added in v0.31.0
func ExecuteSignalTransportAdmit( _ context.Context, req sdk.TypedStepRequest[*contracts.TransportAdmitConfig, *contracts.TransportAdmitInput], ) (*sdk.TypedStepResult[*contracts.TransportAdmitOutput], error)
func ExecuteSignalTransportAdmitBatch ¶ added in v0.36.0
func ExecuteSignalTransportAdmitBatch(ctx context.Context, req sdk.TypedStepRequest[*contracts.TransportAdmitBatchConfig, *contracts.TransportAdmitBatchInput]) (*sdk.TypedStepResult[*contracts.TransportAdmitBatchOutput], error)
func ExecuteSignalTransportReceiptIssue ¶ added in v0.35.0
func ExecuteSignalTransportReceiptIssue( _ context.Context, req sdk.TypedStepRequest[*contracts.TransportReceiptIssueConfig, *contracts.TransportReceiptIssueInput], ) (*sdk.TypedStepResult[*contracts.TransportReceiptIssueOutput], error)
func ExecuteSignalTransportReceiptVerify ¶ added in v0.35.0
func ExecuteSignalTransportReceiptVerify( _ context.Context, req sdk.TypedStepRequest[*contracts.TransportReceiptVerifyConfig, *contracts.TransportReceiptVerifyInput], ) (*sdk.TypedStepResult[*contracts.TransportReceiptVerifyOutput], error)
func ExecuteSignalTransportReceiptVerifyBatch ¶ added in v0.36.0
func ExecuteSignalTransportReceiptVerifyBatch(ctx context.Context, req sdk.TypedStepRequest[*contracts.TransportReceiptVerifyBatchConfig, *contracts.TransportReceiptVerifyBatchInput]) (*sdk.TypedStepResult[*contracts.TransportReceiptVerifyBatchOutput], error)
func ExecuteSignalTrustHistory ¶ added in v0.25.0
func ExecuteSignalTrustHistory( ctx context.Context, req sdk.TypedStepRequest[*contracts.SignalTrustHistoryConfig, *contracts.SignalTrustHistoryInput], ) (*sdk.TypedStepResult[*contracts.SignalTrustHistoryOutput], error)
ExecuteSignalTrustHistory returns bounded, redacted trust decision history.
func ExecuteSignalTrustObserve ¶ added in v0.22.0
func ExecuteSignalTrustObserve( ctx context.Context, req sdk.TypedStepRequest[*contracts.SignalTrustObserveConfig, *contracts.SignalTrustObserveInput], ) (*sdk.TypedStepResult[*contracts.SignalTrustObserveOutput], error)
ExecuteSignalTrustObserve computes a Signal fingerprint and evaluates it against a persistent trust policy store.
func ExecuteSignalTrustPolicyCheck ¶ added in v0.26.0
func ExecuteSignalTrustPolicyCheck( ctx context.Context, req sdk.TypedStepRequest[*contracts.SignalTrustPolicyCheckConfig, *contracts.SignalTrustPolicyCheckInput], ) (*sdk.TypedStepResult[*contracts.SignalTrustPolicyCheckOutput], error)
ExecuteSignalTrustPolicyCheck evaluates stored trust state before an app proceeds to send, seal, fan out, queue, or transport encrypted data.
func ExecuteSignalTrustPolicyCheckBatch ¶ added in v0.28.0
func ExecuteSignalTrustPolicyCheckBatch( ctx context.Context, req sdk.TypedStepRequest[*contracts.SignalTrustPolicyCheckBatchConfig, *contracts.SignalTrustPolicyCheckBatchInput], ) (*sdk.TypedStepResult[*contracts.SignalTrustPolicyCheckBatchOutput], error)
ExecuteSignalTrustPolicyCheckBatch evaluates multiple stored trust refs as one application gate before fanout, room send, queue, or transport work.
func ExecuteSignalTrustReset ¶ added in v0.24.0
func ExecuteSignalTrustReset( ctx context.Context, req sdk.TypedStepRequest[*contracts.SignalTrustResetConfig, *contracts.SignalTrustResetInput], ) (*sdk.TypedStepResult[*contracts.SignalTrustResetOutput], error)
ExecuteSignalTrustReset computes a Signal fingerprint and replaces an existing trusted record after caller-supplied approval metadata passes.
func ExecuteSignalUsernameArtifactPrepare ¶ added in v0.23.0
func ExecuteSignalUsernameArtifactPrepare( _ context.Context, req sdk.TypedStepRequest[*contracts.UsernameArtifactPrepareConfig, *contracts.UsernameArtifactPrepareInput], ) (*sdk.TypedStepResult[*contracts.UsernameArtifactPrepareOutput], error)
ExecuteSignalUsernameArtifactPrepare prepares username reserve/link artifacts.
func ExecuteSignalUsernameLinkCreate ¶ added in v0.3.0
func ExecuteSignalUsernameLinkCreate( _ context.Context, req sdk.TypedStepRequest[*contracts.UsernameLinkCreateConfig, *contracts.UsernameLinkCreateInput], ) (*sdk.TypedStepResult[*contracts.UsernameLinkCreateOutput], error)
ExecuteSignalUsernameLinkCreate creates a Signal username-link ciphertext.
func ExecuteSignalUsernameLinkDecrypt ¶ added in v0.3.0
func ExecuteSignalUsernameLinkDecrypt( _ context.Context, req sdk.TypedStepRequest[*contracts.UsernameLinkDecryptConfig, *contracts.UsernameLinkDecryptInput], ) (*sdk.TypedStepResult[*contracts.UsernameLinkDecryptOutput], error)
ExecuteSignalUsernameLinkDecrypt decrypts a Signal username-link ciphertext.
func ExecuteSignalUsernameProofPrepare ¶ added in v0.9.0
func ExecuteSignalUsernameProofPrepare( _ context.Context, req sdk.TypedStepRequest[*contracts.UsernameProofPrepareConfig, *contracts.UsernameProofPrepareInput], ) (*sdk.TypedStepResult[*contracts.ServiceOperationPrepareOutput], error)
Types ¶
type SignalProvider ¶
type SignalProvider struct{}
SignalProvider implements sdk.PluginProvider, sdk.TypedModuleProvider, sdk.TypedStepProvider, and sdk.ContractProvider.
func NewSignalProvider ¶
func NewSignalProvider() *SignalProvider
NewSignalProvider creates a new SignalProvider.
func (*SignalProvider) ContractRegistry ¶
func (p *SignalProvider) ContractRegistry() *pb.ContractRegistry
ContractRegistry implements sdk.ContractProvider.
func (*SignalProvider) CreateTypedModule ¶ added in v0.2.0
func (p *SignalProvider) CreateTypedModule(typeName, name string, config *anypb.Any) (sdk.ModuleInstance, error)
CreateTypedModule implements sdk.TypedModuleProvider.
func (*SignalProvider) CreateTypedStep ¶
func (p *SignalProvider) CreateTypedStep(typeName, name string, config *anypb.Any) (sdk.StepInstance, error)
CreateTypedStep implements sdk.TypedStepProvider.
func (*SignalProvider) Manifest ¶
func (p *SignalProvider) Manifest() sdk.PluginManifest
Manifest implements sdk.PluginProvider.
func (*SignalProvider) TypedModuleTypes ¶ added in v0.2.0
func (p *SignalProvider) TypedModuleTypes() []string
TypedModuleTypes implements sdk.TypedModuleProvider.
func (*SignalProvider) TypedStepTypes ¶
func (p *SignalProvider) TypedStepTypes() []string
TypedStepTypes implements sdk.TypedStepProvider.
Source Files
¶
- blob_steps.go
- client_worker_device_stubs.go
- custody.go
- custody_steps.go
- device_directory.go
- envelope_steps.go
- envelope_store.go
- envelope_transport.go
- key_custody.go
- modules.go
- provider.go
- public_prekey_directory.go
- sealed_sender_steps.go
- service_boundary.go
- service_compliance.go
- service_test_steps.go
- service_transport.go
- steps.go
- steps_service_operations.go
- trust_store.go