gdnotify

package module

Go to main page

Versions in this module

v0

v0.4.2

Mar 15, 2023

v0.4.1

Mar 15, 2023

v0.4.0

Mar 6, 2023

Changes in this version

type App

+ func (app *App) DriveIDs(ctx context.Context) ([]string, error)

type Config

+ DrivesAutoDetect *bool

v0.3.0

Mar 3, 2023

Changes in this version

type App

+ func (app *App) SendNotification(ctx context.Context, item *ChannelItem, changes []*drive.Change) error

type CLICommand

+ const CLICommandSync

type Config

+ WithinModifiedTime *time.Duration

type RunMode

+ const RunModeSyncer

v0.2.1

Feb 25, 2023

v0.2.0

Jun 15, 2022

Changes in this version

+ const DetailTypeDriveChanged

+ const DetailTypeDriveRemoved

+ const DetailTypeFileChanged

+ const DetailTypeFileRemoved

+ const DetailTypeFileTrashed

+ type ChangeEventDetail struct

+ Actor *drive.User

+ Change *drive.Change

+ Entity *TargetEntity

+ Subject string

+ func (e *ChangeEventDetail) DetailType() string

+ func (e *ChangeEventDetail) MarshalJSON() ([]byte, error)

+ func (e *ChangeEventDetail) Source(sourcePrefix string) string

+ type TargetEntity struct

+ CreatedTime string

+ Id string

+ Kind string

+ Name string

v0.1.2

Jun 14, 2022

v0.1.1

Jun 14, 2022

v0.1.0

Jun 14, 2022

Changes in this version

+ func CredentialsBackendTypeStrings() []string

type Config

+ Credentials *CredentialsBackendConfig

+ type CredentialsBackend interface

+ WithCredentialsClientOption func(context.Context, []option.ClientOption) ([]option.ClientOption, error)

+ func NewCredentialsBackend(ctx context.Context, cfg *CredentialsBackendConfig, awsCfg aws.Config) (CredentialsBackend, error)

+ type CredentialsBackendConfig struct

+ BackendType CredentialsBackendType

+ Base64Encoding bool

+ ParameterName *string

+ func (cfg *CredentialsBackendConfig) Restrict() error

+ type CredentialsBackendType int

+ const CredentialsBackendTypeNone

+ const CredentialsBackendTypeSSMParameterStore

+ func CredentialsBackendTypeString(s string) (CredentialsBackendType, error)

+ func CredentialsBackendTypeValues() []CredentialsBackendType

+ func (i *CredentialsBackendType) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (i CredentialsBackendType) IsACredentialsBackendType() bool

+ func (i CredentialsBackendType) MarshalYAML() (interface{}, error)

+ func (i CredentialsBackendType) String() string

+ type NoneCredentialsBackend struct

+ func (_ *NoneCredentialsBackend) WithCredentialsClientOption(_ context.Context, orig []option.ClientOption) ([]option.ClientOption, error)

+ type SSMParameterStoreCredentialsBackend struct

+ func NewSSMParameterStoreCredentialsBackend(ctx context.Context, cfg *CredentialsBackendConfig, awsCfg aws.Config) (*SSMParameterStoreCredentialsBackend, error)

+ func (cb *SSMParameterStoreCredentialsBackend) WithCredentialsClientOption(ctx context.Context, orig []option.ClientOption) ([]option.ClientOption, error)

v0.0.0

Jun 13, 2022

Changes in this version

+ const DefaultDriveID

+ func CLICommandStrings() []string

+ func GetAttributeValueAs(key string, values map[string]types.AttributeValue) (T, bool)

+ func NotificationTypeStrings() []string

+ func RunModeStrings() []string

+ func StorageTypeStrings() []string

+ func WithCLICommand(cmd string) func(*RunOptions) error

+ func WithLocalAddress(addr string) func(*RunOptions) error

+ func WithRunMode(mode string) func(*RunOptions) error

+ type App struct

+ func New(cfg *Config, gcpOpts ...option.ClientOption) (*App, error)

+ func (app *App) ChangesList(ctx context.Context, channelID string) ([]*drive.Change, *ChannelItem, error)

+ func (app *App) Close() error

+ func (app *App) CreateChannel(ctx context.Context, driveID string) error

+ func (app *App) DeleteChannel(ctx context.Context, item *ChannelItem) error

+ func (app *App) RotateChannel(ctx context.Context, item *ChannelItem) error

+ func (app *App) Run(optFns ...func(*RunOptions) error) error

+ func (app *App) RunWithContext(ctx context.Context, optFns ...func(*RunOptions) error) error

+ func (app *App) ServeHTTP(w http.ResponseWriter, r *http.Request)

+ type CLICommand int

+ const CLICommandCleanup

+ const CLICommandList

+ const CLICommandMaintenance

+ const CLICommandRegister

+ const CLICommandServe

+ func CLICommandString(s string) (CLICommand, error)

+ func CLICommandValues() []CLICommand

+ func (cmd CLICommand) Description() string

+ func (i CLICommand) IsACLICommand() bool

+ func (i CLICommand) String() string

+ type ChannelAlreadyExists struct

+ ChannelID string

+ func (err *ChannelAlreadyExists) Error() string

+ type ChannelItem struct

+ ChannelID string

+ CreatedAt time.Time

+ DriveID string

+ Expiration time.Time

+ PageToken string

+ PageTokenFetchedAt time.Time

+ ResourceID string

+ UpdatedAt time.Time

+ func NewChannelItemWithDynamoDBAttributeValues(values map[string]types.AttributeValue) *ChannelItem

+ func (item *ChannelItem) IsAboutToExpired(ctx context.Context, remaining time.Duration) bool

+ func (item *ChannelItem) ToDynamoDBAttributeValues() map[string]types.AttributeValue

+ type ChannelNotFound struct

+ ChannelID string

+ func (err *ChannelNotFound) Error() string

+ type Config struct

+ Drives []*DriveConfig

+ Expiration time.Duration

+ Notification *NotificationConfig

+ RequiredVersion string

+ Storage *StorageConfig

+ Webhook string

+ func DefaultConfig() *Config

+ func (c *Config) ValidateVersion(version string) error

+ func (cfg *Config) Load(paths ...string) error

+ func (cfg *Config) Restrict() error

+ type DriveConfig struct

+ DriveID string

+ func (cfg *DriveConfig) Restrict() error

+ type DynamoDBStorage struct

+ func NewDynamoDBStorage(ctx context.Context, cfg *StorageConfig, awsCfg aws.Config) (*DynamoDBStorage, func() error, error)

+ func (s *DynamoDBStorage) DeleteChannel(ctx context.Context, target *ChannelItem) error

+ func (s *DynamoDBStorage) FindAllChannels(ctx context.Context) (<-chan []*ChannelItem, error)

+ func (s *DynamoDBStorage) FindOneByChannelID(ctx context.Context, channelID string) (*ChannelItem, error)

+ func (s *DynamoDBStorage) SaveChannel(ctx context.Context, item *ChannelItem) error

+ func (s *DynamoDBStorage) UpdatePageToken(ctx context.Context, target *ChannelItem) error

+ type EventBridgeClient interface

+ PutEvents func(ctx context.Context, params *eventbridge.PutEventsInput, ...) (*eventbridge.PutEventsOutput, error)

+ type EventBridgeNotification struct

+ func (n *EventBridgeNotification) SendChanges(ctx context.Context, item *ChannelItem, changes []*drive.Change) error

+ type FileNotification struct

+ func NewFileNotification(ctx context.Context, cfg *NotificationConfig) (*FileNotification, func() error, error)

+ func (n *FileNotification) SendChanges(ctx context.Context, _ *ChannelItem, changes []*drive.Change) error

+ type FileStorage struct

+ FilePath string

+ Items []*ChannelItem

+ LockFile string

+ func NewFileStorage(ctx context.Context, cfg *StorageConfig) (*FileStorage, func() error, error)

+ func (s *FileStorage) DeleteChannel(ctx context.Context, target *ChannelItem) error

+ func (s *FileStorage) FindAllChannels(ctx context.Context) (<-chan []*ChannelItem, error)

+ func (s *FileStorage) FindOneByChannelID(ctx context.Context, channelID string) (*ChannelItem, error)

+ func (s *FileStorage) SaveChannel(ctx context.Context, item *ChannelItem) error

+ func (s *FileStorage) UpdatePageToken(ctx context.Context, target *ChannelItem) error

+ type Notification interface

+ SendChanges func(context.Context, *ChannelItem, []*drive.Change) error

+ func NewEventBridgeNotification(ctx context.Context, cfg *NotificationConfig, awsCfg aws.Config) (Notification, func() error, error)

+ func NewNotification(ctx context.Context, cfg *NotificationConfig, awsCfg aws.Config) (Notification, func() error, error)

+ type NotificationConfig struct

+ EventBus *string

+ EventFile *string

+ Type NotificationType

+ func (cfg *NotificationConfig) Restrict() error

+ type NotificationType int

+ const NotificationTypeEventBridge

+ const NotificationTypeFile

+ func NotificationTypeString(s string) (NotificationType, error)

+ func NotificationTypeValues() []NotificationType

+ func (i *NotificationType) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (i NotificationType) IsANotificationType() bool

+ func (i NotificationType) MarshalYAML() (interface{}, error)

+ func (i NotificationType) String() string

+ type RunMode int

+ const RunModeCLI

+ const RunModeMaintainer

+ const RunModeWebhook

+ func DefaultRunMode() RunMode

+ func RunModeString(s string) (RunMode, error)

+ func RunModeValues() []RunMode

+ func (i RunMode) IsARunMode() bool

+ func (i RunMode) String() string

+ type RunOptions struct

+ CLICommand CLICommand

+ LocalAddress string

+ Mode RunMode

+ type Storage interface

+ DeleteChannel func(context.Context, *ChannelItem) error

+ FindAllChannels func(context.Context) (<-chan []*ChannelItem, error)

+ FindOneByChannelID func(context.Context, string) (*ChannelItem, error)

+ SaveChannel func(context.Context, *ChannelItem) error

+ UpdatePageToken func(context.Context, *ChannelItem) error

+ func NewStorage(ctx context.Context, cfg *StorageConfig, awsCfg aws.Config) (Storage, func() error, error)

+ type StorageConfig struct

+ DataFile *string

+ LockFile *string

+ TableName *string

+ Type StorageType

+ func (cfg *StorageConfig) Restrict() error

+ type StorageType int

+ const StorageTypeDynamoDB

+ const StorageTypeFile

+ func StorageTypeString(s string) (StorageType, error)

+ func StorageTypeValues() []StorageType

+ func (i *StorageType) UnmarshalYAML(unmarshal func(interface{}) error) error

+ func (i StorageType) IsAStorageType() bool

+ func (i StorageType) MarshalYAML() (interface{}, error)

+ func (i StorageType) String() string

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL