jetstream

package
v0.12.1 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Nov 17, 2023 License: Apache-2.0 Imports: 25 Imported by: 0

Documentation

Index

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 (s *JetStreamStore) CreateCluster(_ context.Context, cluster *corev1.Cluster) error

func (*JetStreamStore) CreateRole 

func (s *JetStreamStore) CreateRole(_ context.Context, role *corev1.Role) error

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 (s *JetStreamStore) DeleteCluster(ctx context.Context, ref *corev1.Reference) error

func (*JetStreamStore) DeleteRole 

func (s *JetStreamStore) DeleteRole(_ context.Context, ref *corev1.Reference) error

func (*JetStreamStore) DeleteRoleBinding 

func (s *JetStreamStore) DeleteRoleBinding(_ context.Context, ref *corev1.Reference) error

func (*JetStreamStore) DeleteToken 

func (s *JetStreamStore) DeleteToken(ctx context.Context, ref *corev1.Reference) error

func (*JetStreamStore) GetCluster 

func (s *JetStreamStore) GetCluster(_ context.Context, ref *corev1.Reference) (*corev1.Cluster, error)

func (*JetStreamStore) GetRole 

func (s *JetStreamStore) GetRole(_ context.Context, ref *corev1.Reference) (*corev1.Role, error)

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) ListRoles 

func (s *JetStreamStore) ListRoles(ctx context.Context) (*corev1.RoleList, 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) UpdateRole added in v0.11.0 

func (s *JetStreamStore) UpdateRole(ctx context.Context, ref *corev1.Reference, mutator storage.RoleMutator) (*corev1.Role, error)

func (*JetStreamStore) UpdateRoleBinding added in v0.11.0 

func (s *JetStreamStore) UpdateRoleBinding(ctx context.Context, ref *corev1.Reference, mutator storage.RoleBindingMutator) (*corev1.RoleBinding, 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
}

type Lock added in v0.12.0 

type Lock struct {
	*lock.LockOptions
	// contains filtered or unexported fields
}

func NewLock added in v0.12.0 

func NewLock(js nats.JetStreamContext, key string, options *lock.LockOptions) *Lock

func (*Lock) Lock added in v0.12.0 

func (l *Lock) Lock() error

func (*Lock) Unlock added in v0.12.0 

func (l *Lock) Unlock() error

type LockManager added in v0.12.0 

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

Requires jetstream 2.9+

func NewJetstreamLockManager added in v0.12.0 

func NewJetstreamLockManager(ctx context.Context, conf *v1beta1.JetStreamStorageSpec, opts ...JetStreamStoreOption) (*LockManager, error)

Requires jetstream 2.9+

func (*LockManager) Locker added in v0.12.0 

func (l *LockManager) Locker(key string, opts ...lock.LockOption) storage.Lock

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.