Documentation
¶
Index ¶
- type ExecuteVtctlCommandRequest
- func (*ExecuteVtctlCommandRequest) Descriptor() ([]byte, []int)
- func (m *ExecuteVtctlCommandRequest) GetActionTimeout() int64
- func (m *ExecuteVtctlCommandRequest) GetArgs() []string
- func (*ExecuteVtctlCommandRequest) ProtoMessage()
- func (m *ExecuteVtctlCommandRequest) Reset()
- func (m *ExecuteVtctlCommandRequest) String() string
- func (m *ExecuteVtctlCommandRequest) XXX_DiscardUnknown()
- func (m *ExecuteVtctlCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecuteVtctlCommandRequest) XXX_Merge(src proto.Message)
- func (m *ExecuteVtctlCommandRequest) XXX_Size() int
- func (m *ExecuteVtctlCommandRequest) XXX_Unmarshal(b []byte) error
- type ExecuteVtctlCommandResponse
- func (*ExecuteVtctlCommandResponse) Descriptor() ([]byte, []int)
- func (m *ExecuteVtctlCommandResponse) GetEvent() *logutil.Event
- func (*ExecuteVtctlCommandResponse) ProtoMessage()
- func (m *ExecuteVtctlCommandResponse) Reset()
- func (m *ExecuteVtctlCommandResponse) String() string
- func (m *ExecuteVtctlCommandResponse) XXX_DiscardUnknown()
- func (m *ExecuteVtctlCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *ExecuteVtctlCommandResponse) XXX_Merge(src proto.Message)
- func (m *ExecuteVtctlCommandResponse) XXX_Size() int
- func (m *ExecuteVtctlCommandResponse) XXX_Unmarshal(b []byte) error
- type MaterializeSettings
- func (*MaterializeSettings) Descriptor() ([]byte, []int)
- func (m *MaterializeSettings) GetCell() string
- func (m *MaterializeSettings) GetSourceKeyspace() string
- func (m *MaterializeSettings) GetStopAfterCopy() bool
- func (m *MaterializeSettings) GetTableSettings() []*TableMaterializeSettings
- func (m *MaterializeSettings) GetTabletTypes() string
- func (m *MaterializeSettings) GetTargetKeyspace() string
- func (m *MaterializeSettings) GetWorkflow() string
- func (*MaterializeSettings) ProtoMessage()
- func (m *MaterializeSettings) Reset()
- func (m *MaterializeSettings) String() string
- func (m *MaterializeSettings) XXX_DiscardUnknown()
- func (m *MaterializeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *MaterializeSettings) XXX_Merge(src proto.Message)
- func (m *MaterializeSettings) XXX_Size() int
- func (m *MaterializeSettings) XXX_Unmarshal(b []byte) error
- type TableMaterializeSettings
- func (*TableMaterializeSettings) Descriptor() ([]byte, []int)
- func (m *TableMaterializeSettings) GetCreateDdl() string
- func (m *TableMaterializeSettings) GetSourceExpression() string
- func (m *TableMaterializeSettings) GetTargetTable() string
- func (*TableMaterializeSettings) ProtoMessage()
- func (m *TableMaterializeSettings) Reset()
- func (m *TableMaterializeSettings) String() string
- func (m *TableMaterializeSettings) XXX_DiscardUnknown()
- func (m *TableMaterializeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
- func (m *TableMaterializeSettings) XXX_Merge(src proto.Message)
- func (m *TableMaterializeSettings) XXX_Size() int
- func (m *TableMaterializeSettings) XXX_Unmarshal(b []byte) error
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
This section is empty.
Types ¶
type ExecuteVtctlCommandRequest ¶
type ExecuteVtctlCommandRequest struct {
Args []string `protobuf:"bytes,1,rep,name=args,proto3" json:"args,omitempty"`
ActionTimeout int64 `protobuf:"varint,2,opt,name=action_timeout,json=actionTimeout,proto3" json:"action_timeout,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
ExecuteVtctlCommandRequest is the payload for ExecuteVtctlCommand. timeouts are in nanoseconds.
func (*ExecuteVtctlCommandRequest) Descriptor ¶
func (*ExecuteVtctlCommandRequest) Descriptor() ([]byte, []int)
func (*ExecuteVtctlCommandRequest) GetActionTimeout ¶
func (m *ExecuteVtctlCommandRequest) GetActionTimeout() int64
func (*ExecuteVtctlCommandRequest) GetArgs ¶
func (m *ExecuteVtctlCommandRequest) GetArgs() []string
func (*ExecuteVtctlCommandRequest) ProtoMessage ¶
func (*ExecuteVtctlCommandRequest) ProtoMessage()
func (*ExecuteVtctlCommandRequest) Reset ¶
func (m *ExecuteVtctlCommandRequest) Reset()
func (*ExecuteVtctlCommandRequest) String ¶
func (m *ExecuteVtctlCommandRequest) String() string
func (*ExecuteVtctlCommandRequest) XXX_DiscardUnknown ¶
func (m *ExecuteVtctlCommandRequest) XXX_DiscardUnknown()
func (*ExecuteVtctlCommandRequest) XXX_Marshal ¶
func (m *ExecuteVtctlCommandRequest) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteVtctlCommandRequest) XXX_Merge ¶
func (m *ExecuteVtctlCommandRequest) XXX_Merge(src proto.Message)
func (*ExecuteVtctlCommandRequest) XXX_Size ¶
func (m *ExecuteVtctlCommandRequest) XXX_Size() int
func (*ExecuteVtctlCommandRequest) XXX_Unmarshal ¶
func (m *ExecuteVtctlCommandRequest) XXX_Unmarshal(b []byte) error
type ExecuteVtctlCommandResponse ¶
type ExecuteVtctlCommandResponse struct {
Event *logutil.Event `protobuf:"bytes,1,opt,name=event,proto3" json:"event,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
ExecuteVtctlCommandResponse is streamed back by ExecuteVtctlCommand.
func (*ExecuteVtctlCommandResponse) Descriptor ¶
func (*ExecuteVtctlCommandResponse) Descriptor() ([]byte, []int)
func (*ExecuteVtctlCommandResponse) GetEvent ¶
func (m *ExecuteVtctlCommandResponse) GetEvent() *logutil.Event
func (*ExecuteVtctlCommandResponse) ProtoMessage ¶
func (*ExecuteVtctlCommandResponse) ProtoMessage()
func (*ExecuteVtctlCommandResponse) Reset ¶
func (m *ExecuteVtctlCommandResponse) Reset()
func (*ExecuteVtctlCommandResponse) String ¶
func (m *ExecuteVtctlCommandResponse) String() string
func (*ExecuteVtctlCommandResponse) XXX_DiscardUnknown ¶
func (m *ExecuteVtctlCommandResponse) XXX_DiscardUnknown()
func (*ExecuteVtctlCommandResponse) XXX_Marshal ¶
func (m *ExecuteVtctlCommandResponse) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*ExecuteVtctlCommandResponse) XXX_Merge ¶
func (m *ExecuteVtctlCommandResponse) XXX_Merge(src proto.Message)
func (*ExecuteVtctlCommandResponse) XXX_Size ¶
func (m *ExecuteVtctlCommandResponse) XXX_Size() int
func (*ExecuteVtctlCommandResponse) XXX_Unmarshal ¶
func (m *ExecuteVtctlCommandResponse) XXX_Unmarshal(b []byte) error
type MaterializeSettings ¶
type MaterializeSettings struct {
// workflow is the name of the workflow.
Workflow string `protobuf:"bytes,1,opt,name=workflow,proto3" json:"workflow,omitempty"`
SourceKeyspace string `protobuf:"bytes,2,opt,name=source_keyspace,json=sourceKeyspace,proto3" json:"source_keyspace,omitempty"`
TargetKeyspace string `protobuf:"bytes,3,opt,name=target_keyspace,json=targetKeyspace,proto3" json:"target_keyspace,omitempty"`
// stop_after_copy specifies if vreplication should be stopped after copying.
StopAfterCopy bool `protobuf:"varint,4,opt,name=stop_after_copy,json=stopAfterCopy,proto3" json:"stop_after_copy,omitempty"`
TableSettings []*TableMaterializeSettings `protobuf:"bytes,5,rep,name=table_settings,json=tableSettings,proto3" json:"table_settings,omitempty"`
// optional parameters.
Cell string `protobuf:"bytes,6,opt,name=cell,proto3" json:"cell,omitempty"`
TabletTypes string `protobuf:"bytes,7,opt,name=tablet_types,json=tabletTypes,proto3" json:"tablet_types,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
MaterializeSettings contains the settings for the Materialize command.
func (*MaterializeSettings) Descriptor ¶
func (*MaterializeSettings) Descriptor() ([]byte, []int)
func (*MaterializeSettings) GetCell ¶
func (m *MaterializeSettings) GetCell() string
func (*MaterializeSettings) GetSourceKeyspace ¶
func (m *MaterializeSettings) GetSourceKeyspace() string
func (*MaterializeSettings) GetStopAfterCopy ¶
func (m *MaterializeSettings) GetStopAfterCopy() bool
func (*MaterializeSettings) GetTableSettings ¶
func (m *MaterializeSettings) GetTableSettings() []*TableMaterializeSettings
func (*MaterializeSettings) GetTabletTypes ¶
func (m *MaterializeSettings) GetTabletTypes() string
func (*MaterializeSettings) GetTargetKeyspace ¶
func (m *MaterializeSettings) GetTargetKeyspace() string
func (*MaterializeSettings) GetWorkflow ¶
func (m *MaterializeSettings) GetWorkflow() string
func (*MaterializeSettings) ProtoMessage ¶
func (*MaterializeSettings) ProtoMessage()
func (*MaterializeSettings) Reset ¶
func (m *MaterializeSettings) Reset()
func (*MaterializeSettings) String ¶
func (m *MaterializeSettings) String() string
func (*MaterializeSettings) XXX_DiscardUnknown ¶
func (m *MaterializeSettings) XXX_DiscardUnknown()
func (*MaterializeSettings) XXX_Marshal ¶
func (m *MaterializeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*MaterializeSettings) XXX_Merge ¶
func (m *MaterializeSettings) XXX_Merge(src proto.Message)
func (*MaterializeSettings) XXX_Size ¶
func (m *MaterializeSettings) XXX_Size() int
func (*MaterializeSettings) XXX_Unmarshal ¶
func (m *MaterializeSettings) XXX_Unmarshal(b []byte) error
type TableMaterializeSettings ¶
type TableMaterializeSettings struct {
TargetTable string `protobuf:"bytes,1,opt,name=target_table,json=targetTable,proto3" json:"target_table,omitempty"`
// source_expression is a select statement.
SourceExpression string `protobuf:"bytes,2,opt,name=source_expression,json=sourceExpression,proto3" json:"source_expression,omitempty"`
// create_ddl contains the DDL to create the target table.
// If empty, the target table must already exist.
// if "copy", the target table DDL is the same as the source table.
CreateDdl string `protobuf:"bytes,3,opt,name=create_ddl,json=createDdl,proto3" json:"create_ddl,omitempty"`
XXX_NoUnkeyedLiteral struct{} `json:"-"`
XXX_unrecognized []byte `json:"-"`
XXX_sizecache int32 `json:"-"`
}
TableMaterializeSttings contains the settings for one table.
func (*TableMaterializeSettings) Descriptor ¶
func (*TableMaterializeSettings) Descriptor() ([]byte, []int)
func (*TableMaterializeSettings) GetCreateDdl ¶
func (m *TableMaterializeSettings) GetCreateDdl() string
func (*TableMaterializeSettings) GetSourceExpression ¶
func (m *TableMaterializeSettings) GetSourceExpression() string
func (*TableMaterializeSettings) GetTargetTable ¶
func (m *TableMaterializeSettings) GetTargetTable() string
func (*TableMaterializeSettings) ProtoMessage ¶
func (*TableMaterializeSettings) ProtoMessage()
func (*TableMaterializeSettings) Reset ¶
func (m *TableMaterializeSettings) Reset()
func (*TableMaterializeSettings) String ¶
func (m *TableMaterializeSettings) String() string
func (*TableMaterializeSettings) XXX_DiscardUnknown ¶
func (m *TableMaterializeSettings) XXX_DiscardUnknown()
func (*TableMaterializeSettings) XXX_Marshal ¶
func (m *TableMaterializeSettings) XXX_Marshal(b []byte, deterministic bool) ([]byte, error)
func (*TableMaterializeSettings) XXX_Merge ¶
func (m *TableMaterializeSettings) XXX_Merge(src proto.Message)
func (*TableMaterializeSettings) XXX_Size ¶
func (m *TableMaterializeSettings) XXX_Size() int
func (*TableMaterializeSettings) XXX_Unmarshal ¶
func (m *TableMaterializeSettings) XXX_Unmarshal(b []byte) error
Click to show internal directories.
Click to hide internal directories.