Documentation
¶
Index ¶
- Variables
- func Consume(s Consumer, group string, evs ...Unmarshaller) (<-chan Event, error)
- func ConsumeAll(s Consumer, group string) (<-chan Event, error)
- func Publish(ctx context.Context, s Publisher, ev interface{}) error
- type BackchannelLogout
- type BytesReceived
- type Consumer
- type ContainerCreated
- type Event
- type FileDownloaded
- type FileLocked
- type FileTouched
- type FileUnlocked
- type FileUploaded
- type FileVersionRestored
- type GroupCreated
- type GroupDeleted
- type GroupFeature
- type GroupFeatureChanged
- type GroupMemberAdded
- type GroupMemberRemoved
- type ItemMoved
- type ItemPurged
- type ItemRestored
- type ItemTrashed
- type LinkAccessFailed
- type LinkAccessed
- type LinkCreated
- type LinkRemoved
- type LinkUpdated
- type OCMCoreShareCreated
- type PersonalDataExtracted
- type PostprocessingFinished
- type PostprocessingOutcome
- type PostprocessingRetry
- type PostprocessingStepFinished
- type Postprocessingstep
- type Publisher
- type ReceivedShareUpdated
- type RestartPostprocessing
- type ResumePostprocessing
- type ScienceMeshInviteTokenGenerated
- type SendEmailsEvent
- type SendSSE
- type ShareCreated
- type ShareExpired
- type ShareRemoved
- type ShareUpdated
- type SpaceCreated
- type SpaceDeleted
- type SpaceDisabled
- type SpaceEnabled
- type SpaceMembershipExpired
- type SpaceRenamed
- type SpaceShareUpdated
- type SpaceShared
- type SpaceUnshared
- type SpaceUpdated
- type StartPostprocessingStep
- type Stream
- type TagsAdded
- type TagsRemoved
- type Unmarshaller
- type UploadReady
- type UserCreated
- type UserDeleted
- type UserFeature
- type UserFeatureChanged
- type UserSignedIn
- type VirusscanResult
Constants ¶
This section is empty.
Variables ¶
var ( // MainQueueName is the name of the main queue // All events will go through here as they are forwarded to the consumer via the // group name // TODO: "fan-out" so not all events go through the same queue? requires investigation MainQueueName = "main-queue" // MetadatakeyEventType is the key used for the eventtype in the metadata map of the event MetadatakeyEventType = "eventtype" // MetadatakeyEventID is the key used for the eventID in the metadata map of the event MetadatakeyEventID = "eventid" // MetadatakeyTraceParent is the key used for the traceparent in the metadata map of the event MetadatakeyTraceParent = "traceparent" // MetadatakeyInitiatorID is the key used for the initiator id in the metadata map of the event MetadatakeyInitiatorID = "initiatorid" )
var ( // PPStepAntivirus is the step that scans for viruses PPStepAntivirus Postprocessingstep = "virusscan" // PPStepPolicies is the step the step that enforces policies PPStepPolicies Postprocessingstep = "policies" // PPStepDelay is the step that processing. Useful for testing or user annoyment PPStepDelay Postprocessingstep = "delay" // PPStepFinished is the step that signals that postprocessing is finished, but storage provider hasn't acknowledged it yet PPStepFinished Postprocessingstep = "finished" // PPOutcomeDelete means that the file and the upload should be deleted PPOutcomeDelete PostprocessingOutcome = "delete" // PPOutcomeAbort means that the upload is cancelled but the bytes are being kept in the upload folder PPOutcomeAbort PostprocessingOutcome = "abort" // PPOutcomeContinue means that the upload is moved to its final destination (eventually being marked with pp results) PPOutcomeContinue PostprocessingOutcome = "continue" // PPOutcomeRetry means that there was a temporary issue and the postprocessing should be retried at a later point in time PPOutcomeRetry PostprocessingOutcome = "retry" )
Functions ¶
func Consume ¶
func Consume(s Consumer, group string, evs ...Unmarshaller) (<-chan Event, error)
Consume returns a channel that will get all events that match the given evs group defines the service type: One group will get exactly one copy of a event that is emitted NOTE: uses reflect on initialization
func ConsumeAll ¶
ConsumeAll allows consuming all events. Note that unmarshalling must be done manually in this case, therefore Event.Event will always be of type []byte
Types ¶
type BackchannelLogout ¶
type BackchannelLogout struct {
Executant *user.UserId
SessionId string
Timestamp *types.Timestamp
}
BackchannelLogout is emitted when the callback from the identity provider is received
func (BackchannelLogout) Unmarshal ¶
func (BackchannelLogout) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type BytesReceived ¶
type BytesReceived struct {
UploadID string
SpaceOwner *user.UserId
ExecutingUser *user.User
ResourceID *provider.ResourceId
Filename string
Filesize uint64
URL string
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
BytesReceived is emitted by the server when it received all bytes of an upload
func (BytesReceived) Unmarshal ¶
func (BytesReceived) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ContainerCreated ¶
type ContainerCreated struct {
SpaceOwner *user.UserId
Executant *user.UserId
Ref *provider.Reference
Owner *user.UserId
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
ContainerCreated is emitted when a directory has been created
func (ContainerCreated) Unmarshal ¶
func (ContainerCreated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type FileDownloaded ¶
type FileDownloaded struct {
Executant *user.UserId
Ref *provider.Reference
Owner *user.UserId
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
FileDownloaded is emitted when a file is downloaded
func (FileDownloaded) Unmarshal ¶
func (FileDownloaded) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type FileLocked ¶
type FileLocked struct {
Executant *user.UserId
Ref *provider.Reference
Owner *user.UserId
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
FileLocked is emitted when a file is locked
func (FileLocked) Unmarshal ¶
func (FileLocked) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type FileTouched ¶
type FileTouched struct {
SpaceOwner *user.UserId
Executant *user.UserId
Ref *provider.Reference
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
FileTouched is emitted when a file is uploaded
func (FileTouched) Unmarshal ¶
func (FileTouched) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type FileUnlocked ¶
type FileUnlocked struct {
Executant *user.UserId
Ref *provider.Reference
Owner *user.UserId
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
FileUnlocked is emitted when a file is unlocked
func (FileUnlocked) Unmarshal ¶
func (FileUnlocked) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type FileUploaded ¶
type FileUploaded struct {
SpaceOwner *user.UserId
Executant *user.UserId
Ref *provider.Reference
Owner *user.UserId
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
FileUploaded is emitted when a file is uploaded
func (FileUploaded) Unmarshal ¶
func (FileUploaded) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type FileVersionRestored ¶
type FileVersionRestored struct {
SpaceOwner *user.UserId
Executant *user.UserId
Ref *provider.Reference
Owner *user.UserId
Key string
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
FileVersionRestored is emitted when a file version is restored
func (FileVersionRestored) Unmarshal ¶
func (FileVersionRestored) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type GroupCreated ¶
GroupCreated is emitted when a group was created
func (GroupCreated) Unmarshal ¶
func (GroupCreated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type GroupDeleted ¶
GroupDeleted is emitted when a group was deleted
func (GroupDeleted) Unmarshal ¶
func (GroupDeleted) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type GroupFeature ¶
GroupFeature represents a group feature
type GroupFeatureChanged ¶
type GroupFeatureChanged struct {
Executant *user.UserId
GroupID string
Features []GroupFeature
Timestamp *types.Timestamp
}
GroupFeatureChanged is emitted when a group feature was changed
func (GroupFeatureChanged) Unmarshal ¶
func (GroupFeatureChanged) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill unmarshaller interface
type GroupMemberAdded ¶
type GroupMemberAdded struct {
Executant *user.UserId
GroupID string
UserID string
Timestamp *types.Timestamp
}
GroupMemberAdded is emitted when a user was added to a group
func (GroupMemberAdded) Unmarshal ¶
func (GroupMemberAdded) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type GroupMemberRemoved ¶
type GroupMemberRemoved struct {
Executant *user.UserId
GroupID string
UserID string
Timestamp *types.Timestamp
}
GroupMemberRemoved is emitted when a user was removed from a group
func (GroupMemberRemoved) Unmarshal ¶
func (GroupMemberRemoved) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ItemMoved ¶
type ItemMoved struct {
SpaceOwner *user.UserId
Executant *user.UserId
Ref *provider.Reference
Owner *user.UserId
OldReference *provider.Reference
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
ItemMoved is emitted when a file or folder is moved
type ItemPurged ¶
type ItemPurged struct {
Executant *user.UserId
ID *provider.ResourceId
Ref *provider.Reference
Owner *user.UserId
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
ItemPurged is emitted when a file or folder is removed from trashbin
func (ItemPurged) Unmarshal ¶
func (ItemPurged) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ItemRestored ¶
type ItemRestored struct {
SpaceOwner *user.UserId
Executant *user.UserId
ID *provider.ResourceId
Ref *provider.Reference
Owner *user.UserId
OldReference *provider.Reference
Key string
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
ItemRestored is emitted when a file or folder is restored from trashbin
func (ItemRestored) Unmarshal ¶
func (ItemRestored) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ItemTrashed ¶
type ItemTrashed struct {
SpaceOwner *user.UserId
Executant *user.UserId
ID *provider.ResourceId
Ref *provider.Reference
Owner *user.UserId
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
ItemTrashed is emitted when a file or folder is trashed
func (ItemTrashed) Unmarshal ¶
func (ItemTrashed) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type LinkAccessFailed ¶
type LinkAccessFailed struct {
Executant *user.UserId
Token string
Status rpc.Code
Message string
Timestamp *types.Timestamp
}
LinkAccessFailed is emitted when an access to a public link has resulted in an error (by token)
func (LinkAccessFailed) Unmarshal ¶
func (LinkAccessFailed) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type LinkAccessed ¶
type LinkAccessed struct {
Executant *user.UserId
ItemID *provider.ResourceId
Path string
Permissions *link.PublicSharePermissions
DisplayName string
Expiration *types.Timestamp
PasswordProtected bool
CTime *types.Timestamp
Token string
}
LinkAccessed is emitted when a public link is accessed successfully (by token)
func (LinkAccessed) Unmarshal ¶
func (LinkAccessed) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type LinkCreated ¶
type LinkCreated struct {
Executant *user.UserId
ItemID *provider.ResourceId
ResourceName string
Permissions *link.PublicSharePermissions
DisplayName string
Expiration *types.Timestamp
PasswordProtected bool
CTime *types.Timestamp
Token string
}
LinkCreated is emitted when a public link is created
func (LinkCreated) Unmarshal ¶
func (LinkCreated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type LinkRemoved ¶
type LinkRemoved struct {
Executant *user.UserId
// split protobuf Ref
Timestamp *types.Timestamp
ItemID *provider.ResourceId
ResourceName string
}
LinkRemoved is emitted when a share is removed
func (LinkRemoved) Unmarshal ¶
func (LinkRemoved) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type LinkUpdated ¶
type LinkUpdated struct {
Executant *user.UserId
ItemID *provider.ResourceId
ResourceName string
Permissions *link.PublicSharePermissions
DisplayName string
Expiration *types.Timestamp
PasswordProtected bool
MTime *types.Timestamp
Token string
FieldUpdated string
}
LinkUpdated is emitted when a public link is updated
func (LinkUpdated) Unmarshal ¶
func (LinkUpdated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type OCMCoreShareCreated ¶
type OCMCoreShareCreated struct {
}
OCMCoreShareCreated is emitted when an ocm share is received
func (OCMCoreShareCreated) Unmarshal ¶
func (OCMCoreShareCreated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type PersonalDataExtracted ¶
type PersonalDataExtracted struct {
Executant *user.UserId
Timestamp *types.Timestamp
ErrorMsg string
}
PersonalDataExtracted is emitted when a user data extraction is finished
func (PersonalDataExtracted) Unmarshal ¶
func (PersonalDataExtracted) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type PostprocessingFinished ¶
type PostprocessingFinished struct {
UploadID string
Filename string
SpaceOwner *user.UserId
ExecutingUser *user.User
Result map[Postprocessingstep]interface{} // it is a map[step]Event
Outcome PostprocessingOutcome
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
PostprocessingFinished is emitted by *some* service which can decide that
func (PostprocessingFinished) Unmarshal ¶
func (PostprocessingFinished) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type PostprocessingOutcome ¶
type PostprocessingOutcome string
PostprocessingOutcome defines the result of the postprocessing
type PostprocessingRetry ¶
type PostprocessingRetry struct {
UploadID string
Filename string
ExecutingUser *user.User
Failures int
BackoffDuration time.Duration
}
PostprocessingRetry is emitted by *some* service which can decide that
func (PostprocessingRetry) Unmarshal ¶
func (PostprocessingRetry) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type PostprocessingStepFinished ¶
type PostprocessingStepFinished struct {
UploadID string
ExecutingUser *user.User
Filename string
FinishedStep Postprocessingstep // name of the step
Result interface{} // result information see VirusscanResult for example
Error error // possible error of the step
Outcome PostprocessingOutcome // some services may cause postprocessing to stop
Timestamp *types.Timestamp
}
PostprocessingStepFinished can be issued by the server when a postprocessing step is finished
func (PostprocessingStepFinished) Unmarshal ¶
func (PostprocessingStepFinished) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type Postprocessingstep ¶
type Postprocessingstep string
Postprocessingstep are the available postprocessingsteps
type Publisher ¶
type Publisher interface {
Publish(string, interface{}, ...events.PublishOption) error
}
Publisher is the interface publishers need to fulfill
type ReceivedShareUpdated ¶
type ReceivedShareUpdated struct {
}
ReceivedShareUpdated is emitted when a received share is accepted or declined
func (ReceivedShareUpdated) Unmarshal ¶
func (ReceivedShareUpdated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type RestartPostprocessing ¶
RestartPostprocessing will be emitted by postprocessing service if it doesn't know about an upload
func (RestartPostprocessing) Unmarshal ¶
func (RestartPostprocessing) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ResumePostprocessing ¶
type ResumePostprocessing struct {
UploadID string
Step Postprocessingstep
Timestamp *types.Timestamp
}
ResumePostprocessing can be emitted to repair broken postprocessing
func (ResumePostprocessing) Unmarshal ¶
func (ResumePostprocessing) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ScienceMeshInviteTokenGenerated ¶
type ScienceMeshInviteTokenGenerated struct {
RecipientMail string
Token string
Description string
Expiration uint64
InviteLink string
Timestamp *types.Timestamp
}
ScienceMeshInviteTokenGenerated is emitted when a sciencemesh token is generated
func (ScienceMeshInviteTokenGenerated) Unmarshal ¶
func (ScienceMeshInviteTokenGenerated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill unmarshaller interface
type SendEmailsEvent ¶
type SendEmailsEvent struct {
Interval string
}
SendEmailsEvent instructs the notification service to send grouped emails
func (SendEmailsEvent) Unmarshal ¶
func (SendEmailsEvent) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ShareCreated ¶
type ShareCreated struct {
// split the protobuf Grantee oneof so we can use stdlib encoding/json
}
ShareCreated is emitted when a share is created
func (ShareCreated) Unmarshal ¶
func (ShareCreated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ShareExpired ¶
type ShareExpired struct {
// split the protobuf Grantee oneof so we can use stdlib encoding/json
}
ShareExpired is emitted when a share expires
func (ShareExpired) Unmarshal ¶
func (ShareExpired) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ShareRemoved ¶
type ShareRemoved struct {
// split protobuf Spec
// split the protobuf Grantee oneof so we can use stdlib encoding/json
}
ShareRemoved is emitted when a share is removed
func (ShareRemoved) Unmarshal ¶
func (ShareRemoved) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type ShareUpdated ¶
type ShareUpdated struct {
UpdateMask []string
}
ShareUpdated is emitted when a share is updated
func (ShareUpdated) Unmarshal ¶
func (ShareUpdated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceCreated ¶
type SpaceCreated struct {
Executant *user.UserId
ID *provider.StorageSpaceId
Owner *user.UserId
Root *provider.ResourceId
Name string
Type string
Quota *provider.Quota
MTime *types.Timestamp
}
SpaceCreated is emitted when a space is created
func (SpaceCreated) Unmarshal ¶
func (SpaceCreated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceDeleted ¶
type SpaceDeleted struct {
Executant *user.UserId
ID *provider.StorageSpaceId
SpaceName string
FinalMembers map[string]provider.ResourcePermissions
Timestamp time.Time
}
SpaceDeleted is emitted when a space is deleted
func (SpaceDeleted) Unmarshal ¶
func (SpaceDeleted) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceDisabled ¶
type SpaceDisabled struct {
Executant *user.UserId
ID *provider.StorageSpaceId
Timestamp time.Time
}
SpaceDisabled is emitted when a space is disabled
func (SpaceDisabled) Unmarshal ¶
func (SpaceDisabled) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceEnabled ¶
type SpaceEnabled struct {
Executant *user.UserId
ID *provider.StorageSpaceId
Owner *user.UserId
Timestamp *types.Timestamp
}
SpaceEnabled is emitted when a space is (re-)enabled
func (SpaceEnabled) Unmarshal ¶
func (SpaceEnabled) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceMembershipExpired ¶
type SpaceMembershipExpired struct {
SpaceOwner *user.UserId
SpaceID *provider.StorageSpaceId
SpaceName string
ExpiredAt time.Time
// split the protobuf Grantee oneof so we can use stdlib encoding/json
GranteeUserID *user.UserId
GranteeGroupID *group.GroupId
Timestamp *types.Timestamp
}
SpaceMembershipExpired is emitted when a space membership expires
func (SpaceMembershipExpired) Unmarshal ¶
func (SpaceMembershipExpired) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceRenamed ¶
type SpaceRenamed struct {
Executant *user.UserId
ID *provider.StorageSpaceId
Owner *user.UserId
Name string
Timestamp *types.Timestamp
}
SpaceRenamed is emitted when a space is renamed
func (SpaceRenamed) Unmarshal ¶
func (SpaceRenamed) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceShareUpdated ¶
type SpaceShareUpdated struct {
}
SpaceShareUpdated is emitted when a space share is updated
func (SpaceShareUpdated) Unmarshal ¶
func (SpaceShareUpdated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceShared ¶
type SpaceShared struct {
}
SpaceShared is emitted when a space is shared
func (SpaceShared) Unmarshal ¶
func (SpaceShared) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceUnshared ¶
type SpaceUnshared struct {
}
SpaceUnshared is emitted when a space is unshared
func (SpaceUnshared) Unmarshal ¶
func (SpaceUnshared) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type SpaceUpdated ¶
type SpaceUpdated struct {
Executant *user.UserId
ID *provider.StorageSpaceId
Space *provider.StorageSpace
Timestamp *types.Timestamp
}
SpaceUpdated is emitted when a space is updated
func (SpaceUpdated) Unmarshal ¶
func (SpaceUpdated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type StartPostprocessingStep ¶
type StartPostprocessingStep struct {
UploadID string
URL string
ExecutingUser *user.User
Filename string
Filesize uint64
Token string // for file retrieval in after upload case
ResourceID *provider.ResourceId // for file retrieval in after upload case
RevaToken string // for file retrieval in after upload case
StepToStart Postprocessingstep
Timestamp *types.Timestamp
ImpersonatingUser *user.User
}
StartPostprocessingStep can be issued by the server to start a postprocessing step
func (StartPostprocessingStep) Unmarshal ¶
func (StartPostprocessingStep) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type Stream ¶
type Stream interface {
Publish(string, interface{}, ...events.PublishOption) error
Consume(string, ...events.ConsumeOption) (<-chan events.Event, error)
}
Stream is the interface common to Publisher and Consumer
type TagsAdded ¶
type TagsAdded struct {
SpaceOwner *user.UserId
Tags string
Ref *provider.Reference
Executant *user.UserId
Timestamp *types.Timestamp
}
TagsAdded is emitted when a Tag has been added
type TagsRemoved ¶
type TagsRemoved struct {
SpaceOwner *user.UserId
Tags string
Ref *provider.Reference
Executant *user.UserId
Timestamp *types.Timestamp
}
TagsRemoved is emitted when a Tag has been added
func (TagsRemoved) Unmarshal ¶
func (TagsRemoved) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type Unmarshaller ¶
Unmarshaller is the interface events need to fulfill
type UploadReady ¶
type UploadReady struct {
UploadID string
Filename string
SpaceOwner *user.UserId
ExecutingUser *user.User
ImpersonatingUser *user.User
FileRef *provider.Reference
Timestamp *types.Timestamp
Failed bool
IsVersion bool
}
UploadReady is emitted by the storage provider when postprocessing is finished
func (UploadReady) Unmarshal ¶
func (UploadReady) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type UserCreated ¶
UserCreated is emitted when a user was created
func (UserCreated) Unmarshal ¶
func (UserCreated) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type UserDeleted ¶
UserDeleted is emitted when a user was deleted
func (UserDeleted) Unmarshal ¶
func (UserDeleted) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type UserFeature ¶
UserFeature represents a user feature
type UserFeatureChanged ¶
type UserFeatureChanged struct {
Executant *user.UserId
UserID string
Features []UserFeature
Timestamp *types.Timestamp
}
UserFeatureChanged is emitted when a user feature was changed
func (UserFeatureChanged) Unmarshal ¶
func (UserFeatureChanged) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
type UserSignedIn ¶
UserSignedIn is emitted when a user signs in
func (UserSignedIn) Unmarshal ¶
func (UserSignedIn) Unmarshal(v []byte) (interface{}, error)
Unmarshal to fulfill umarshaller interface
Source Files
¶
Directories
¶
| Path | Synopsis |
|---|---|
|
consumer
Package consumer contains an example implementation of an event consumer
|
Package consumer contains an example implementation of an event consumer |
|
publisher
Package publisher contains an example implementation for a publisher
|
Package publisher contains an example implementation for a publisher |
|
Package stream provides streaming clients used by `Consume` and `Publish` methods
|
Package stream provides streaming clients used by `Consume` and `Publish` methods |