Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security Policy
  
  How Go can help keep you secure by default
Learn
Docs
- Effective Go
  
  Tips for writing clear, performant, and idiomatic Go code
- Go User Manual
  
  A complete introduction to building software with Go
- Standard library
  
  Reference documentation for Go's standard library
- Release Notes
  
  Learn what's new in each Go release
Packages
Community
- Recorded Talks
  
  Videos from prior events
- Meetups
  
  Meet other local Go developers
- Conferences
  
  Learn and network with Go developers from around the world
- Go blog
  
  The Go project's official blog.
- Go project
  
  Get help and stay informed from Go
- Get connected

etcd

package

Go to main page

Versions in this module

v1

v1.2.1

Feb 11, 2022

Changes in this version

+ const CacheDynamicPrefix

+ const CreateDynamic

+ const DeleteDynamic

+ const ResumeDynamic

+ const ResumeRelay

+ const StopDynamic

+ const StopRelay

+ const UpdateDynamic

type Etcd

+ Actions *actions.Actions

+ PersistentConfig *config.Config

+ func (e *Etcd) PublishCreateDynamic(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

+ func (e *Etcd) PublishDeleteDynamic(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

+ func (e *Etcd) PublishResumeDynamic(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

+ func (e *Etcd) PublishResumeRelay(ctx context.Context, relay *opts.RelayOptions) error

+ func (e *Etcd) PublishStopDynamic(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

+ func (e *Etcd) PublishStopRelay(ctx context.Context, relay *opts.RelayOptions) error

+ func (e *Etcd) PublishUpdateDynamic(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

type IEtcd

+ PublishCreateDynamic func(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

+ PublishDeleteDynamic func(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

+ PublishResumeDynamic func(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

+ PublishResumeRelay func(ctx context.Context, relay *opts.RelayOptions) error

+ PublishStopDynamic func(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

+ PublishStopRelay func(ctx context.Context, relay *opts.RelayOptions) error

+ PublishUpdateDynamic func(ctx context.Context, dynamicOptions *opts.DynamicOptions) error

v1.2.0

Jan 26, 2022

v1.1.2

Jan 4, 2022

v1.1.1

Jan 3, 2022

v1.1.0

Dec 30, 2021

v1.0.5

Dec 20, 2021

v1.0.4

Dec 18, 2021

v1.0.3

Dec 15, 2021

v1.0.2

Dec 13, 2021

v1.0.1

Dec 13, 2021

v1.0.0

Dec 6, 2021

Changes in this version

+ const BroadcastPath

+ const CacheCompositesPrefix

+ const CacheConnectionsPrefix

+ const CacheErrorsPrefix

+ const CacheReadsPrefix

+ const CacheRelaysPrefix

+ const CacheSchemasPrefix

+ const CacheServerConfigKey

+ const CacheServicesPrefix

+ const CacheValidationsPrefix

+ const CreateComposite

+ const CreateConnection

+ const CreateRead

+ const CreateRelay

+ const CreateSchema

+ const CreateService

+ const CreateValidation

+ const DeleteComposite

+ const DeleteConnection

+ const DeleteRead

+ const DeleteRelay

+ const DeleteSchema

+ const DeleteService

+ const DeleteValidation

+ const QueuePath

+ const UpdateComposite

+ const UpdateConfig

+ const UpdateConnection

+ const UpdateRelay

+ const UpdateSchema

+ const UpdateService

+ const UpdateValidation

+ var ErrMissingConfigMessage = errors.New("msg cannot be nil")

+ var ErrMissingGithubToken = errors.New("GithubToken cannot be empty")

+ var ErrMissingVCServiceToken = errors.New("VCServiceToken cannot be empty")

+ var ServerAlreadyStartedErr = errors.New("server already started")

+ var ServerNotStartedErr = errors.New("server not started")

+ var ValidActions = []Action

+ type Action string

+ type Etcd struct

+ PlumberConfig *config.Config

+ func New(serverOptions *opts.ServerOptions, plumberConfig *config.Config) (*Etcd, error)

+ func (e *Etcd) Broadcast(ctx context.Context, msg *Message) error

+ func (e *Etcd) Client() *clientv3.Client

+ func (e *Etcd) Delete(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error)

+ func (e *Etcd) Direct(ctx context.Context, node string, msg *Message) error

+ func (e *Etcd) Get(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)

+ func (e *Etcd) GrantLease(ctx context.Context, ttl int64) (*clientv3.LeaseGrantResponse, error)

+ func (e *Etcd) PopulateCache() error

+ func (e *Etcd) PublishConfigUpdate(ctx context.Context, msg *MessageUpdateConfig) error

+ func (e *Etcd) PublishCreateComposite(ctx context.Context, comp *opts.Composite) error

+ func (e *Etcd) PublishCreateConnection(ctx context.Context, conn *opts.ConnectionOptions) error

+ func (e *Etcd) PublishCreateRead(ctx context.Context, read *opts.ReadOptions) error

+ func (e *Etcd) PublishCreateRelay(ctx context.Context, relay *opts.RelayOptions) error

+ func (e *Etcd) PublishCreateSchema(ctx context.Context, schema *protos.Schema) error

+ func (e *Etcd) PublishCreateService(ctx context.Context, svc *protos.Service) error

+ func (e *Etcd) PublishCreateValidation(ctx context.Context, validation *common.Validation) error

+ func (e *Etcd) PublishDeleteComposite(ctx context.Context, comp *opts.Composite) error

+ func (e *Etcd) PublishDeleteConnection(ctx context.Context, conn *opts.ConnectionOptions) error

+ func (e *Etcd) PublishDeleteRead(ctx context.Context, read *opts.ReadOptions) error

+ func (e *Etcd) PublishDeleteRelay(ctx context.Context, relay *opts.RelayOptions) error

+ func (e *Etcd) PublishDeleteSchema(ctx context.Context, schema *protos.Schema) error

+ func (e *Etcd) PublishDeleteService(ctx context.Context, svc *protos.Service) error

+ func (e *Etcd) PublishDeleteValidation(ctx context.Context, validation *common.Validation) error

+ func (e *Etcd) PublishUpdateComposite(ctx context.Context, comp *opts.Composite) error

+ func (e *Etcd) PublishUpdateConnection(ctx context.Context, conn *opts.ConnectionOptions) error

+ func (e *Etcd) PublishUpdateRelay(ctx context.Context, relay *opts.RelayOptions) error

+ func (e *Etcd) PublishUpdateSchema(ctx context.Context, schema *protos.Schema) error

+ func (e *Etcd) PublishUpdateService(ctx context.Context, svc *protos.Service) error

+ func (e *Etcd) PublishUpdateValidation(ctx context.Context, validation *common.Validation) error

+ func (e *Etcd) Put(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)

+ func (e *Etcd) PutWithTTL(ctx context.Context, key, val string, expires time.Duration) (*clientv3.PutResponse, error)

+ func (e *Etcd) SaveConfig(ctx context.Context, cfg *config.Config) error

+ func (e *Etcd) Shutdown(force bool) error

+ func (e *Etcd) Start(serviceCtx context.Context) error

+ type HandlerFunc func(context.Context, *clientv3.WatchResponse) error

+ type IEtcd interface

+ Broadcast func(ctx context.Context, msg *Message) error

+ Client func() *clientv3.Client

+ Delete func(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.DeleteResponse, error)

+ Direct func(ctx context.Context, node string, msg *Message) error

+ Get func(ctx context.Context, key string, opts ...clientv3.OpOption) (*clientv3.GetResponse, error)

+ GrantLease func(ctx context.Context, ttl int64) (*clientv3.LeaseGrantResponse, error)

+ PublishConfigUpdate func(ctx context.Context, msg *MessageUpdateConfig) error

+ PublishCreateComposite func(ctx context.Context, validation *opts.Composite) error

+ PublishCreateConnection func(ctx context.Context, conn *opts.ConnectionOptions) error

+ PublishCreateRead func(ctx context.Context, svc *opts.ReadOptions) error

+ PublishCreateRelay func(ctx context.Context, relay *opts.RelayOptions) error

+ PublishCreateSchema func(ctx context.Context, schema *protos.Schema) error

+ PublishCreateService func(ctx context.Context, svc *protos.Service) error

+ PublishCreateValidation func(ctx context.Context, validation *common.Validation) error

+ PublishDeleteComposite func(ctx context.Context, validation *opts.Composite) error

+ PublishDeleteConnection func(ctx context.Context, conn *opts.ConnectionOptions) error

+ PublishDeleteRead func(ctx context.Context, svc *opts.ReadOptions) error

+ PublishDeleteRelay func(ctx context.Context, relay *opts.RelayOptions) error

+ PublishDeleteSchema func(ctx context.Context, schema *protos.Schema) error

+ PublishDeleteService func(ctx context.Context, svc *protos.Service) error

+ PublishDeleteValidation func(ctx context.Context, validation *common.Validation) error

+ PublishUpdateComposite func(ctx context.Context, validation *opts.Composite) error

+ PublishUpdateConnection func(ctx context.Context, conn *opts.ConnectionOptions) error

+ PublishUpdateRelay func(ctx context.Context, relay *opts.RelayOptions) error

+ PublishUpdateSchema func(ctx context.Context, schema *protos.Schema) error

+ PublishUpdateService func(ctx context.Context, svc *protos.Service) error

+ PublishUpdateValidation func(ctx context.Context, validation *common.Validation) error

+ Put func(ctx context.Context, key, val string, opts ...clientv3.OpOption) (*clientv3.PutResponse, error)

+ PutWithTTL func(ctx context.Context, key, val string, expires time.Duration) (*clientv3.PutResponse, error)

+ SaveConfig func(ctx context.Context, cfg *config.Config) error

+ Shutdown func(force bool) error

+ Start func(serviceCtx context.Context) error

+ type Message struct

+ Action Action

+ Data []byte

+ EmittedAt time.Time

+ EmittedBy string

+ Metadata map[string]string

+ func (m *Message) Validate() error

+ type MessageUpdateConfig struct

+ GithubToken string

+ VCServiceToken string