Why Go
- Case Studies
  
  Common problems companies solve with Go
- Use Cases
  
  Stories about how and why companies use Go
- Security
  
  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

migration

package

Go to main page

Versions in this module

v0

v0.0.7

Apr 16, 2018

Changes in this version

+ var HealthCheckResponse_Status_name = map[int32]string

+ var HealthCheckResponse_Status_value = map[string]int32

+ func NewMigration(cfg MigrationConfig) *migration

+ func NewServer(options ...func(*migrationServer)) *migrationServer

+ func RegisterMigrationServer(s *grpc.Server, srv MigrationServer)

+ func WithClock(c clock) func(*migrationServer)

+ func WithPGBouncer(bouncer pgBouncerPauser) func(*migrationServer)

+ func WithPacemaker(c crm) func(*migrationServer)

+ func WithServerLogger(logger *logrus.Logger) func(*migrationServer)

+ type Empty struct

+ func (*Empty) Descriptor() ([]byte, []int)

+ func (*Empty) ProtoMessage()

+ func (m *Empty) Reset()

+ func (m *Empty) String() string

+ type HealthCheckResponse struct

+ Status HealthCheckResponse_Status

+ func (*HealthCheckResponse) Descriptor() ([]byte, []int)

+ func (*HealthCheckResponse) ProtoMessage()

+ func (m *HealthCheckResponse) GetStatus() HealthCheckResponse_Status

+ func (m *HealthCheckResponse) Reset()

+ func (m *HealthCheckResponse) String() string

+ type HealthCheckResponse_Status int32

+ const HealthCheckResponse_HEALTHY

+ const HealthCheckResponse_UNHEALTHY

+ const HealthCheckResponse_UNKNOWN

+ func (HealthCheckResponse_Status) EnumDescriptor() ([]byte, []int)

+ func (x HealthCheckResponse_Status) String() string

+ type MigrateResponse struct

+ Address string

+ CreatedAt *google_protobuf.Timestamp

+ MigratingTo string

+ func (*MigrateResponse) Descriptor() ([]byte, []int)

+ func (*MigrateResponse) ProtoMessage()

+ func (m *MigrateResponse) GetAddress() string

+ func (m *MigrateResponse) GetCreatedAt() *google_protobuf.Timestamp

+ func (m *MigrateResponse) GetMigratingTo() string

+ func (m *MigrateResponse) Reset()

+ func (m *MigrateResponse) String() string

+ type MigrationClient interface

+ HealthCheck func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*HealthCheckResponse, error)

+ Migrate func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*MigrateResponse, error)

+ Pause func(ctx context.Context, in *PauseRequest, opts ...grpc.CallOption) (*PauseResponse, error)

+ Resume func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*ResumeResponse, error)

+ Unmigrate func(ctx context.Context, in *Empty, opts ...grpc.CallOption) (*UnmigrateResponse, error)

+ func NewMigrationClient(cc *grpc.ClientConn) MigrationClient

+ type MigrationConfig struct

+ Clients []MigrationClient

+ Etcd etcdClient

+ EtcdMasterKey string

+ HealthCheckTimeout time.Duration

+ LockTimeout time.Duration

+ Locker locker

+ PacemakerTimeout time.Duration

+ PauseExpiry time.Duration

+ PauseTimeout time.Duration

+ type MigrationServer interface

+ HealthCheck func(context.Context, *Empty) (*HealthCheckResponse, error)

+ Migrate func(context.Context, *Empty) (*MigrateResponse, error)

+ Pause func(context.Context, *PauseRequest) (*PauseResponse, error)

+ Resume func(context.Context, *Empty) (*ResumeResponse, error)

+ Unmigrate func(context.Context, *Empty) (*UnmigrateResponse, error)

+ type PauseRequest struct

+ Expiry int32

+ Timeout int32

+ func (*PauseRequest) Descriptor() ([]byte, []int)

+ func (*PauseRequest) ProtoMessage()

+ func (m *PauseRequest) GetExpiry() int32

+ func (m *PauseRequest) GetTimeout() int32

+ func (m *PauseRequest) Reset()

+ func (m *PauseRequest) String() string

+ type PauseResponse struct

+ CreatedAt *google_protobuf.Timestamp

+ ExpiresAt *google_protobuf.Timestamp

+ func (*PauseResponse) Descriptor() ([]byte, []int)

+ func (*PauseResponse) ProtoMessage()

+ func (m *PauseResponse) GetCreatedAt() *google_protobuf.Timestamp

+ func (m *PauseResponse) GetExpiresAt() *google_protobuf.Timestamp

+ func (m *PauseResponse) Reset()

+ func (m *PauseResponse) String() string

+ type ResumeResponse struct

+ CreatedAt *google_protobuf.Timestamp

+ func (*ResumeResponse) Descriptor() ([]byte, []int)

+ func (*ResumeResponse) ProtoMessage()

+ func (m *ResumeResponse) GetCreatedAt() *google_protobuf.Timestamp

+ func (m *ResumeResponse) Reset()

+ func (m *ResumeResponse) String() string

+ type UnmigrateResponse struct

+ CreatedAt *google_protobuf.Timestamp

+ func (*UnmigrateResponse) Descriptor() ([]byte, []int)

+ func (*UnmigrateResponse) ProtoMessage()

+ func (m *UnmigrateResponse) GetCreatedAt() *google_protobuf.Timestamp

+ func (m *UnmigrateResponse) Reset()

+ func (m *UnmigrateResponse) String() string

v0.0.6

Dec 5, 2017

v0.0.5

Nov 30, 2017

v0.0.4

Nov 30, 2017

v0.0.3

Nov 14, 2017

v0.0.2

Nov 7, 2017