Skip to content

Commit c7cd6b4

Browse files
committed
removed Create from queueconfig interface
1 parent 9069584 commit c7cd6b4

1 file changed

Lines changed: 0 additions & 7 deletions

File tree

extension/queueconfig/queueconfig.go

Lines changed: 0 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -10,16 +10,9 @@ import (
1010
// ErrNotFound is returned when the requested queue configuration does not exist.
1111
var ErrNotFound = errors.New("queue config not found")
1212

13-
// ErrAlreadyExists is returned when a queue configuration with the same name already exists.
14-
var ErrAlreadyExists = errors.New("queue config already exists")
15-
1613
// Store loads and provides queue configurations.
1714
// Implementations may read from YAML files, databases, remote services, etc.
1815
type Store interface {
19-
// Create adds a new queue configuration.
20-
// Returns ErrAlreadyExists if a configuration with the same name already exists.
21-
Create(ctx context.Context, config entity.QueueConfig) error
22-
2316
// Get returns the configuration for a named queue.
2417
// Returns ErrNotFound if no configuration exists for the given name.
2518
Get(ctx context.Context, name string) (entity.QueueConfig, error)

0 commit comments

Comments
 (0)