Documentation
¶
Overview ¶
Copyright © 2021 Yugabyte Support
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Copyright © 2021 Yugabyte Support ¶
Licensed under the Apache License, Version 2.0 (the "License"); you may not use this file except in compliance with the License. You may obtain a copy of the License at
http://www.apache.org/licenses/LICENSE-2.0
Unless required by applicable law or agreed to in writing, software distributed under the License is distributed on an "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. See the License for the specific language governing permissions and limitations under the License.
Index ¶
Constants ¶
This section is empty.
Variables ¶
This section is empty.
Functions ¶
func InitConsumerCmd ¶
func InitConsumerCmd(ctx *cmdutil.YugatoolContext) *cobra.Command
func InitProducerCmd ¶
func InitProducerCmd(ctx *cmdutil.YugatoolContext) *cobra.Command
func StreamInfoCmd ¶
func StreamInfoCmd(ctx *cmdutil.YugatoolContext) *cobra.Command
Types ¶
type ClusterInfoOptions ¶
type ClusterInfoOptions struct {
GetLastUpdated bool
}
func (*ClusterInfoOptions) AddFlags ¶
func (o *ClusterInfoOptions) AddFlags(cmd *cobra.Command)
func (*ClusterInfoOptions) Validate ¶
func (o *ClusterInfoOptions) Validate() error
type InitConsumerOptions ¶
type InitConsumerOptions struct {
KeyspaceName string `mapstructure:"keyspace"`
SkipBootstraps bool `mapstructure:"skip_bootstraps"`
BatchSize int `mapstructure:"batch_size"`
}
func (*InitConsumerOptions) AddFlags ¶
func (o *InitConsumerOptions) AddFlags(cmd *cobra.Command)
func (*InitConsumerOptions) Validate ¶
func (o *InitConsumerOptions) Validate() error
type InitProducerOptions ¶
type InitProducerOptions struct {
KeyspaceName string `mapstructure:"keyspace"`
BatchSize int `mapstructure:"batch_size"`
}
func (*InitProducerOptions) AddFlags ¶
func (o *InitProducerOptions) AddFlags(cmd *cobra.Command)
func (*InitProducerOptions) Validate ¶
func (o *InitProducerOptions) Validate() error
Source Files