v1

Documentation

Index

• Constants
• Variables
• func UserSyncActionTenantID(action proto.Message) string
• func UserSyncActionWorkflowID(action proto.Message) string
• func UserSyncQueueDefinition(activityMain any, workflowFunc any, ...) *actionqueue.Definition
• type UserSyncAction
  • func (*UserSyncAction) Descriptor() ([]byte, []int)
  • func (x *UserSyncAction) GetSyncReason() string
  • func (x *UserSyncAction) GetTenantId() string
  • func (x *UserSyncAction) GetUserId() string
  • func (*UserSyncAction) ProtoMessage()
  • func (x *UserSyncAction) ProtoReflect() protoreflect.Message
  • func (x *UserSyncAction) Reset()
  • func (x *UserSyncAction) String() string

Constants

const (
	UserSyncQueueName   = "user-sync-queue"
	UserSyncQueueSignal = "signal:start:user-sync-queue"
)

Variables

var File_v1_example_proto protoreflect.FileDescriptor

Functions

func UserSyncActionTenantID

func UserSyncActionTenantID(action proto.Message) string

UserSyncActionTenantID extracts the tenant ID from a UserSyncAction action.

func UserSyncActionWorkflowID

func UserSyncActionWorkflowID(action proto.Message) string

UserSyncActionWorkflowID returns the workflow ID for a UserSyncAction action.

func UserSyncQueueDefinition

func UserSyncQueueDefinition(activityMain any, workflowFunc any, activityOptions func() workflow.ActivityOptions) *actionqueue.Definition

UserSyncQueueDefinition creates an actionqueue.Definition for the user-sync-queue queue.

Types

type UserSyncAction

type UserSyncAction struct {
	TenantId   string `protobuf:"bytes,1,opt,name=tenant_id,json=tenantId,proto3" json:"tenant_id,omitempty"`
	UserId     string `protobuf:"bytes,2,opt,name=user_id,json=userId,proto3" json:"user_id,omitempty"`
	SyncReason string `protobuf:"bytes,3,opt,name=sync_reason,json=syncReason,proto3" json:"sync_reason,omitempty"`
	// contains filtered or unexported fields
}

func (*UserSyncAction) Descriptor

func (*UserSyncAction) Descriptor() ([]byte, []int)

Deprecated: Use UserSyncAction.ProtoReflect.Descriptor instead.

func (*UserSyncAction) GetSyncReason

func (x *UserSyncAction) GetSyncReason() string

func (*UserSyncAction) GetTenantId

func (x *UserSyncAction) GetTenantId() string

func (*UserSyncAction) GetUserId

func (x *UserSyncAction) GetUserId() string

func (*UserSyncAction) ProtoMessage

func (*UserSyncAction) ProtoMessage()

func (*UserSyncAction) ProtoReflect

func (x *UserSyncAction) ProtoReflect() protoreflect.Message

func (*UserSyncAction) Reset

func (x *UserSyncAction) Reset()

func (*UserSyncAction) String

func (x *UserSyncAction) String() string