seaweedfs/weed/credential/memory/memory_group.go

package memory

import (
	"context"

	"github.com/seaweedfs/seaweedfs/weed/credential"
	"github.com/seaweedfs/seaweedfs/weed/pb/iam_pb"
)

func (store *MemoryStore) CreateGroup(ctx context.Context, group *iam_pb.Group) error {
	store.mu.Lock()
	defer store.mu.Unlock()

	if _, exists := store.groups[group.Name]; exists {
		return credential.ErrGroupAlreadyExists
	}
	store.groups[group.Name] = group
	return nil
}

func (store *MemoryStore) GetGroup(ctx context.Context, groupName string) (*iam_pb.Group, error) {
	store.mu.RLock()
	defer store.mu.RUnlock()

	if g, exists := store.groups[groupName]; exists {
		return g, nil
	}
	return nil, credential.ErrGroupNotFound
}

func (store *MemoryStore) DeleteGroup(ctx context.Context, groupName string) error {
	store.mu.Lock()
	defer store.mu.Unlock()

	if _, exists := store.groups[groupName]; !exists {
		return credential.ErrGroupNotFound
	}
	delete(store.groups, groupName)
	return nil
}

func (store *MemoryStore) ListGroups(ctx context.Context) ([]string, error) {
	store.mu.RLock()
	defer store.mu.RUnlock()

	var names []string
	for name := range store.groups {
		names = append(names, name)
	}
	return names, nil
}

func (store *MemoryStore) UpdateGroup(ctx context.Context, group *iam_pb.Group) error {
	store.mu.Lock()
	defer store.mu.Unlock()

	if _, exists := store.groups[group.Name]; !exists {
		return credential.ErrGroupNotFound
	}
	store.groups[group.Name] = group
	return nil
}