storage

type FindProfileIDsFunc func(ctx context.Context, params *FindProfilesParams) ([]profile.ID, error)

type FindProfilesFunc func(ctx context.Context, params *FindProfilesParams) ([]profile.Meta, error)

type FindProfilesParams struct {
	Service      string
	Type         profile.ProfileType
	Labels       profile.Labels
	CreatedAtMin time.Time
	CreatedAtMax time.Time
	Limit        int
}

type ListProfilesFunc func(ctx context.Context, pid []profile.ID) (ProfileList, error)

type ListServicesFunc func(ctx context.Context) ([]string, error)

type MultiWriter struct {
	// contains filtered or unexported fields
}

type ProfileList interface {
	Next() bool
	Profile() (io.Reader, error)
	Close() error
}

type Reader interface {
	FindProfiles(ctx context.Context, params *FindProfilesParams) ([]profile.Meta, error)
	FindProfileIDs(ctx context.Context, params *FindProfilesParams) ([]profile.ID, error)
	ListProfiles(ctx context.Context, pid []profile.ID) (ProfileList, error)
	ListServices(ctx context.Context) ([]string, error)
}

type Storage interface {
	Writer
	Reader
}

type StubReader struct {
	ListServicesFunc
	ListProfilesFunc
	FindProfilesFunc
	FindProfileIDsFunc
}

type StubWriter struct {
	WriteProfileFunc
}

type WriteProfileFunc func(ctx context.Context, params *WriteProfileParams, r io.Reader) (profile.Meta, error)

type WriteProfileParams struct {
	ExternalID profile.ID
	Service    string
	Type       profile.ProfileType
	Labels     profile.Labels
	CreatedAt  time.Time
}

type Writer interface {
	WriteProfile(ctx context.Context, params *WriteProfileParams, r io.Reader) (profile.Meta, error)
}