repository

Nov 28, 2023

Changes in this version

+ type Cache interface

+ DeleteOwner func(ctx context.Context, alias string) error

+ DeleteRepository func(ctx context.Context, key string) error

+ DeleteService func(ctx context.Context, name string) error

+ GetOwner func(ctx context.Context, alias string) (openapi.OwnerDto, error)

+ GetOwnerListTimestamp func(ctx context.Context) (string, error)

+ GetRepository func(ctx context.Context, key string) (openapi.RepositoryDto, error)

+ GetRepositoryListTimestamp func(ctx context.Context) (string, error)

+ GetService func(ctx context.Context, name string) (openapi.ServiceDto, error)

+ GetServiceListTimestamp func(ctx context.Context) (string, error)

+ GetSortedOwnerAliases func(ctx context.Context) ([]string, error)

+ GetSortedRepositoryKeys func(ctx context.Context) ([]string, error)

+ GetSortedServiceNames func(ctx context.Context) ([]string, error)

+ IsCache func() bool

+ PutOwner func(ctx context.Context, alias string, entry openapi.OwnerDto) error

+ PutRepository func(ctx context.Context, key string, entry openapi.RepositoryDto) error

+ PutService func(ctx context.Context, name string, entry openapi.ServiceDto) error

+ SetOwnerListTimestamp func(ctx context.Context, timestamp string) error

+ SetRepositoryListTimestamp func(ctx context.Context, timestamp string) error

+ SetServiceListTimestamp func(ctx context.Context, timestamp string) error

+ Setup func() error

Oct 10, 2023

Changes in this version

type Bitbucket

+ SetupClient func(ctx context.Context) error

type HostIP

+ Setup func() error

type IdentityProvider

+ SetupConnector func(ctx context.Context) error

type Kafka

+ Setup func() error

+ Teardown func()

type Metadata

+ Setup func() error

+ Teardown func()

type Notifier

+ SetupNotifier func(ctx context.Context) error

type SshAuthProvider

+ SetupProvider func(ctx context.Context) error

Aug 14, 2023

Changes in this version

+ const NotifierAcornName

+ type Notifier interface

+ IsNotifier func() bool

+ PublishCreation func(ctx context.Context, payloadName string, payload openapi.NotificationPayload) error

+ PublishDeletion func(ctx context.Context, payloadName string, ...)

+ PublishModification func(ctx context.Context, payloadName string, payload openapi.NotificationPayload) error

+ Setup func(ctx context.Context) error

Jul 4, 2023

Changes in this version

+ const BitbucketAcornName

+ const HostIPAcornName

+ const IdentityProviderAcornName

+ const KafkaAcornName

+ const MetadataAcornName

+ const SshAuthProviderAcornName

+ type Bitbucket interface

+ FilterExistingUsernames func(ctx context.Context, usernames []string) ([]string, error)

+ GetBitbucketUser func(ctx context.Context, username string) (BitbucketUser, error)

+ GetBitbucketUsers func(ctx context.Context, usernames []string) ([]BitbucketUser, error)

+ IsBitbucket func() bool

+ Setup func(ctx context.Context) error

+ type BitbucketUser struct

+ Active bool

+ Id int

+ Name string

+ type CommitInfo struct

+ CommitHash string

+ FilesChanged []string

+ Message string

+ TimeStamp time.Time

+ type EventAffects struct

+ OwnerAliases []string

+ RepositoryKeys []string

+ ServiceNames []string

+ type HostIP interface

+ IsHostIP func() bool

+ ObtainLocalIp func() (net.IP, error)

+ type IdentityProvider interface

+ GetKeySet func(ctx context.Context) []string

+ IsIdentityProvider func() bool

+ ObtainKeySet func(ctx context.Context) error

+ Setup func(ctx context.Context) error

+ VerifyToken func(ctx context.Context, token string) error

+ type Kafka interface

+ IsKafka func() bool

+ Send func(ctx context.Context, event UpdateEvent) error

+ StartReceiveLoop func(ctx context.Context) error

+ SubscribeIncoming func(ctx context.Context, callback ReceiverCallback) error

+ type Metadata interface

+ Clone func(ctx context.Context) error

+ Commit func(ctx context.Context, message string) (CommitInfo, error)

+ DeleteFile func(filename string) error

+ Discard func(ctx context.Context)

+ IsCommitKnown func(hash string) bool

+ IsMetadata func() bool

+ LastUpdated func() time.Time

+ MkdirAll func(path string) error

+ NewPulledCommits func() []CommitInfo

+ Pull func(ctx context.Context) error

+ Push func(ctx context.Context) error

+ ReadDir func(path string) ([]os.FileInfo, error)

+ ReadFile func(filename string) ([]byte, CommitInfo, error)

+ Stat func(filename string) (os.FileInfo, error)

+ WriteFile func(filename string, contents []byte) error

+ type ReceiverCallback func(event UpdateEvent)

+ type SshAuthProvider interface

+ IsSshAuthProvider func() bool

+ ProvideSshAuth func(ctx context.Context) (*ssh.PublicKeys, error)

+ Setup func(ctx context.Context) error

+ type UpdateEvent struct

+ Affected EventAffects

+ CommitHash string

+ TimeStamp string