consume

package
v0.0.17 Latest Latest
Warning

This package is not in the latest version of its module.

 Go to latest Published: Dec 16, 2024 License: Apache-2.0 Imports: 6 Imported by: 0

Documentation

Overview

Copyright © 2020 Marvin

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 © 2020 Marvin

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 © 2020 Marvin

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

This section is empty.

Types

type IMsgDdlRewrite 

type IMsgDdlRewrite interface {
	CreateMsgDdlRewrite(ctx context.Context, data *MsgDdlRewrite) (*MsgDdlRewrite, error)
	ListMsgDdlRewrite(ctx context.Context, page uint64, pageSize uint64) ([]*MsgDdlRewrite, error)
	QueryMsgDdlRewrite(ctx context.Context, data *MsgDdlRewrite) ([]*MsgDdlRewrite, error)
	GetMsgDdlRewrite(ctx context.Context, data *MsgDdlRewrite) (*MsgDdlRewrite, error)
	DeleteMsgDdlRewrite(ctx context.Context, taskName []string) error
}

type IMsgTopicPartition 

type IMsgTopicPartition interface {
	CreateMsgTopicPartition(ctx context.Context, data *MsgTopicPartition) (*MsgTopicPartition, error)
	ListMsgTopicPartition(ctx context.Context, page uint64, pageSize uint64) ([]*MsgTopicPartition, error)
	GetMsgTopicPartition(ctx context.Context, data *MsgTopicPartition) (*MsgTopicPartition, error)
	CountMsgTopicPartition(ctx context.Context, data *MsgTopicPartition) (int, error)
	DeleteMsgTopicPartition(ctx context.Context, taskName []string) error
	UpdateMsgTopicPartition(ctx context.Context, data *MsgTopicPartition, updates map[string]interface{}) error
}

type MsgDdlRewrite 

type MsgDdlRewrite struct {
	ID             uint64 `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName       string `gorm:"type:varchar(30);not null;uniqueIndex:uniq_task_topic_complex;comment:task name" json:"taskName"`
	Topic          string `gorm:"type:varchar(100);not null;uniqueIndex:uniq_task_topic_complex;comment:subscribe topic name" json:"topic"`
	DdlDigest      string `gorm:"type:varchar(300);not null;uniqueIndex:uniq_task_topic_complex;comment:subscribe topic ddl digest" json:"ddlDigest"`
	OriginDdlText  string `gorm:"type:longtext;not null;comment:subscribe topic origin ddl text" json:"originDdlText"`
	RewriteDdlText string `gorm:"type:longtext;not null;comment:subscribe topic rewrite ddl text" json:"rewriteDdlText"`
	*common.Entity
}

type MsgTopicPartition 

type MsgTopicPartition struct {
	ID         uint64 `gorm:"primary_key;autoIncrement;comment:id" json:"id"`
	TaskName   string `gorm:"type:varchar(30);not null;uniqueIndex:uniq_task_topic_complex;comment:task name" json:"taskName"`
	Topic      string `gorm:"type:varchar(100);not null;uniqueIndex:uniq_task_topic_complex;comment:subscribe topic name" json:"topic"`
	Partitions int    `gorm:"type:bigint;not null;uniqueIndex:uniq_task_topic_complex;comment:subscribe topic partiton number" json:"partitions"`
	Replicas   int    `gorm:"type:int;not null;comment:subscribe topic partiton replicas" json:"replicas"`
	Checkpoint uint64 `gorm:"type:bigint;not null;default 0;comment:subscribe topic partiton consume checkpoint" json:"checkpoint"`
	Offset     int64  `gorm:"type:bigint;not null;default 0;comment:subscribe topic partiton consume message offset" json:"offset"`
	*common.Entity
}

type RWMsgDdlRewrite 

type RWMsgDdlRewrite struct {
	common.GormDB
}

func NewMsgDdlRewriteRW 

func NewMsgDdlRewriteRW(db *gorm.DB) *RWMsgDdlRewrite

func (*RWMsgDdlRewrite) CreateMsgDdlRewrite 

func (rw *RWMsgDdlRewrite) CreateMsgDdlRewrite(ctx context.Context, data *MsgDdlRewrite) (*MsgDdlRewrite, error)

func (*RWMsgDdlRewrite) DeleteMsgDdlRewrite 

func (rw *RWMsgDdlRewrite) DeleteMsgDdlRewrite(ctx context.Context, taskName []string) error

func (*RWMsgDdlRewrite) GetMsgDdlRewrite 

func (rw *RWMsgDdlRewrite) GetMsgDdlRewrite(ctx context.Context, data *MsgDdlRewrite) (*MsgDdlRewrite, error)

func (*RWMsgDdlRewrite) ListMsgDdlRewrite 

func (rw *RWMsgDdlRewrite) ListMsgDdlRewrite(ctx context.Context, page uint64, pageSize uint64) ([]*MsgDdlRewrite, error)

func (*RWMsgDdlRewrite) QueryMsgDdlRewrite 

func (rw *RWMsgDdlRewrite) QueryMsgDdlRewrite(ctx context.Context, data *MsgDdlRewrite) ([]*MsgDdlRewrite, error)

func (*RWMsgDdlRewrite) TableName 

func (rw *RWMsgDdlRewrite) TableName(ctx context.Context) string

type RWMsgTopicPartition 

type RWMsgTopicPartition struct {
	common.GormDB
}

func NewMsgTopicPartitionRW 

func NewMsgTopicPartitionRW(db *gorm.DB) *RWMsgTopicPartition

func (*RWMsgTopicPartition) CountMsgTopicPartition 

func (rw *RWMsgTopicPartition) CountMsgTopicPartition(ctx context.Context, data *MsgTopicPartition) (int, error)

func (*RWMsgTopicPartition) CreateMsgTopicPartition 

func (rw *RWMsgTopicPartition) CreateMsgTopicPartition(ctx context.Context, data *MsgTopicPartition) (*MsgTopicPartition, error)

func (*RWMsgTopicPartition) DeleteMsgTopicPartition 

func (rw *RWMsgTopicPartition) DeleteMsgTopicPartition(ctx context.Context, taskName []string) error

func (*RWMsgTopicPartition) GetMsgTopicPartition 

func (rw *RWMsgTopicPartition) GetMsgTopicPartition(ctx context.Context, data *MsgTopicPartition) (*MsgTopicPartition, error)

func (*RWMsgTopicPartition) ListMsgTopicPartition 

func (rw *RWMsgTopicPartition) ListMsgTopicPartition(ctx context.Context, page uint64, pageSize uint64) ([]*MsgTopicPartition, error)

func (*RWMsgTopicPartition) TableName 

func (rw *RWMsgTopicPartition) TableName(ctx context.Context) string

func (*RWMsgTopicPartition) UpdateMsgTopicPartition 

func (rw *RWMsgTopicPartition) UpdateMsgTopicPartition(ctx context.Context, data *MsgTopicPartition, updates map[string]interface{}) error

Source Files

View all Source files

Jump to

Keyboard shortcuts

? : This menu
/ : Search site
f or F : Jump to
y or Y : Canonical URL
go.dev uses cookies from Google to deliver and enhance the quality of its services and to analyze traffic. Learn more.