GO-2025-3921: Coder accepts an APIKey beyond the linked OIDC expiry if there is no refresh token in github.com/coder/coder

replicasync

package

v2.1.2 Latest Latest Go to latest Published: Aug 23, 2023 License: AGPL-3.0 Imports: 17 Imported by: 0

Details

Valid go.mod file
Redistributable license
Tagged version
Stable version
Learn more about best practices

Repository

github.com/coder/coder

Links

Open Source Insights

Documentation ¶

Index ¶

Variables
type Manager
- func New(ctx context.Context, logger slog.Logger, db database.Store, ps pubsub.Pubsub, ...) (*Manager, error)
type Options

Constants ¶

This section is empty.

Variables ¶

View Source

var PubsubEvent = "replica"

Functions ¶

This section is empty.

Types ¶

type Manager ¶

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

Manager keeps the replica up to date and in sync with other replicas.

func New ¶

func New(ctx context.Context, logger slog.Logger, db database.Store, ps pubsub.Pubsub, options *Options) (*Manager, error)

New registers the replica with the database and periodically updates to ensure it's healthy. It contacts all other alive replicas to ensure they are reachable.

func (*Manager) AllPrimary ¶

func (m *Manager) AllPrimary() []database.Replica

AllPrimary returns every primary replica (not workspace proxy replicas), including itself.

func (*Manager) Close ¶

func (m *Manager) Close() error

func (*Manager) ID ¶

func (m *Manager) ID() uuid.UUID

func (*Manager) InRegion ¶

func (m *Manager) InRegion(regionID int32) []database.Replica

InRegion returns every replica in the given DERP region excluding itself.

func (*Manager) PublishUpdate ¶

func (m *Manager) PublishUpdate() error

PublishUpdate notifies all other replicas to update.

func (*Manager) Regional ¶

func (m *Manager) Regional() []database.Replica

Regional returns all replicas in the same region excluding itself.

func (*Manager) Self ¶

func (m *Manager) Self() database.Replica

Self represents the current replica.

func (*Manager) SetCallback ¶

func (m *Manager) SetCallback(callback func())

SetCallback sets a function to execute whenever new peers are refreshed or updated.

func (*Manager) UpdateNow ¶

func (m *Manager) UpdateNow(ctx context.Context) error

UpdateNow synchronously updates replicas.

type Options ¶

type Options struct {
	ID              uuid.UUID
	CleanupInterval time.Duration
	UpdateInterval  time.Duration
	PeerTimeout     time.Duration
	RelayAddress    string
	RegionID        int32
	TLSConfig       *tls.Config
}

Source Files ¶

View all Source files

replicasync.go

?	: This menu
/	: Search site
f or F	: Jump to
y or Y	: Canonical URL