Documentation ¶
Index ¶
- type JetStreamStore
- func (s *JetStreamStore) CreateCluster(_ context.Context, cluster *corev1.Cluster) error
- func (s *JetStreamStore) CreateRole(_ context.Context, role *corev1.Role) error
- func (s *JetStreamStore) CreateRoleBinding(_ context.Context, rb *corev1.RoleBinding) error
- func (s *JetStreamStore) CreateToken(_ context.Context, ttl time.Duration, opts ...storage.TokenCreateOption) (*corev1.BootstrapToken, error)
- func (s *JetStreamStore) DeleteCluster(ctx context.Context, ref *corev1.Reference) error
- func (s *JetStreamStore) DeleteRole(_ context.Context, ref *corev1.Reference) error
- func (s *JetStreamStore) DeleteRoleBinding(_ context.Context, ref *corev1.Reference) error
- func (s *JetStreamStore) DeleteToken(ctx context.Context, ref *corev1.Reference) error
- func (s *JetStreamStore) GetCluster(_ context.Context, ref *corev1.Reference) (*corev1.Cluster, error)
- func (s *JetStreamStore) GetRole(_ context.Context, ref *corev1.Reference) (*corev1.Role, error)
- func (s *JetStreamStore) GetRoleBinding(ctx context.Context, ref *corev1.Reference) (*corev1.RoleBinding, error)
- func (s *JetStreamStore) GetToken(_ context.Context, ref *corev1.Reference) (*corev1.BootstrapToken, error)
- func (s *JetStreamStore) KeyValueStore(prefix string) storage.KeyValueStore
- func (s *JetStreamStore) KeyringStore(prefix string, ref *corev1.Reference) storage.KeyringStore
- func (s *JetStreamStore) ListClusters(ctx context.Context, matchLabels *corev1.LabelSelector, ...) (*corev1.ClusterList, error)
- func (s *JetStreamStore) ListRoleBindings(ctx context.Context) (*corev1.RoleBindingList, error)
- func (s *JetStreamStore) ListRoles(ctx context.Context) (*corev1.RoleList, error)
- func (s *JetStreamStore) ListTokens(ctx context.Context) ([]*corev1.BootstrapToken, error)
- func (s *JetStreamStore) UpdateCluster(ctx context.Context, ref *corev1.Reference, mutator storage.ClusterMutator) (*corev1.Cluster, error)
- func (s *JetStreamStore) UpdateToken(ctx context.Context, ref *corev1.Reference, mutator storage.TokenMutator) (*corev1.BootstrapToken, error)
- func (s *JetStreamStore) WatchCluster(ctx context.Context, cluster *corev1.Cluster) (<-chan storage.WatchEvent[*corev1.Cluster], error)
- func (s *JetStreamStore) WatchClusters(ctx context.Context, knownClusters []*corev1.Cluster) (<-chan storage.WatchEvent[*corev1.Cluster], error)
- type JetStreamStoreOption
- type JetStreamStoreOptions
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type JetStreamStore ¶
type JetStreamStore struct { JetStreamStoreOptions // contains filtered or unexported fields }
func NewJetStreamStore ¶
func NewJetStreamStore(ctx context.Context, conf *v1beta1.JetStreamStorageSpec, opts ...JetStreamStoreOption) (*JetStreamStore, error)
func (*JetStreamStore) CreateCluster ¶
func (*JetStreamStore) CreateRole ¶
func (*JetStreamStore) CreateRoleBinding ¶
func (s *JetStreamStore) CreateRoleBinding(_ context.Context, rb *corev1.RoleBinding) error
func (*JetStreamStore) CreateToken ¶
func (s *JetStreamStore) CreateToken(_ context.Context, ttl time.Duration, opts ...storage.TokenCreateOption) (*corev1.BootstrapToken, error)
func (*JetStreamStore) DeleteCluster ¶
func (*JetStreamStore) DeleteRole ¶
func (*JetStreamStore) DeleteRoleBinding ¶
func (*JetStreamStore) DeleteToken ¶
func (*JetStreamStore) GetCluster ¶
func (*JetStreamStore) GetRoleBinding ¶
func (s *JetStreamStore) GetRoleBinding(ctx context.Context, ref *corev1.Reference) (*corev1.RoleBinding, error)
func (*JetStreamStore) GetToken ¶
func (s *JetStreamStore) GetToken(_ context.Context, ref *corev1.Reference) (*corev1.BootstrapToken, error)
func (*JetStreamStore) KeyValueStore ¶
func (s *JetStreamStore) KeyValueStore(prefix string) storage.KeyValueStore
func (*JetStreamStore) KeyringStore ¶
func (s *JetStreamStore) KeyringStore(prefix string, ref *corev1.Reference) storage.KeyringStore
func (*JetStreamStore) ListClusters ¶
func (s *JetStreamStore) ListClusters(ctx context.Context, matchLabels *corev1.LabelSelector, matchOptions corev1.MatchOptions) (*corev1.ClusterList, error)
func (*JetStreamStore) ListRoleBindings ¶
func (s *JetStreamStore) ListRoleBindings(ctx context.Context) (*corev1.RoleBindingList, error)
func (*JetStreamStore) ListTokens ¶
func (s *JetStreamStore) ListTokens(ctx context.Context) ([]*corev1.BootstrapToken, error)
func (*JetStreamStore) UpdateCluster ¶
func (s *JetStreamStore) UpdateCluster(ctx context.Context, ref *corev1.Reference, mutator storage.ClusterMutator) (*corev1.Cluster, error)
func (*JetStreamStore) UpdateToken ¶
func (s *JetStreamStore) UpdateToken(ctx context.Context, ref *corev1.Reference, mutator storage.TokenMutator) (*corev1.BootstrapToken, error)
func (*JetStreamStore) WatchCluster ¶
func (s *JetStreamStore) WatchCluster(ctx context.Context, cluster *corev1.Cluster) (<-chan storage.WatchEvent[*corev1.Cluster], error)
func (*JetStreamStore) WatchClusters ¶
func (s *JetStreamStore) WatchClusters(ctx context.Context, knownClusters []*corev1.Cluster) (<-chan storage.WatchEvent[*corev1.Cluster], error)
type JetStreamStoreOption ¶
type JetStreamStoreOption func(*JetStreamStoreOptions)
func WithBucketPrefix ¶ added in v0.9.2
func WithBucketPrefix(prefix string) JetStreamStoreOption
type JetStreamStoreOptions ¶
type JetStreamStoreOptions struct {
BucketPrefix string
}
Click to show internal directories.
Click to hide internal directories.