offset

type Core struct {
	// contains filtered or unexported fields
}

type ICore interface {
	SetOffset(ctx context.Context, m *Model) error
	RollBackOffset(ctx context.Context, m *Model) error
	GetOffset(ctx context.Context, m *Model) (*Model, error)
	DeleteOffset(ctx context.Context, m *Model) error
	Exists(ctx context.Context, m *Model) (bool, error)

	SetOffsetStatus(ctx context.Context, m *Status) error
	OffsetStatusExists(ctx context.Context, m *Status) (bool, error)
	GetOffsetStatus(ctx context.Context, m *Status) (*Status, error)
	DeleteOffsetStatus(ctx context.Context, m *Status) error
}

type IRepo interface {
	common.IRepo
}

type Model struct {
	common.BaseModel
	Topic        string `json:"topic_id"`
	Subscription string `json:"subscription_id"`
	Partition    int32  `json:"partition_id"`
	LatestOffset int32  `json:"latest_offset_value"`
	OrderingKey  string `json:"ordering_key"`
	// contains filtered or unexported fields
}

type Repo struct {
	common.BaseRepo
}

type Status struct {
	Model
	OffsetStatus string `json:"status,omitempty"`
}